构造boto sqs fifo MessageGroupId

2024-05-14 01:50:37 发布

您现在位置:Python中文网/ 问答频道 /正文

当前正在使用boto(不是boto3)并试图为FIFO队列构造消息-但它一直抱怨没有MessageGroupId。(boto)文档对此字段完全没有说明,我无法确定在何处设置此信息。在

设置:

from boto import sqs
from boto.sqs.message import Message
sqs = boto.resource('sqs')
conn = sqs.connect_to_region('my_region')
fifo = conn.get_queue('my-queue.fifo')

尝试1:

^{pr2}$

好吧,好吧,它不属于message.attribute,那。。。message.message_attributes

>> m = Message()
>> m.message_attributes['MessageGroupId'] = 'group1'
>> m.set_body('test 1')
>> fifo.write(m)

## same error as above

也许我需要把它当作一个论据?在

>> M = Message(MessageGroupId='group1')

TypeError: unexpected keyword arg

所以,我的问题是:如何在boto中构造一个有效的FIFOmessage?让我们从MessageGroupId开始,但是如果MessageDeduplicationId有什么不同的地方,也请包括这些信息(我没有使用ContentBasedDeduplication)。在


Tags: fromimport信息messagequeuemyconnregion