python - 通过 zmq ipc 发送现有的字典

Question

我正在尝试通过 zmq ipc 套接字发送一个现有的字典，我可以用这段代码发送一个字符串，但我不能发送一个字典对象

import zmq, datetime

d = {0: ('356612022462768', 'EVENT', 0, '2012-12-26 15:50:16', -20.22216, -70.13723, 6.44, 134.0, 1, 2, '18743230', datetime.datetime(2013, 2, 10, 9, 6, 2, 362734))}

if __name__ == "__main__":
    context = zmq.Context()
    publisher = context.socket(zmq.PUB)
    publisher.connect("ipc://shared")
    while True:
        publisher.send( d )
        time.sleep( 1 )

---

TypeError: {0: ('356612022462768', 'EVENT', 0, '2012-12-26 15:50:16', 
           -20.22216, -70.13723, 6.44, 134.0, 1, 2, '18743230', 
           datetime.datetime(2013, 2, 10, 9, 6, 2, 362734))} 
does not provide a buffer interface.

我该怎么做？

Answer 1

只能通过开箱即用的 ZeroMq 发送字符串或字节数组。在将任何其他内容传递给 ZeroMq 进行在线传输之前，都需要对其进行序列化。

您可以使用任何您喜欢的方式对其进行序列化，例如 Protocol Buffers、JSON 或 Message Pack。请注意，任何收件人都需要能够使用相同的协议(protocol)反序列化数据。

您可以找到有关如何将各种序列化技术(包括 numpy 数组)与 pyzmq 结合使用的示例 here .它们是 pyzmq source 的一部分.