Index

A

Amqp (azure.eventhub.TransportType attribute) AmqpOverWebsocket (azure.eventhub.TransportType attribute) application_properties() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property) args (azure.eventhub.aio.eventprocessor.OwnershipLostError attribute) (azure.eventhub.aio.eventprocessor.partition_manager.OwnershipLostError attribute) (azure.eventhub.AuthenticationError attribute) (azure.eventhub.ConnectError attribute) (azure.eventhub.ConnectionLostError attribute) (azure.eventhub.error.AuthenticationError attribute) (azure.eventhub.error.ConnectError attribute) (azure.eventhub.error.ConnectionLostError attribute) (azure.eventhub.error.EventDataError attribute) (azure.eventhub.error.EventDataSendError attribute) (azure.eventhub.error.EventHubError attribute) (azure.eventhub.error.OperationTimeoutError attribute) (azure.eventhub.EventDataError attribute) (azure.eventhub.EventDataSendError attribute) (azure.eventhub.EventHubError attribute) AuthenticationError, [1] azure (module)

azure.eventhub (module) azure.eventhub.aio (module) azure.eventhub.aio.client_async (module) azure.eventhub.aio.consumer_async (module) azure.eventhub.aio.error_async (module) azure.eventhub.aio.eventprocessor (module) azure.eventhub.aio.eventprocessor.event_processor (module) azure.eventhub.aio.eventprocessor.partition_context (module) azure.eventhub.aio.eventprocessor.partition_manager (module) azure.eventhub.aio.eventprocessor.partition_processor (module) azure.eventhub.aio.eventprocessor.sample_partition_manager (module) azure.eventhub.aio.eventprocessor.utils (module) azure.eventhub.aio.producer_async (module) azure.eventhub.client (module) azure.eventhub.client_abstract (module) azure.eventhub.common (module) azure.eventhub.configuration (module) azure.eventhub.consumer (module) azure.eventhub.error (module) azure.eventhub.extensions (module) azure.eventhub.producer (module)

B

body() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property) body_as_json() (azure.eventhub.common.EventData method) (azure.eventhub.EventData method)

body_as_str() (azure.eventhub.common.EventData method) (azure.eventhub.EventData method)

C

checkpoint_fields (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute) claim_ownership() (azure.eventhub.aio.eventprocessor.partition_manager.PartitionManager method) (azure.eventhub.aio.eventprocessor.PartitionManager method) (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager method) (azure.eventhub.aio.eventprocessor.SamplePartitionManager method) close() (azure.eventhub.aio.client_async.EventHubClient method) (azure.eventhub.aio.consumer_async.EventHubConsumer method) (azure.eventhub.aio.EventHubClient method) (azure.eventhub.aio.EventHubConsumer method) (azure.eventhub.aio.EventHubProducer method) (azure.eventhub.aio.eventprocessor.partition_processor.PartitionProcessor method) (azure.eventhub.aio.eventprocessor.PartitionProcessor method) (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager method) (azure.eventhub.aio.eventprocessor.SamplePartitionManager method) (azure.eventhub.aio.producer_async.EventHubProducer method) (azure.eventhub.client.EventHubClient method) (azure.eventhub.consumer.EventHubConsumer method) (azure.eventhub.EventHubClient method) (azure.eventhub.EventHubConsumer method) (azure.eventhub.EventHubProducer method) (azure.eventhub.producer.EventHubProducer method)

CloseReason (class in azure.eventhub.aio.eventprocessor) (class in azure.eventhub.aio.eventprocessor.partition_processor) ConnectError, [1] ConnectionLostError, [1] create_batch() (azure.eventhub.aio.EventHubProducer method) (azure.eventhub.aio.producer_async.EventHubProducer method) (azure.eventhub.EventHubProducer method) (azure.eventhub.producer.EventHubProducer method) create_consumer() (azure.eventhub.aio.client_async.EventHubClient method) (azure.eventhub.aio.EventHubClient method) (azure.eventhub.client.EventHubClient method) (azure.eventhub.EventHubClient method) create_producer() (azure.eventhub.aio.client_async.EventHubClient method) (azure.eventhub.aio.EventHubClient method) (azure.eventhub.client.EventHubClient method) (azure.eventhub.EventHubClient method)

E

encode_message() (azure.eventhub.common.EventData method) (azure.eventhub.EventData method) enqueued_time() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property) EventData (class in azure.eventhub) (class in azure.eventhub.common) EventDataBatch (class in azure.eventhub) (class in azure.eventhub.common) EventDataError, [1] EventDataSendError, [1] EVENTHUB_EXCEPTION (azure.eventhub.aio.eventprocessor.CloseReason attribute) (azure.eventhub.aio.eventprocessor.partition_processor.CloseReason attribute) EventHubClient (class in azure.eventhub) (class in azure.eventhub.aio) (class in azure.eventhub.aio.client_async) (class in azure.eventhub.client) EventHubClientAbstract (class in azure.eventhub.client_abstract)

EventHubConsumer (class in azure.eventhub) (class in azure.eventhub.aio) (class in azure.eventhub.aio.consumer_async) (class in azure.eventhub.consumer) EventHubError, [1] EventHubProducer (class in azure.eventhub) (class in azure.eventhub.aio) (class in azure.eventhub.aio.producer_async) (class in azure.eventhub.producer) EventHubSASTokenCredential (class in azure.eventhub) (class in azure.eventhub.common) EventHubSharedKeyCredential (class in azure.eventhub) (class in azure.eventhub.common) EventPosition (class in azure.eventhub) (class in azure.eventhub.common) EventProcessor (class in azure.eventhub.aio.eventprocessor) (class in azure.eventhub.aio.eventprocessor.event_processor)

F

fields (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute) fields_dict (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute)

from_connection_string() (azure.eventhub.aio.client_async.EventHubClient class method) (azure.eventhub.aio.EventHubClient class method) (azure.eventhub.client.EventHubClient class method) (azure.eventhub.client_abstract.EventHubClientAbstract class method) (azure.eventhub.EventHubClient class method)

G

get_partition_ids() (azure.eventhub.aio.client_async.EventHubClient method) (azure.eventhub.aio.EventHubClient method) (azure.eventhub.client.EventHubClient method) (azure.eventhub.EventHubClient method) get_partition_properties() (azure.eventhub.aio.client_async.EventHubClient method) (azure.eventhub.aio.EventHubClient method) (azure.eventhub.client.EventHubClient method) (azure.eventhub.EventHubClient method)

get_properties() (azure.eventhub.aio.client_async.EventHubClient method) (azure.eventhub.aio.EventHubClient method) (azure.eventhub.client.EventHubClient method) (azure.eventhub.EventHubClient method) get_running_loop() (in module azure.eventhub.aio.eventprocessor.utils) get_sas_token() (azure.eventhub.common.EventHubSASTokenCredential method) (azure.eventhub.EventHubSASTokenCredential method)

I

initialize() (azure.eventhub.aio.eventprocessor.partition_processor.PartitionProcessor method) (azure.eventhub.aio.eventprocessor.PartitionProcessor method)

L

last_enqueued_event_properties() (azure.eventhub.aio.consumer_async.EventHubConsumer property) (azure.eventhub.aio.EventHubConsumer property) (azure.eventhub.consumer.EventHubConsumer property) (azure.eventhub.EventHubConsumer property)

list_ownership() (azure.eventhub.aio.eventprocessor.partition_manager.PartitionManager method) (azure.eventhub.aio.eventprocessor.PartitionManager method) (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager method) (azure.eventhub.aio.eventprocessor.SamplePartitionManager method)

N

next() (azure.eventhub.consumer.EventHubConsumer method) (azure.eventhub.EventHubConsumer method)

O

offset() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property) OperationTimeoutError other_fields (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute)

other_fields_dict (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute) OWNERSHIP_LOST (azure.eventhub.aio.eventprocessor.CloseReason attribute) (azure.eventhub.aio.eventprocessor.partition_processor.CloseReason attribute) OwnershipLostError, [1]

P

parse_sas_token() (in module azure.eventhub.common) partition_key() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property) PartitionContext (class in azure.eventhub.aio.eventprocessor) (class in azure.eventhub.aio.eventprocessor.partition_context) PartitionManager (class in azure.eventhub.aio.eventprocessor) (class in azure.eventhub.aio.eventprocessor.partition_manager) PartitionProcessor (class in azure.eventhub.aio.eventprocessor) (class in azure.eventhub.aio.eventprocessor.partition_processor) primary_keys (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute) primary_keys_dict (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager attribute) (azure.eventhub.aio.eventprocessor.SamplePartitionManager attribute) process_error() (azure.eventhub.aio.eventprocessor.partition_processor.PartitionProcessor method) (azure.eventhub.aio.eventprocessor.PartitionProcessor method) process_events() (azure.eventhub.aio.eventprocessor.partition_processor.PartitionProcessor method) (azure.eventhub.aio.eventprocessor.PartitionProcessor method) PROCESS_EVENTS_ERROR (azure.eventhub.aio.eventprocessor.CloseReason attribute) (azure.eventhub.aio.eventprocessor.partition_processor.CloseReason attribute)

PROP_LAST_ENQUEUED_OFFSET (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_LAST_ENQUEUED_SEQUENCE_NUMBER (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_LAST_ENQUEUED_TIME_UTC (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_OFFSET (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_PARTITION_KEY (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_PARTITION_KEY_AMQP_SYMBOL (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_RUNTIME_INFO_RETRIEVAL_TIME_UTC (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_SEQ_NUMBER (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute) PROP_TIMESTAMP (azure.eventhub.common.EventData attribute) (azure.eventhub.EventData attribute)

Q

queue_size() (azure.eventhub.aio.consumer_async.EventHubConsumer property) (azure.eventhub.aio.EventHubConsumer property) (azure.eventhub.consumer.EventHubConsumer property) (azure.eventhub.EventHubConsumer property)

R

receive() (azure.eventhub.aio.consumer_async.EventHubConsumer method) (azure.eventhub.aio.EventHubConsumer method) (azure.eventhub.consumer.EventHubConsumer method) (azure.eventhub.EventHubConsumer method)

S

SamplePartitionManager (class in azure.eventhub.aio.eventprocessor) (class in azure.eventhub.aio.eventprocessor.sample_partition_manager) send() (azure.eventhub.aio.EventHubProducer method) (azure.eventhub.aio.producer_async.EventHubProducer method) (azure.eventhub.EventHubProducer method) (azure.eventhub.producer.EventHubProducer method) sequence_number() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property) SHUTDOWN (azure.eventhub.aio.eventprocessor.CloseReason attribute) (azure.eventhub.aio.eventprocessor.partition_processor.CloseReason attribute)

size() (azure.eventhub.common.EventDataBatch property) (azure.eventhub.EventDataBatch property) start() (azure.eventhub.aio.eventprocessor.event_processor.EventProcessor method) (azure.eventhub.aio.eventprocessor.EventProcessor method) stop() (azure.eventhub.aio.eventprocessor.event_processor.EventProcessor method) (azure.eventhub.aio.eventprocessor.EventProcessor method) system_properties() (azure.eventhub.common.EventData property) (azure.eventhub.EventData property)

T

TransportType (class in azure.eventhub)

try_add() (azure.eventhub.common.EventDataBatch method) (azure.eventhub.EventDataBatch method)

U

update_checkpoint() (azure.eventhub.aio.eventprocessor.partition_context.PartitionContext method) (azure.eventhub.aio.eventprocessor.partition_manager.PartitionManager method) (azure.eventhub.aio.eventprocessor.PartitionContext method) (azure.eventhub.aio.eventprocessor.PartitionManager method) (azure.eventhub.aio.eventprocessor.sample_partition_manager.SamplePartitionManager method) (azure.eventhub.aio.eventprocessor.SamplePartitionManager method)

W

with_traceback() (azure.eventhub.aio.eventprocessor.OwnershipLostError method) (azure.eventhub.aio.eventprocessor.partition_manager.OwnershipLostError method) (azure.eventhub.AuthenticationError method) (azure.eventhub.ConnectError method) (azure.eventhub.ConnectionLostError method) (azure.eventhub.error.AuthenticationError method) (azure.eventhub.error.ConnectError method) (azure.eventhub.error.ConnectionLostError method) (azure.eventhub.error.EventDataError method) (azure.eventhub.error.EventDataSendError method) (azure.eventhub.error.EventHubError method) (azure.eventhub.error.OperationTimeoutError method) (azure.eventhub.EventDataError method) (azure.eventhub.EventDataSendError method) (azure.eventhub.EventHubError method)