时间戳

首页 > 解决方案 > 使用 python 应用程序将数据发送到 azure 事件中心

python - 使用 python 应用程序将数据发送到 azure 事件中心

问题描述

我正在使用我的 python 应用程序向事件中心发送 JSON 转储。我的连接字符串的形式是

connection_string="端点=sb://xyz.servicebus.windows.net/;SharedAccessKeyName=abc;SharedAccessKey=pqr"

我得到以下回复

令牌放置完成，结果：0，状态：202，描述：b'Accepted'，连接：xxxxxxxxx

但是我没有在eventhub中看到数据。我也没有收到任何错误。我的问题是正在发送的事件？如果事件发送成功，我们应该不会得到响应码 200 吗？

我的代码来自这个链接

from azure.eventhub import EventHubProducerClient, EventData

def send_event_data_batch(producer, data):
    # Without specifying partition_id or partition_key
    # the events will be distributed to available partitions via round-robin.
    event_data_batch = producer.create_batch()
    event_data_batch.add(EventData(data))
    try:
        producer.send_batch(event_data_batch)
    except Exception as exp:
        _LOG.info(type(exp).__name__)
        _LOG.info(exp.args)
    producer.close()


def send_data_to_event_hub(data):
    producer = EventHubProducerClient.from_connection_string(
        conn_str=connection_string,
        eventhub_name="EVENT HUB NAME" )
    with producer:
        send_event_data_batch(producer, data)
    producer.close()

标签： pythonazuremessage-queueazure-eventhub

解决方案

send() 方法如果成功则不返回任何内容 ( None)，如果不成功则引发家庭错误EventHubError。“Token put complete with result: 0, status: 202, description: b'Accepted', connection:xxxxxxxxx”是建立连接的日志信息。

推荐阅读