azure package

Subpackages

• azure.eventhub package
  • EventHubConsumerClient
    • EventHubConsumerClient.close()
    • EventHubConsumerClient.from_connection_string()
    • EventHubConsumerClient.get_eventhub_properties()
    • EventHubConsumerClient.get_partition_ids()
    • EventHubConsumerClient.get_partition_properties()
    • EventHubConsumerClient.receive()
    • EventHubConsumerClient.receive_batch()
  • EventHubProducerClient
    • EventHubProducerClient.close()
    • EventHubProducerClient.create_batch()
    • EventHubProducerClient.flush()
    • EventHubProducerClient.from_connection_string()
    • EventHubProducerClient.get_buffered_event_count()
    • EventHubProducerClient.get_eventhub_properties()
    • EventHubProducerClient.get_partition_ids()
    • EventHubProducerClient.get_partition_properties()
    • EventHubProducerClient.send_batch()
    • EventHubProducerClient.send_event()
    • EventHubProducerClient.total_buffered_event_count
  • EventData
    • EventData.body_as_json()
    • EventData.body_as_str()
    • EventData.from_message_content()
    • EventData.body
    • EventData.body_type
    • EventData.content_type
    • EventData.correlation_id
    • EventData.enqueued_time
    • EventData.message
    • EventData.message_id
    • EventData.offset
    • EventData.partition_key
    • EventData.properties
    • EventData.raw_amqp_message
    • EventData.sequence_number
    • EventData.system_properties
  • EventDataBatch
    • EventDataBatch.add()
    • EventDataBatch.message
    • EventDataBatch.size_in_bytes
  • EventHubSharedKeyCredential
    • EventHubSharedKeyCredential.get_token()
  • CheckpointStore
    • CheckpointStore.claim_ownership()
    • CheckpointStore.list_checkpoints()
    • CheckpointStore.list_ownership()
    • CheckpointStore.update_checkpoint()
  • PartitionContext
    • PartitionContext.update_checkpoint()
    • PartitionContext.last_enqueued_event_properties
  • CloseReason
    • CloseReason.OWNERSHIP_LOST
    • CloseReason.SHUTDOWN
  • TransportType
    • TransportType.Amqp
    • TransportType.AmqpOverWebsocket
  • LoadBalancingStrategy
    • LoadBalancingStrategy.BALANCED
    • LoadBalancingStrategy.GREEDY
  • Subpackages
    • azure.eventhub.aio package
      • EventHubConsumerClient
        • EventHubConsumerClient.close()
        • EventHubConsumerClient.from_connection_string()
        • EventHubConsumerClient.get_eventhub_properties()
        • EventHubConsumerClient.get_partition_ids()
        • EventHubConsumerClient.get_partition_properties()
        • EventHubConsumerClient.receive()
        • EventHubConsumerClient.receive_batch()
      • EventHubProducerClient
        • EventHubProducerClient.close()
        • EventHubProducerClient.create_batch()
        • EventHubProducerClient.flush()
        • EventHubProducerClient.from_connection_string()
        • EventHubProducerClient.get_buffered_event_count()
        • EventHubProducerClient.get_eventhub_properties()
        • EventHubProducerClient.get_partition_ids()
        • EventHubProducerClient.get_partition_properties()
        • EventHubProducerClient.send_batch()
        • EventHubProducerClient.send_event()
        • EventHubProducerClient.total_buffered_event_count
      • EventHubSharedKeyCredential
        • EventHubSharedKeyCredential.get_token()
      • CheckpointStore
        • CheckpointStore.claim_ownership()
        • CheckpointStore.list_checkpoints()
        • CheckpointStore.list_ownership()
        • CheckpointStore.update_checkpoint()
      • PartitionContext
        • PartitionContext.update_checkpoint()
        • PartitionContext.last_enqueued_event_properties
    • azure.eventhub.exceptions package
      • EventHubError
      • ConnectError
      • ConnectionLostError
      • EventDataError
      • EventDataSendError
      • AuthenticationError
      • OwnershipLostError
      • ClientClosedError
      • OperationTimeoutError
    • azure.eventhub.amqp package
      • AmqpAnnotatedMessage
        • AmqpAnnotatedMessage.annotations
        • AmqpAnnotatedMessage.application_properties
        • AmqpAnnotatedMessage.body
        • AmqpAnnotatedMessage.body_type
        • AmqpAnnotatedMessage.delivery_annotations
        • AmqpAnnotatedMessage.footer
        • AmqpAnnotatedMessage.header
        • AmqpAnnotatedMessage.properties
      • AmqpMessageHeader
        • AmqpMessageHeader.get()
        • AmqpMessageHeader.has_key()
        • AmqpMessageHeader.items()
        • AmqpMessageHeader.keys()
        • AmqpMessageHeader.update()
        • AmqpMessageHeader.values()
      • AmqpMessageProperties
        • AmqpMessageProperties.get()
        • AmqpMessageProperties.has_key()
        • AmqpMessageProperties.items()
        • AmqpMessageProperties.keys()
        • AmqpMessageProperties.update()
        • AmqpMessageProperties.values()
      • AmqpMessageBodyType
        • AmqpMessageBodyType.DATA
        • AmqpMessageBodyType.SEQUENCE
        • AmqpMessageBodyType.VALUE