aio Package

Classes

CheckpointStore	CheckpointStore deals with the interaction with the chosen storage service. It can list and claim partition ownerships as well as list and save checkpoints.
EventHubConsumerClient	The EventHubConsumerClient class defines a high level interface for receiving events from the Azure Event Hubs service. The main goal of EventHubConsumerClient is to receive events from all partitions of an EventHub with load-balancing and checkpointing. When multiple EventHubConsumerClient instances are running against the same event hub, consumer group and checkpointing location, the partitions will be evenly distributed among them. To enable load-balancing and persisted checkpoints, checkpoint_store must be set when creating the EventHubConsumerClient. If a checkpoint store is not provided, the checkpoint will be maintained internally in memory. An EventHubConsumerClient can also receive from a specific partition when you call its method receive() or receive_batch() and specify the partition_id. Load-balancing won't work in single-partition mode. But users can still save checkpoints if the checkpoint_store is set.
EventHubProducerClient	The EventHubProducerClient class defines a high level interface for sending events to the Azure Event Hubs service.
EventHubSharedKeyCredential	The shared access key credential used for authentication.
PartitionContext	Contains partition related context information. A PartitionContext instance will be passed to the event, error and initialization callbacks defined when calling EventHubConsumerClient.receive(). Users can call update_checkpoint() of this class to persist checkpoint data.