物联网中心事件python答案

【问题标题】：Iot hub event python物联网中心事件python
【发布时间】：2018-11-10 18:56:36
【问题描述】：

我已经搜索了很多，我正在尝试使用 python，使用 azure event sdk 将接收器连接到我在 azure 上的 iot 集线器，但遗憾的是没有成功，我的接收器告诉我它已与客户端连接，但是它从不真正查看数据

我的收件人是

    #!/usr/bin/env python

# --------------------------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
# --------------------------------------------------------------------------------------------

"""
An example to show receiving events from an Event Hub partition.
"""
import os
import sys
import logging
import time
from azure.eventhub import EventHubClient, Receiver, Offset

# Address can be in either of these formats:
# "amqps://<URL-encoded-SAS-policy>:<URL-encoded-SAS-key>@<mynamespace>.servicebus.windows.net/myeventhub"
# "amqps://<mynamespace>.servicebus.windows.net/myeventhub"
ADDRESS ="amqps://iothub-ns-virtualab2-926709-043cc22e89.servicebus.windows.net/virtualab2"

# SAS policy and key are not required if they are encoded in the URL
USER = "iothubowner"
KEY = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
CONSUMER_GROUP = "teststream"
OFFSET = Offset("-1")
PARTITION = "1"


total = 0
last_sn = -1
last_offset = "-1"
client = EventHubClient(ADDRESS, debug=True, username=USER, password=KEY)

try:
    receiver = client.add_receiver(CONSUMER_GROUP, PARTITION, prefetch=5000, offset=OFFSET)
    client.run()
    print("client connected")
    start_time = time.time()
    print("listening")
    batch = receiver.receive(timeout=5000)

    while batch:
        for event_data in batch:
            last_offset = event_data.offset
            last_sn = event_data.sequence_number
            print("Received: {}, {}".format(last_offset.value, last_sn))
            print(event_data.body_as_str())
            total += 1
        batch = receiver.receive(timeout=5000)

    end_time = time.time()
    client.stop()
    run_time = end_time - start_time
    print("Received {} messages in {} seconds".format(total, run_time))

except KeyboardInterrupt:
    pass
finally:
    client.stop()

我正在使用来自 iot hub 的 quickstart 中的标准发件人

【问题讨论】：

标签： python azure iot azure-iot-hub azure-eventhub

【解决方案1】：

您拥有的代码确实有效，但是您需要检查以下几点：

如果您使用的是 IoT 中心内置事件终结点，请确保您使用的是与事件中心兼容的终结点中的命名空间名称以及与事件中心兼容的名称。我测试的地址如下：amqps://ihsuprodbyresXXXXXXnamespace.servicebus.windows.net/iothub-ehub-sample-XXXXX-XXXXXXXXXX
- 确保您使用的是iothubowner 键值。
- 确保您使用的使用者组已添加到与事件中心兼容的端点。
- 默认情况下，与事件中心兼容的终结点有两个分区 - 您的代码仅侦听其中一个分区上的消息。

【讨论】：