我正在使用 Microsoft 提供的標準代碼向 Azure 事件中心發送一條消息,它工作正常,但是,我還想為每條消息添加一個標頭以了解有關該消息的其他詳細信息。我找不到辦法做到這一點,下面是我的嘗試,但沒有奏效。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 的形式發送屬性和消息正文,下面是監聽器。聽眾: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')))當我嘗試獲取屬性時,它出錯了。
1 回答

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