在Lambda函数中,可以使用以下代码示例来解决此问题:
import boto3 import json
sqs = boto3.client('sqs')
def lambda_handler(event, context):
queue_url = 'YOUR_QUEUE_URL'
messages = [
{
'Id': '1',
'MessageBody': 'Message 1'
},
{
'Id': '2',
'MessageBody': 'Message 2'
},
{
'Id': '3',
'MessageBody': 'Message 3'
}
]
try:
response = sqs.send_message_batch(QueueUrl=queue_url, Entries=messages)
print(f"Response: {json.dumps(response)}")
except Exception as e:
print(f"Error: {e}")
raise e
在上面的示例中,我们使用SQS客户端的send_message_batch方法来将多个消息发送到指定的队列URL。如果超时或出现其他错误,则会引发异常并将其作为Lambda函数的错误返回给调用方。
上一篇:AWSLambda返回“Error:connectETIMEDOUT**.****.***.***:443”
下一篇:AWSLambdaffmpegpython函数错误-[Errno2]找不到文件或目录:'/tmp/resizedVideo.mp4'。