azure_eventhub_async_batch_send_with_producer_client.py

1import asyncio
2from azure.eventhub.aio import EventHubProducerClient
3from azure.eventhub import EventData
4
5async def run():
6    # Create a producer client to send messages to the event hub.
7    # Specify a connection string to your event hubs namespace and
8    # the event hub name.
9    producer = EventHubProducerClient.from_connection_string(
10        conn_str="EVENT_HUBS_NAMESPACE_CONNECTION_STRING", 
11        eventhub_name="EVENT_HUB_NAME"
12    )
13    async with producer:
14        # Create a batch
15        event_data_batch = await producer.create_batch()
16
17        # Add events to the batch.
18        event_data_batch.add(EventData("First event "))
19        event_data_batch.add(EventData("Second event"))
20        event_data_batch.add(EventData("Third event"))
21
22        # Send the batch of events to the event hub.
23        await producer.send_batch(event_data_batch)
24
25asyncio.run(run())