时间戳

首页 > 解决方案 > 如何通过python向事件中心发送消息

azure-eventhub - 如何通过python向事件中心发送消息

问题描述

我正在尝试将许多 iot 对象连接到 eventthub 并将它们保存到 blob 存储（也是一个 sql 数据库）。我想用 python 来做这个（我不确定这是否是推荐的做法）。关于 python 的文档令人困惑。我尝试了一些示例，但它们创建了一个 blob 存储条目，但条目似乎无关紧要。

像这样的东西： Objavro.codecnullavro.schema\EC{"type":"record","name":"EventData","namespace":"Microsoft.ServiceBus.Messaging","fields":[{"name": "SequenceNumber","type":"long"}...

这不是我发送的。我该如何解决这个问题？

标签： azure-eventhub

解决方案

您可以使用 azure-eventhub Python SDK 将消息发送到pypi上可用的事件中心。

还有一个发送示例显示如何发送消息：

import os
from azure.eventhub import EventHubProducerClient, EventData
producer = EventHubProducerClient.from_connection_string(
    conn_str=CONNECTION_STR,
    eventhub_name=EVENTHUB_NAME
)
with producer:
    event_data_batch = producer.create_batch()
    event_data_batch.add(EventData('Single message'))
    producer.send_batch(event_data_batch)

我感兴趣的是The documentation about python was confusing. I tried a few examples but they create an entry to blob storage but entries seems to be irrelevant.

你能和我分享你的代码吗？我想知道事件中心和存储 Blob 的输入/输出是什么，以及数据处理流程如何。

顺便说一句，对于 Azure Storage Blob Python SDK 的使用，您可以查看repo和 [blob samples] 以获取更多信息。

推荐阅读