AWS - 通过 Lambda 读取 SQS 消息

Question

以下代码复制自 AWS 文档，但我的代码几乎相同，除了队列 URL 定义部分。

我想以 JSON 格式打印出消息体，但它似乎有一些额外的东西。如何在不使用子字符串的情况下摆脱它们？

# Create SQS client
# blah blah

# Receive message from SQS queue
response = sqs.receive_message(
    QueueUrl=queue_url,
    AttributeNames=[
        'SentTimestamp'
    ],
    MaxNumberOfMessages=1,
    MessageAttributeNames=[
        'All'
    ],
    VisibilityTimeout=0,
    WaitTimeSeconds=0
)

message = response['Messages'][0]
receipt_handle = message['ReceiptHandle']

print('Received and deleted message: %s' % message)

此打印消息具有以下格式：

START RequestId: fe107bc8-3829-4600-9bfc-df89f59b0c70 Version: $LATEST
{JSON body}
END RequestId: fe107bc8-3829-4600-9bfc-df89f59b0c70
REPORT RequestId: fe107bc8-3829-4600-9bfc-df89f59b0c70  Duration: 914.38 ms Billed Duration: 1000 ms    Memory Size: 128 MB Max Memory Used: 71 MB  Init Duration: 247.03 ms

我真正想要的只是 {JSON 正文}。我怎样才能摆脱其余的？

Answer 1

很遗憾您无法删除

START RequestId: fe107bc8-3829-4600-9bfc-df89f59b0c70 Version: $LATEST
END RequestId: fe107bc8-3829-4600-9bfc-df89f59b0c70
REPORT RequestId: fe107bc8-3829-4600-9bfc-df89f59b0c70  Duration: 914.38 ms Billed Duration: 1000 ms    Memory Size: 128 MB Max Memory Used: 71 MB  Init Duration: 247.03 ms

来自 CloudWatch 日志。这是 lambda 函数的标准打印输出行为。

但是，您可以在控制台中使用log event filters，这有助于定位特定的感兴趣的{JSON body}。不过，它是最基本和最快的解决方案。

也可以对您的日志进行更复杂的过滤，但我认为这不是您所追求的。