我想以字典格式向RabbitMQ发送消息:
import pika
# ....
my_msg = {}
my_msg["a"] = 1
my_msg["a"]["b"] = 2
channel.basic_publish(exchange="", routing_key="some_key", body=my_msg)
我得到一个错误:
^{pr2}$
请注意,我有很多my_msg
,并且每个都有一些键,所以我需要能够以某种方式将列表字典发送到RabbitMQ。在
我怎么能做到呢?或者还有其他选择吗?在
Tags:
根据the documentation,
body
应该是一个字符串。在你可以试试
body=json.dumps(my_msg)
您需要将字典序列化为字符串并通过RabbitMQ发送它们。在
见this question
相关问题 更多 >
编程相关推荐