diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py index 0b106072c49a..c7949272fd38 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob-aio/setup.py @@ -67,7 +67,7 @@ python_requires=">=3.5.3", install_requires=[ 'azure-storage-blob<13.0.0,>=12.0.0', - 'azure-eventhub<6.0.0,>=5.0.0b6', + 'azure-eventhub<6.0.0,>=5.0.0', 'aiohttp<4.0,>=3.0', ], extras_require={ diff --git a/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py b/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py index e340619cda86..7bbd06725e9a 100644 --- a/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py +++ b/sdk/eventhub/azure-eventhub-checkpointstoreblob/setup.py @@ -68,7 +68,7 @@ packages=find_packages(exclude=exclude_packages), install_requires=[ 'azure-storage-blob<13.0.0,>=12.0.0', - 'azure-eventhub<6.0.0,>=5.0.0b6', + 'azure-eventhub<6.0.0,>=5.0.0', ], extras_require={ diff --git a/sdk/eventhub/azure-eventhub/samples/async_samples/sample_code_eventhub_async.py b/sdk/eventhub/azure-eventhub/samples/async_samples/sample_code_eventhub_async.py index 3a083e686fd3..da5eefc958ae 100644 --- a/sdk/eventhub/azure-eventhub/samples/async_samples/sample_code_eventhub_async.py +++ b/sdk/eventhub/azure-eventhub/samples/async_samples/sample_code_eventhub_async.py @@ -112,8 +112,9 @@ async def example_eventhub_async_send_and_receive(): logger = logging.getLogger("azure.eventhub") async def on_event(partition_context, event): + # Put your code here. + # If the operation is i/o intensive, async will have better performance. logger.info("Received event from partition: {}".format(partition_context.partition_id)) - # Do some asynchronous ops on received event async with consumer: await consumer.receive( @@ -171,8 +172,9 @@ async def example_eventhub_async_consumer_receive_and_close(): logger = logging.getLogger("azure.eventhub") async def on_event(partition_context, event): + # Put your code here. + # If the operation is i/o intensive, async will have better performance. logger.info("Received event from partition: {}".format(partition_context.partition_id)) - # Do some asynchronous ops on the received event # The receive method is a coroutine which will be blocking when awaited. # It can be executed in an async task for non-blocking behavior, and combined with the 'close' method. diff --git a/sdk/eventhub/azure-eventhub/samples/sync_samples/sample_code_eventhub.py b/sdk/eventhub/azure-eventhub/samples/sync_samples/sample_code_eventhub.py index e0a273553658..f524e41cd57f 100644 --- a/sdk/eventhub/azure-eventhub/samples/sync_samples/sample_code_eventhub.py +++ b/sdk/eventhub/azure-eventhub/samples/sync_samples/sample_code_eventhub.py @@ -128,8 +128,9 @@ def example_eventhub_sync_send_and_receive(): logger = logging.getLogger("azure.eventhub") def on_event(partition_context, event): + # Put your code here. + # If the operation is i/o intensive, multi-thread will have better performance. logger.info("Received event from partition: {}".format(partition_context.partition_id)) - # Do ops on the received event with consumer: consumer.receive(on_event=on_event) @@ -186,8 +187,9 @@ def example_eventhub_consumer_receive_and_close(): logger = logging.getLogger("azure.eventhub") def on_event(partition_context, event): + # Put your code here. + # If the operation is i/o intensive, multi-thread will have better performance. logger.info("Received event from partition: {}".format(partition_context.partition_id)) - # Do some ops on the received event # The 'receive' method is a blocking call, it can be executed in a thread for # non-blocking behavior, and combined with the 'close' method. diff --git a/shared_requirements.txt b/shared_requirements.txt index b12e9f47295d..be542b1a53a2 100644 --- a/shared_requirements.txt +++ b/shared_requirements.txt @@ -10,7 +10,7 @@ azure-common~=1.1 azure-core<2.0.0,>=1.0.0 azure-cosmosdb-table~=1.0 azure-datalake-store~=0.0.18 -azure-eventhub<6.0.0,>=5.0.0b6 +azure-eventhub<6.0.0,>=5.0.0 azure-eventgrid~=1.1 azure-graphrbac~=0.40.0 azure-keyvault==4.0.0b5