Azure/azure-sdk-for-python azure-eventhub_5.0.0b2

on GitHub

New features

• Added method create_batch on the EventHubProducer to create an EventDataBatch that can then be used to add events until the maximum size is reached.
  • This batch object can then be used in the send() method to send all the added events to Event Hubs.
  • This allows publishers to build batches without the possibility of encountering the error around the message size exceeding the supported limit when sending events.
  • It also allows publishers with bandwidth concerns to control the size of each batch published.
• Added new configuration parameters for exponential delay between retry operations.
  • retry_total: The total number of attempts to redo the failed operation.
  • backoff_factor: The delay time factor.
  • backoff_max: The maximum delay time in total.
• Added support for context manager on EventHubClient.
• Added new error type OperationTimeoutError for send operation.
• Introduced a new class EventProcessor which replaces the older concept of Event Processor Host. This early preview is intended to allow users to test the new design using a single instance of EventProcessor. The ability to checkpoints to a durable store will be added in future updates.
  • EventProcessor: EventProcessor creates and runs consumers for all partitions of the eventhub.
  • PartitionManager: PartitionManager defines the interface for getting/claiming ownerships of partitions and updating checkpoints.
  • PartitionProcessor: PartitionProcessor defines the interface for processing events.
  • CheckpointManager: CheckpointManager takes responsibility for updating checkpoints during events processing.

Breaking changes

• EventProcessorHost was replaced by EventProcessor, please read the new features for details.
• Replaced max_retries configuration parameter of the EventHubClient with retry_total.