def pack(tag, msg):
'''
tags look like '/namespace/type'
msg is a dictionary containing the message to be processed
'''
return msgpack.dumps({'tag': tag, 'data': msg})
微信
公众号
扫码关注公众号