使用Python绑定在Qpid Proton中设置自定义消息属性
发布时间：2020-12-20 13:40:48 所属栏目：Python 来源：网络整理
导读：我正在尝试使用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") da
|
我正在尝试使用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来映射他的类属性. 如果它有用,请告诉我！ （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |