如何在boto3中设置SQS消息class?

How to set the SQS message class in boto3?

我正在从 boto 迁移到 boto3。

以下代码段将消息 class 设置为我的 sqs:

conn = boto.sqs.connect_to_region(my_region)
queue = conn.create_queue(queue_name)
queue.set_message_class(boto.sqs.message.RawMessage)

如何使用 boto3 执行此操作?

您需要创建 SQS Client 并使用它。您不再需要设置 RawMessage class。

import boto3
client = boto3.client('sqs')
response = client.send_message(
    QueueUrl='string',
    MessageBody='string',
    DelaySeconds=123,
    MessageAttributes={
        'string': {
            'StringValue': 'string',
            'BinaryValue': b'bytes',
            'StringListValues': [
                'string',
            ],
            'BinaryListValues': [
                b'bytes',
            ],
            'DataType': 'string'
        }
    },
    MessageDeduplicationId='string',
    MessageGroupId='string'
)

来源:https://boto3.readthedocs.io/en/latest/reference/services/sqs.html#SQS.Client.send_message