diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/README.md b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/README.md index 7a2fb134cd0c..a317a5d6b115 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/README.md +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/README.md @@ -117,14 +117,16 @@ Enabling logging will be helpful to do trouble shooting. ## Next steps -### Examples -- [https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py) - EventHubConsumerClient with blob checkpoint store example -- [https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py) - EventHubConsumerClient with blob checkpoint store and storage version example +### More sample code +Get started with our [EventHubs Checkpoint Store async samples](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples). + +- [receive_events_using_checkpoint_store_async.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py) - EventHubConsumerClient with blob checkpoint store example +- [receive_events_using_checkpoint_store_storage_api_version_async.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py) - EventHubConsumerClient with blob checkpoint store and storage version example ### Documentation -Reference documentation is available [here](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/latest/azure.eventhub.aio.html#azure.eventhub.aio.CheckpointStore) +Reference documentation is available [here](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/latest/azure.eventhub.aio.html#azure.eventhub.aio.CheckpointStore). ### Provide Feedback diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py index 3d96cb4c34ee..6da7b2841ca2 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_async.py @@ -4,6 +4,7 @@ from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -27,7 +28,8 @@ async def main(client): ) client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, - "$Default", + consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store ) try: diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py index 89c97d8ff621..be14e8c918c3 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/samples/receive_events_using_checkpoint_store_storage_api_version_async.py @@ -20,6 +20,7 @@ from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. STORAGE_SERVICE_API_VERSION = "2017-11-09" @@ -45,7 +46,8 @@ async def main(client): ) client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, - "$Default", + consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store ) try: diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/README.md b/sdk/eventhub/azure-eventhub-checkpointstoreblob/README.md index dba40e1b5234..d6c61b7cb0d1 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/README.md +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/README.md @@ -116,13 +116,16 @@ Enabling logging will be helpful to do trouble shooting. ## Next steps -### Examples -- [https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py) - EventHubConsumerClient with blob checkpoint store example -- [https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py) - EventHubConsumerClient with blob checkpoint store and storage version example +### More sample code + +Get started with our [EventHubs Checkpoint Store samples](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples). + +- [receive_events_using_checkpoint_store.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py) - EventHubConsumerClient with blob checkpoint store example +- [receive_events_using_checkpoint_store_storage_api_version.py](https://github.com/Azure/azure-sdk-for-python/blob/master/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py) - EventHubConsumerClient with blob checkpoint store and storage version example ### Documentation -Reference documentation is available [here](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/latest/azure.eventhub.html#azure.eventhub.CheckpointStore) +Reference documentation is available [here](https://azuresdkdocs.blob.core.windows.net/$web/python/azure-eventhub/latest/azure.eventhub.html#azure.eventhub.CheckpointStore). ### Provide Feedback diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py index 53c685b02400..e88c47751758 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store.py @@ -3,6 +3,7 @@ from azure.eventhub.extensions.checkpointstoreblob import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -21,7 +22,8 @@ def on_event(partition_context, event): ) client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, - "$Default", + consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store ) diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py index 8fddcf10e4e0..39679b7d7a6f 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/samples/receive_events_using_checkpoint_store_storage_api_version.py @@ -19,6 +19,7 @@ from azure.eventhub.extensions.checkpointstoreblob import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. STORAGE_SERVICE_API_VERSION = "2017-11-09" @@ -39,7 +40,8 @@ def on_event(partition_context, event): ) client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, - "$Default", + consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store ) diff --git a/sdk/eventhub/azure-eventhub/samples/async_samples/client_identity_authentication_async.py b/sdk/eventhub/azure-eventhub/samples/async_samples/client_identity_authentication_async.py index ff196656f529..250bdfa1bab1 100644 --- a/sdk/eventhub/azure-eventhub/samples/async_samples/client_identity_authentication_async.py +++ b/sdk/eventhub/azure-eventhub/samples/async_samples/client_identity_authentication_async.py @@ -45,20 +45,21 @@ async def run(): credential = EnvironmentCredential() - producer = EventHubProducerClient(fully_qualified_namespace=fully_qualified_namespace, - eventhub_name=eventhub_name, - credential=credential) + async with credential: + producer = EventHubProducerClient(fully_qualified_namespace=fully_qualified_namespace, + eventhub_name=eventhub_name, + credential=credential) - async with producer: - event_data_batch = await producer.create_batch() - while True: - try: - event_data_batch.add(EventData('Message inside EventBatchData')) - except ValueError: - # EventDataBatch object reaches max_size. - # New EventDataBatch object can be created here to send more data. - break - await producer.send_batch(event_data_batch) + async with producer: + event_data_batch = await producer.create_batch() + while True: + try: + event_data_batch.add(EventData('Message inside EventBatchData')) + except ValueError: + # EventDataBatch object reaches max_size. + # New EventDataBatch object can be created here to send more data. + break + await producer.send_batch(event_data_batch) loop = asyncio.get_event_loop() loop.run_until_complete(run()) diff --git a/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_event_count_async.py b/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_event_count_async.py index a5f655116bcb..363f1151a635 100644 --- a/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_event_count_async.py +++ b/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_event_count_async.py @@ -20,6 +20,7 @@ from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -56,6 +57,7 @@ async def main(): client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, consumer_group="$Default", + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store, # For load-balancing and checkpoint. Leave None for no load-balancing. ) async with client: diff --git a/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_time_interval_async.py b/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_time_interval_async.py index e674c5d4b07a..df56b6b7ffe1 100644 --- a/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_time_interval_async.py +++ b/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_by_time_interval_async.py @@ -20,6 +20,7 @@ from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -59,6 +60,7 @@ async def main(): client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, consumer_group="$Default", + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store, # For load-balancing and checkpoint. Leave None for no load-balancing. ) async with client: diff --git a/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_store_async.py b/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_store_async.py index 37be2bf4e14e..aa4b08fafb3a 100644 --- a/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_store_async.py +++ b/sdk/eventhub/azure-eventhub/samples/async_samples/recv_with_checkpoint_store_async.py @@ -18,6 +18,7 @@ from azure.eventhub.extensions.checkpointstoreblobaio import BlobCheckpointStore CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -47,6 +48,7 @@ async def main(): client = EventHubConsumerClient.from_connection_string( CONNECTION_STR, consumer_group="$Default", + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store, # For load-balancing and checkpoint. Leave None for no load-balancing. ) async with client: diff --git a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_track_last_enqueued_event_prop.py b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_track_last_enqueued_event_prop.py index 01822dad5bb2..1725d775ed34 100644 --- a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_track_last_enqueued_event_prop.py +++ b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_track_last_enqueued_event_prop.py @@ -10,7 +10,6 @@ the last enqueued event properties of specific partition. """ import os -import time from azure.eventhub import EventHubConsumerClient CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] diff --git a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_event_count.py b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_event_count.py index 0adb243c1c6d..2d2cca4cc238 100644 --- a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_event_count.py +++ b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_event_count.py @@ -19,6 +19,7 @@ CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -42,6 +43,7 @@ def on_event(partition_context, event): consumer_client = EventHubConsumerClient.from_connection_string( conn_str=CONNECTION_STR, consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store, # For load-balancing and checkpoint. Leave None for no load-balancing. ) diff --git a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_time_interval.py b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_time_interval.py index ade41b18317b..89a0b83c74a8 100644 --- a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_time_interval.py +++ b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_by_time_interval.py @@ -19,6 +19,7 @@ CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -44,6 +45,7 @@ def on_event(partition_context, event): consumer_client = EventHubConsumerClient.from_connection_string( conn_str=CONNECTION_STR, consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store, # For load-balancing and checkpoint. Leave None for no load-balancing. ) diff --git a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_store.py b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_store.py index fefca29cd558..c1b0a04bd2e2 100644 --- a/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_store.py +++ b/sdk/eventhub/azure-eventhub/samples/sync_samples/recv_with_checkpoint_store.py @@ -17,6 +17,7 @@ CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"] +EVENTHUB_NAME = os.environ['EVENT_HUB_NAME'] STORAGE_CONNECTION_STR = os.environ["AZURE_STORAGE_CONN_STR"] BLOB_CONTAINER_NAME = "your-blob-container-name" # Please make sure the blob container resource exists. @@ -33,6 +34,7 @@ def on_event(partition_context, event): consumer_client = EventHubConsumerClient.from_connection_string( conn_str=CONNECTION_STR, consumer_group='$Default', + eventhub_name=EVENTHUB_NAME, checkpoint_store=checkpoint_store, # For load-balancing and checkpoint. Leave None for no load-balancing. )