[EventHubs & ServiceBus] Async sample should use asyncio.run (Azure#22307)

Author: yunhaoling

sdk/eventhub/azure-eventhub/samples/async_samples/client_creation_async.py

@@ -97,6 +97,5 @@ async def create_consumer_client():
         print("Calling consumer client get eventhub properties:", await consumer_client.get_eventhub_properties())
 
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(create_producer_client())
-loop.run_until_complete(create_consumer_client())
+asyncio.run(create_producer_client())
+asyncio.run(create_consumer_client())

sdk/eventhub/azure-eventhub/samples/async_samples/connection_to_custom_endpoint_address_async.py

@@ -70,6 +70,5 @@ async def consumer_connecting_to_custom_endpoint():
         print('Stopped receiving.')
 
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(producer_connecting_to_custom_endpoint())
-loop.run_until_complete(consumer_connecting_to_custom_endpoint())
+asyncio.run(producer_connecting_to_custom_endpoint())
+asyncio.run(consumer_connecting_to_custom_endpoint())

sdk/eventhub/azure-eventhub/samples/async_samples/sample_code_eventhub_async.py

@@ -207,8 +207,6 @@ async def on_event(partition_context, event):
     # [END eventhub_consumer_client_close_async]
 
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    # loop.run_until_complete(example_eventhub_async_consumer_receive_and_close())
-    # loop.run_until_complete(example_eventhub_async_producer_send_and_close())
-    loop.run_until_complete(example_eventhub_async_send_and_receive())
-
+    asyncio.run(example_eventhub_async_consumer_receive_and_close())
+    asyncio.run(example_eventhub_async_producer_send_and_close())
+    asyncio.run(example_eventhub_async_send_and_receive())

sdk/eventhub/azure-eventhub/samples/sync_samples/sample_code_eventhub.py

@@ -221,6 +221,6 @@ def on_event(partition_context, event):
 
 
 if __name__ == '__main__':
+    example_eventhub_producer_send_and_close()
+    example_eventhub_consumer_receive_and_close()
     example_eventhub_sync_send_and_receive()
-    # example_eventhub_producer_send_and_close()
-    # example_eventhub_consumer_receive_and_close()

sdk/servicebus/azure-servicebus/samples/async_samples/authenticate_client_connstr_async.py

@@ -32,5 +32,4 @@ async def run():
     async with ServiceBusClient.from_connection_string(connstr) as client:
         pass # Client is now initialized and can be used.
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(run())
+asyncio.run(run())

sdk/servicebus/azure-servicebus/samples/async_samples/authenticate_using_azure_named_key_credential_async.py

@@ -28,5 +28,4 @@ async def send_message():
         async with client.get_queue_sender(QUEUE_NAME) as sender:
             await sender.send_messages([ServiceBusMessage("hello")])
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(send_message())
+asyncio.run(send_message())

sdk/servicebus/azure-servicebus/samples/async_samples/authenticate_using_azure_sas_credential_async.py

@@ -52,6 +52,5 @@ async def send_message():
             await sender.send_messages([ServiceBusMessage("hello")])
 
 
-loop = asyncio.get_event_loop()
 start_time = time.time()
-loop.run_until_complete(send_message())
+asyncio.run(send_message())

sdk/servicebus/azure-servicebus/samples/async_samples/auto_lock_renew_async.py

@@ -127,8 +127,6 @@ async def on_lock_renew_failure_callback(renewable, error):
                 print('Lock renew failure demonstration complete.')
 
 
-
-loop = asyncio.get_event_loop()
-loop.run_until_complete(renew_lock_on_message_received_from_non_sessionful_entity())
-loop.run_until_complete(renew_lock_on_session_of_the_sessionful_entity())
-loop.run_until_complete(renew_lock_with_lock_renewal_failure_callback())
+asyncio.run(renew_lock_on_message_received_from_non_sessionful_entity())
+asyncio.run(renew_lock_on_session_of_the_sessionful_entity())
+asyncio.run(renew_lock_with_lock_renewal_failure_callback())

sdk/servicebus/azure-servicebus/samples/async_samples/client_identity_authentication_async.py

@@ -60,8 +60,6 @@ async def run():
 
     await credential.close()
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(run())
-
+asyncio.run(run())
 
 print("Send message is done.")

sdk/servicebus/azure-servicebus/samples/async_samples/deadletter_messages_and_correct_async.py

@@ -114,5 +114,4 @@ async def main():
 
     await servicebus_client.close()
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(main())
+asyncio.run(main())