update samples

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_publish_receive_renew_async.py

@@ -0,0 +1,49 @@
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+# --------------------------------------------------------------------------
+import os
+import asyncio
+from azure.core.credentials import AzureKeyCredential
+from azure.eventgrid.aio import EventGridClient
+from azure.eventgrid.models import *
+from azure.core.messaging import CloudEvent
+from azure.core.exceptions import HttpResponseError
+
+
+EVENTGRID_KEY: str = os.environ["EVENTGRID_KEY"]
+EVENTGRID_ENDPOINT: str = os.environ["EVENTGRID_ENDPOINT"]
+TOPIC_NAME: str = os.environ["EVENTGRID_TOPIC_NAME"]
+EVENT_SUBSCRIPTION_NAME: str = os.environ["EVENTGRID_EVENT_SUBSCRIPTION_NAME"]
+
+
+async def run():
+    # Create a client
+    client = EventGridClient(EVENTGRID_ENDPOINT, AzureKeyCredential(EVENTGRID_KEY))
+
+    async with client:
+        # Publish a CloudEvent
+        try:
+            cloud_event = CloudEvent(data="hello", source="https://example.com", type="example")
+            await client.publish_cloud_events(topic_name=TOPIC_NAME, body=cloud_event)
+
+            receive_result = await client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=10, max_wait_time=10)
+            lock_tokens_to_release = []
+            for item in receive_result.value:
+                lock_tokens_to_release.append(item.broker_properties.lock_token)
+
+
+            # Renew a lock token
+            lock_tokens = RenewLockOptions(lock_tokens=lock_tokens_to_release)
+            renew_events = await client.renew_cloud_event_locks(
+                topic_name=TOPIC_NAME,
+                event_subscription_name=EVENT_SUBSCRIPTION_NAME,
+                renew_lock_options=lock_tokens,
+            )
+            print("Renewed Event:", renew_events)
+        except HttpResponseError:
+            raise
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(run())

sdk/eventgrid/azure-eventgrid/samples/async_samples/eventgrid_client_samples/sample_publish_release_receive_async.py

@@ -0,0 +1,64 @@
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+# --------------------------------------------------------------------------
+import os
+import asyncio
+from azure.core.credentials import AzureKeyCredential
+from azure.eventgrid.aio import EventGridClient
+from azure.eventgrid.models import *
+from azure.core.messaging import CloudEvent
+from azure.core.exceptions import HttpResponseError
+
+
+EVENTGRID_KEY: str = os.environ["EVENTGRID_KEY"]
+EVENTGRID_ENDPOINT: str = os.environ["EVENTGRID_ENDPOINT"]
+TOPIC_NAME: str = os.environ["EVENTGRID_TOPIC_NAME"]
+EVENT_SUBSCRIPTION_NAME: str = os.environ["EVENTGRID_EVENT_SUBSCRIPTION_NAME"]
+
+
+async def run():
+    # Create a client
+    client = EventGridClient(EVENTGRID_ENDPOINT, AzureKeyCredential(EVENTGRID_KEY))
+
+    async with client:
+        # Publish a CloudEvent
+        try:
+            cloud_event = CloudEvent(data="hello", source="https://example.com", type="example")
+            await client.publish_cloud_events(topic_name=TOPIC_NAME, body=cloud_event)
+
+            receive_result = await client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
+            lock_tokens_to_release = []
+            for item in receive_result.value:
+                lock_tokens_to_release.append(item.broker_properties.lock_token)
+
+            print("Received events:", receive_result.value)
+
+            # Release a LockToken
+            release_token = ReleaseOptions(lock_tokens=lock_tokens_to_release)
+            release_events = await client.release_cloud_events(
+                topic_name=TOPIC_NAME,
+                event_subscription_name=EVENT_SUBSCRIPTION_NAME,
+                release_delay_in_seconds=60,
+                release_options=release_token,
+            )
+            print("Released Event:", release_events)
+
+
+            receive_result = await client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
+            print("Received events after release:", receive_result.value)
+
+            # Acknowledge a LockToken
+            acknowledge_token = AcknowledgeOptions(lock_tokens=lock_tokens_to_release)
+            acknowledge_events = await client.acknowledge_cloud_events(
+                topic_name=TOPIC_NAME,
+                event_subscription_name=EVENT_SUBSCRIPTION_NAME,
+                acknowledge_options=acknowledge_token,
+            )
+            print("Acknowledged events after release:", acknowledge_events)
+        except HttpResponseError:
+            raise
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(run())

sdk/eventgrid/azure-eventgrid/samples/sync_samples/eventgrid_client_samples/sample_publish_release_receive.py

@@ -25,7 +25,7 @@
     cloud_event = CloudEvent(data="hello", source="https://example.com", type="example")
     client.publish_cloud_events(topic_name=TOPIC_NAME, body=cloud_event)
 
-    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=5)
+    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
     lock_tokens_to_release = []
     for item in receive_result.value:
         lock_tokens_to_release.append(item.broker_properties.lock_token)
@@ -43,7 +43,7 @@
     print("Released Event:", release_events)
 
 
-    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=5)
+    receive_result = client.receive_cloud_events(topic_name=TOPIC_NAME, event_subscription_name=EVENT_SUBSCRIPTION_NAME, max_events=1, max_wait_time=15)
     print("Received events after release:", receive_result.value)
 
     # Acknowledge a LockToken