问题的解决方法是在AWS CloudFormation Lambda的代码中添加缺少的代码,以确保所有消息都被发送到SQS。
以下是一个示例代码,演示如何使用AWS SDK for Python(Boto3)发送消息到SQS:
import boto3
sqs = boto3.client('sqs')
def lambda_handler(event, context): response = sqs.send_message( QueueUrl='QUEUE_URL', DelaySeconds=0, MessageBody=( 'This is a test message' ) )
print(response['MessageId'])
注意,此代码未添加错误处理,因此在实际使用中应该添加适当的错误检查和处理。此外,请记得将QUEUE_URL替换为您的SQS队列的URL。
完成此更改后,重新部署AWS CloudFormation模板和Lambda代码。现在,当Lambda函数运行时,所有消息应该都被正确地发送到SQS。