我正在尝试使用Qpid Proton的
Python绑定发送带有自定义属性的消息,但我找不到正确的方法来执行此操作…
message = Message() message.body = u"hello body" data = Data() data.put_map() data.enter() data.put_string("key") data.put_string("value") data.exit() message.properties = data messenger.put(message) messenger.send()
结果是…
Traceback (most recent call last): File "./candy_ingest.py",line 37,in <module> messenger.put(message) File "/usr/lib/python2.7/dist-packages/proton.py",line 473,in put message._pre_encode() File "/usr/lib/python2.7/dist-packages/proton.py",line 781,in _pre_encode props.put_object(self.properties) File "/usr/lib/python2.7/dist-packages/proton.py",line 2036,in put_object putter = self.put_mappings[obj.__class__] KeyError: <class proton.Data at 0x2320420>
欢迎任何帮助!
TIA,
托马斯.
解决方法
这是我用于将RaspBerryPi连接到Windows Azure Service Bus的代码
import sys from proton import * #This code is for initiating the AMQP messenger amqpmng = Messenger() amqpmng._set_timeout(2000L) #Set timeout for sending and receiving at 2000 ms address = "amqp://owner:<longpassword>@<namespace>.servicebus.windows.net/<queuename>" #This code is for creating messages msg = Message() msg.subject = "This is a testmessage" msg.body = "Lorem ipsum dolor sit amet,consectetuer adipiscing elit." #This code is for sending messages try: msg.address = address amqpmng.put(msg) amqpmng.send() except: e = sys.exc_info()[0] print e,"Waited for 2s to send messages,nothing send,connection timed out" amqpmng.stop(); #This code is for receiving messages amqpmng.subscribe(address) amqpmng.start() try: amqpmng.recv(1) #receive exactly 1 message (you can enter any value) msg = Message() while amqpmng.incoming > 0: amqpmng.get(msg) print(msg.body) except: e = sys.exc_info()[0] print e,"Waited for 2s to receive messages,nothing received,connection timed out" amqpmng.stop()
此外,消息类只有两个将数据作为参数的方法.
message.decode(data) message.load(data)
我认为你应该使用message.load(data).
我从API参考中理解的是,message.properties使用python类dict来映射他的类属性.
如果它有用,请告诉我!