我尝试使用以下lambda代码将sqs消息放入S3存储桶中。代码将实现这一点,但是我需要弄清楚如何定义messageId,以便放置在S3 bucket中的每个对象都具有与sqs messageId相同的名称
import json
import boto3
def lambda_handler(event, context):
s3 = boto3.client("s3")
data = json.loads(event["Records"][0]["body"])
s3.put_object(Bucket="dlqbucket", Key="messageId", Body=json.dumps(data))
# TODO implement
return {
'statusCode': 200,
'body': json.dumps('Hello from lambda')
}
以下是从Amazon SQS到AWS Lambda函数的传入记录示例:
因此,您可以通过以下方式获得
messageId
:ReceiveMessage Receive Elements @ docs.aws.amazon.com
相关问题 更多 >
编程相关推荐