Publish and consume Azure Event Hubs events from Python with checkpointing.
npx skills add https://github.com/rrbanda/skills --skill azure-eventhub-py-rrbanda
Please help me install this Agent Skill. Skill: azure-eventhub-py Source: https://github.com/rrbanda/skills/tree/main/skills/data/azure-eventhub-py Command: npx skills add https://github.com/rrbanda/skills --skill azure-eventhub-py-rrbanda
Python developers implementing streaming workloads often struggle to reliably ingest and process high-volume data with Azure Event Hubs. This skill provides ready-to-run patterns and code examples to publish and consume events from Event Hubs using Python, with built-in checkpointing and partition-aware patterns.
Install dependencies and run scripts/setup_consumer.py receive to start consuming events from your Event Hub.
High-intent search queries and answers about installing and using this skill.
Partition-aware receive in Azure Event Hubs processes events from specific partitions rather than the entire hub. This allows Python consumers to scale out by assigning individual partitions to separate workers for higher throughput and ordered processing.
Yes, you can use async authentication for Azure Event Hubs streaming in Python. The azure-identity library enables async authentication, while environment-based configuration safely supplies connection credentials without hardcoding them directly in your application code.
The best way to inspect Azure Event Hub partitions before consuming events is using CLI utilities. These scripts provide immediate info and testing capabilities, allowing you to verify partition structures and hub connectivity without writing custom boilerplate code.
Yes, you need an Azure Blob Storage account to enable checkpointing for Event Hubs consumers. The azure-eventhub-checkpointstoreblob dependency persists consumer offset states directly to Blob Storage, ensuring reliable fault tolerance during high-throughput streaming.
delorenjPublish and consume typed events on the Bloodbank event bus with RabbitMQ routing.
delta-and-betaStream Braze Currents events to data warehouses with Avro or JSON formats.
microsoftAutomate Azure Blob Storage container, blob, and metadata operations with Python.
davidrrowleyIngest event streams into Azure Event Hubs with checkpointed Python consumers.
