[EventHubs]Update async samples (Azure#21857)

Author: sammiee5311

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

@@ -83,7 +83,6 @@ async def create_with_sas_token():
         await producer_client.send_batch(event_data_batch)
 
 
-loop = asyncio.get_event_loop()
 start_time = time.time()
-loop.run_until_complete(create_with_sas_token())
+asyncio.run(create_with_sas_token())
 print("Send messages in {} seconds.".format(time.time() - start_time))

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

@@ -61,6 +61,6 @@ async def run():
                     break
             await producer.send_batch(event_data_batch)
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(run())
+
+asyncio.run(run())
 print('Finished sending.')

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

@@ -15,6 +15,7 @@
 CONNECTION_STR = os.environ["EVENT_HUB_CONN_STR"]
 EVENTHUB_NAME = os.environ['EVENT_HUB_NAME']
 
+
 async def main():
     consumer_client = EventHubConsumerClient.from_connection_string(
         conn_str=CONNECTION_STR,
@@ -24,6 +25,6 @@ async def main():
     async with consumer_client:
         pass # consumer_client is now ready to be used.
 
+
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(main())
+    asyncio.run(main())

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

@@ -123,5 +123,4 @@ async def on_event_batch(partition_context, events):
 
 if __name__ == '__main__':
     iothub_conn_str = os.environ["IOTHUB_CONN_STR"]
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(receive_events_from_iothub(iothub_conn_str))
+    asyncio.run(receive_events_from_iothub(iothub_conn_str))

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

@@ -61,6 +61,4 @@ async def main():
         print('Finished receiving.')
 
 
-loop = asyncio.get_event_loop()
-loop.run_until_complete(main())
-
+asyncio.run(main())

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

@@ -55,5 +55,4 @@ async def receive_batch():
 
 
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(receive_batch())
+    asyncio.run(receive_batch())

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

@@ -63,6 +63,6 @@ async def main():
             starting_position="-1",  # "-1" is from the beginning of the partition.
         )
 
+
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(main())
+    asyncio.run(main())

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

@@ -73,6 +73,6 @@ async def main():
 
     print('Consumer has stopped receiving, end time is {}.'.format(time.time()))
 
+
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(main())
+    asyncio.run(main())

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

@@ -46,5 +46,4 @@ async def main():
 
 
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(main())
+    asyncio.run(main())

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

@@ -65,5 +65,4 @@ async def main():
 
 
 if __name__ == '__main__':
-    loop = asyncio.get_event_loop()
-    loop.run_until_complete(main())
+    asyncio.run(main())