2 回答

TA貢獻(xiàn)1946條經(jīng)驗(yàn) 獲得超4個(gè)贊
這里重要的是EventData
object 只需要string 或 bytes。Python SDK 不會(huì)為您讀取文件,只會(huì)將該文件路徑作為原始數(shù)據(jù)字符串并將該字符串發(fā)送到事件中心。
因此,您需要做的是打開文件并將內(nèi)容加載到字節(jié)數(shù)組中,然后將字節(jié)傳遞給EventData
構(gòu)造函數(shù) -- EventData(body=loaded_bytes)
。請注意,根據(jù)您選擇的層級(基本/標(biāo)準(zhǔn)) ,活動(dòng)規(guī)模有配額限制。
值得注意的是,azure-eventhub v5 已于 2020 年 1 月 GAed。
它在 pypi 上可用:https ://pypi.org/project/azure-eventhub/
請按照從 v1 到 v5 的遷移指南遷移您的程序。
還有一個(gè)示例文件夾示例供您開始使用。

TA貢獻(xiàn)1829條經(jīng)驗(yàn) 獲得超9個(gè)贊
問題在于您嘗試將數(shù)據(jù)發(fā)送到事件中心的方式。您不能直接調(diào)用此函數(shù)并傳遞文件夾以處理文件,如下所示:
sender.send(EventData("C:/Users/shef123/Desktop/"))
您可以查看此鏈接以讀取 json 文件:
https://www.simplifiedpython.net/python-read-json-file/
您可以從文件夾中讀取 JSON 文件,并且可以使用類似的代碼一一發(fā)送。
您可以在 beloe repo 中找到與發(fā)送數(shù)據(jù)相關(guān)的代碼:
https://github.com/Azure/azure-event-hubs-python/blob/master/examples/send_async.py
添加回答
舉報(bào)