当前正在使用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
中构造一个有效的FIFO
message
?让我们从MessageGroupId
开始,但是如果MessageDeduplicationId
有什么不同的地方,也请包括这些信息(我没有使用ContentBasedDeduplication
)。在
目前没有回答
相关问题 更多 >
编程相关推荐