Azure事件中心:如何查看事件中心的功能?

k4emjkb1  于 2023-06-30  发布在  其他
关注(0)|答案(1)|浏览(129)

我继承了Azure Event Hub作为管理和使用的资源。不幸的是,没有文件。我只能看到一个事件中心命名空间资源,并且有一个活动的事件中心实体。如果我点击它,只有一个$Default消费者组,我不能弄清楚事件中心做什么。是否可以查看事件中心的功能以及如何通过事件中心检索信息?
谢谢!
编辑:这是我正在使用的当前代码。我可以进行身份验证,但我没有收到任何消息,或者我无法检索Event Hub提供的内容。如何接收数据?

from confluent_kafka import Consumer, KafkaException, KafkaError

bootstrap_servers = SERVER
topic = TEST_HUB
group_id = ID

# Kafka Config

consumer_config = {
    'bootstrap.servers': bootstrap_servers,
    'group.id': group_id,
    'auto.offset.reset': 'earliest',
    'enable.auto.commit': False,
    'security.protocol': 'SASL_SSL',
    'sasl.mechanism': 'PLAIN',
    'sasl.username': '$ConnectionString',
    'sasl.password': MY_EVENT_HUB_ENDPOINT
}

# Consumer
consumer = Consumer(consumer_config)

# Subscribe to the azure event hub
consumer.subscribe([topic])

# Consume messages from Kafka 
try:
    while True:
        message = consumer.poll(5.0)

        if message is None:
            continue

        if message.error():
            if message.error().code() == KafkaError._PARTITION_EOF:
                # End of partition event
                continue
            else:
                # Handle error
                print(f"Error: {message.error().str()}")
                break

        # Process the Kafka message
        key = message.key()
        value = message.value()
        print(value)

        # Commit the message offset
        consumer.commit(message)

except KeyboardInterrupt:
    pass

finally:
    # Close
    consumer.close()
k5ifujac

k5ifujac1#

事件中心向任何希望阅读事件的消费者公开事件。详情请参阅:Azure Event Hubrefer1refer2
希望能帮上忙。

相关问题