如何使用Python for Azure Data Exp使用动态路由属性

2024-06-26 03:15:31 发布

您现在位置:Python中文网/ 问答频道 /正文

在Azure数据资源管理器中,创建数据连接时有一个名为my table Data contains routing info的选项。如何使用python使用它?在Azure示例(https://github.com/Azure-Samples/event-hubs-dotnet-ingest/blob/master/EventHubSampleData/EventHub2/Program.cs)中,他们使用csharp添加路由属性。如何在python中实现相同的功能?你知道吗

client = EventHubClient(ADDRESS, debug=False, username=USER, password=KEY)
sender = client.add_sender(partition="0")
client.run()
try:
    start_time = time.time()
    employess = [
        {
            "empid": 10,
            "name":"Samir",
            "age": 25
        }
    ]
    for i in employess:
        print("Sending Employee: {}".format(json.dumps(i)))

        sender.send(EventData(json.dumps(i)))
except:
    raise

Tags: 数据infoclientjsondatatimemytable
1条回答
网友
1楼 · 发布于 2024-06-26 03:15:31

github中有一个python代码示例:

data = {}
tableName = 'TestTable'
tableMapping = 'TestMapping'

event = EventData(json.dumps(data).encode('UTF-8'))
event.application_properties = {
    'Table': tableName,
    'Format': "json",
    'IngestionMappingReference': tableMapping,
}
sender.send(event)

如果样品不符合您的需要,请随意修改。你知道吗

相关问题 更多 >