amazon-web-services - 无法使用 boto3 访问 SQS 消息属性

Question

我正在尝试将带有属性的消息传递到 AWS SQS，然后检索该消息。 尽管我可以通过管理控制台查看消息的属性，但我无法使用 boto3 获取它们，总是获取 None。更改“AttributeNames”不会产生任何影响。消息正文可以正常检索。

import boto3
sqs = boto3.resource('sqs', region_name = "us-west-2")
queue = sqs.get_queue_by_name(QueueName='test')

queue.send_message(MessageBody = "LastEvaluatedKey",
                   MessageAttributes ={
                           'class_number':{
                                          "StringValue":"Value value ",
                                          "DataType":"String"
                                            }
                                        }
                    )
messages = queue.receive_messages(
                                  MaxNumberOfMessages=1,
                                  AttributeNames=['All']
                                   )
for msg in messages:
    print(msg.message_attributes) # returns None
    print(msg.body) # returns correct value

Answer 1

属性(系统生成)和消息属性(用户定义)是back-end API提供的两种不同类型的东西。 。

您正在寻找消息属性，但您要求代码获取属性。

AttributeNames=['All']`

看来您需要获取消息属性...

MessageAttributeNames=['All']

...调用queue.receive_messages()时。或者，您想要的特定消息属性名称(如果已知)可以用来代替 'All'(如果我设计了此 API，它会被称为 '*' ，但我离题了)。

诚然，这只是我基于对底层API熟悉程度的直观猜测，但似乎与 http://boto3.readthedocs.io/en/latest/guide/sqs.html 一致。 .