如何在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
我正在从 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