1

Azure 流分析的新手。我正在使用下面的 Python 程序将事件发送到 Azure 事件中心，方法是将响应\数据序列化为JSON格式，以便流分析作业输入可以读取它。但是，有一些错误或我丢失了，因此我无法在流分析作业中查看测试数据。

import asyncio
import time
import requests
import json
from azure.eventhub.aio import EventHubProducerClient
from azure.eventhub import EventData

connection_str = 'XXX'
consumer_group = 'XXX'
eventhub_name = 'XXX'

async def run():
    # create a producer client to send messages to the event hub
    # specify connection string to your event hubs namespace and
    # the event hub name
    producer = EventHubProducerClient.from_connection_string(connection_str, consumer_group=consumer_group, eventhub_name=eventhub_name)

    async with producer:
        # create a batch        
        event_data_batch = await producer.create_batch(partition_id='1')

        while True:
            # add events to the batch
            response = requests.get("https://jsonplaceholder.typicode.com/todos/1")

            data = json.loads(response.text)        

            event_data_batch.add(EventData(data))

            time.sleep(5)

            # send the batch of events to the event hub
            await producer.send_batch(event_data_batch)

loop = asyncio.get_event_loop()
loop.run_until_complete(run())
4

0 回答 0