据我所知，你可以使用Azure事件中心。你可以使用Python的事件中心客户端库来使用来自Azure事件中心的数据。

pip install azure-eventhub

示例代码：

from azure.eventhub import EventHubProducerClient, EventData
CONNECTION_STR "{Event Hubs Connection String}"
EVENTHUB_NAME = "{Event Hub name}"

producer = EventHubProducerClient.from_connection_string(CONNECTION_STR, eventhub_name=EVENTHUB_NAME)

for word in words.split():
  event_data_batch = producer.create_batch()
  event_data = EventData(word)
  try:
    event_data_batch.add(event_data)
  except ValueError:
    producer.send_batch(event_data_batch)
    event_data_batch = producer.create_batch()
    event_data_batch(event_data_batch)

producer.send_batch(event_data_batch)

在本地示例上，代码如下：

from azure.eventhub import EventHubConsumerClient

CONNECTION_STR = "{Event Hubs connection string}"
EVENTHUB_NAME = "{Event Hub name}"
CONSUMER_GROUP = "$default"

consumer = EventHubConsumerClient.from_connection_string(CONNECTION_STR, consumer_group=CONSUMER_GROUP, eventhub_name=EVENTHUB_NAME)

def on_event(partition_context, event):
  print(event,body_as_str())

with consumer:
  consumer.receive(on_event)