我正在使用 Microsoft 提供的標(biāo)準(zhǔn)代碼向 Azure 事件中心發(fā)送一條消息,它工作正常,但是,我還想為每條消息添加一個(gè)標(biāo)頭以了解有關(guān)該消息的其他詳細(xì)信息。我找不到辦法做到這一點(diǎn),下面是我的嘗試,但沒有奏效。client = EventHubClient(ADDRESS, username=USER, password=KEY, debug=True) sender = client.add_sender(partition="0", send_timeout=2000, keep_alive=500) client.run() try: nevent_data = EventData('Message with properties') nevent_data.properties = {'prop': 'prop1'} sender.send(nevent_data)在這里,我試圖以 dict 的形式發(fā)送屬性和消息正文,下面是監(jiān)聽器。聽眾:client = EventHubClient(ADDRESS, debug=False, username=USER, password=KEY)try: receiver = client.add_receiver( CONSUMER_GROUP, PARTITION, prefetch=5000, offset=OFFSET) client.run() start_time = time.time() while True: for event_data in receiver.receive(timeout=1): print(event_data.properties) print("Received: {}".format(event_data.body_as_str(encoding='UTF-8')))當(dāng)我嘗試獲取屬性時(shí),它出錯(cuò)了。
1 回答

梵蒂岡之花
TA貢獻(xiàn)1900條經(jīng)驗(yàn) 獲得超5個(gè)贊
只需更改上面的一個(gè)參數(shù)即可。
改變
nevent_data.properties = {'prop': 'prop1'}
到
nevent_data.application_properties = {'prop': 'prop1'}
在接收器上做同樣的事情。
print(event_data.application_properties)
添加回答
舉報(bào)
0/150
提交
取消