-
Notifications
You must be signed in to change notification settings - Fork 17
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
SqsConsumer with Lambda didn't work #17
Comments
Yes, the lambda mode is broken atm, I've linked an issue with the details. |
@lesimoes Please share your solution |
@funkel1989 I did create another package because my solution doen't use same approach (consumer). |
Thanks all for creating solutions for this problem, it's been very helpful for me to understand the different options there are for sending and receiving large SQS messages. I see @funkel1989 has since created Battle-Line-Productions/sqs-large-payload-nodejs which looks good for my use case since it separates the processing of the sent SQS message from the receiving, so I can wire it into an SQS-triggered lambda which delivers the message to the lambda. Just thought I'd mention it here in case as seems somewhat related to this issue and may serve as an inspiration for this ticket and I see the above repo's author (@funkel1989) in the comments above. If you have any other relevant info Michael, please feel free to comment. |
Hello, I tried use package with my lambda functions, for SqsProducer works fine, it send a payload json to S3 Bucket, but my problem is when I need to consume a message that was sent to S3. I tried like this example: https://github.com/aspecto-io/sns-sqs-big-payload/blob/HEAD/docs/usage-in-lambda.md
But never runs the handleMessage function and always returns undefined response. The transformMessageBody runs but with body param undefined too.
My function getMessage should return a message payload.
This is my entire message payload
I send the first object of array Records, like this.
I really believe that I missed something but I dont know where. Could you help me?
Thanks.
The text was updated successfully, but these errors were encountered: