updates

sdk/eventgrid/azure-eventgrid/azure/eventgrid/_operations/_patch.py

@@ -193,7 +193,7 @@ def receive(
             max_wait_time=max_wait_time,
             **kwargs,
         )
-        for detail_item in received_result.value:
+        for detail_item in received_result.details:
             deserialized_cloud_event = CloudEvent.from_dict(detail_item.event)
             detail_item.event = deserialized_cloud_event
             detail_items.append(

sdk/eventgrid/azure-eventgrid/azure/eventgrid/_patch.py

@@ -117,7 +117,7 @@ def __init__(
         super().__init__(
             endpoint=endpoint,
             credential=credential,
-            api_version=api_version,
+            api_version=api_version or DEFAULT_STANDARD_API_VERSION,
             **kwargs
         )
 

sdk/eventgrid/azure-eventgrid/azure/eventgrid/aio/_operations/_patch.py

@@ -151,7 +151,7 @@ async def receive(
             max_wait_time=max_wait_time,
             **kwargs,
         )
-        for detail_item in receive_result.value:
+        for detail_item in receive_result.details:
             deserialized_cloud_event = CloudEvent.from_dict(detail_item.event)
             detail_item.event = deserialized_cloud_event
             detail_items.append(

sdk/eventgrid/azure-eventgrid/samples/async_samples/sample_publish_cloud_event_using_dict_async.py

@@ -21,6 +21,7 @@
 from azure.eventgrid.aio import EventGridPublisherClient
 from azure.core.credentials import AzureKeyCredential
 
+# To Event Grid Basic
 topic_key = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_KEY"]
 endpoint = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_ENDPOINT"]
 
@@ -44,5 +45,28 @@ async def publish():
         ])
     # [END publish_cloud_event_dict_async]
 
+    # To Event Grid Namespaces
+    topic_endpoint = os.environ["EVENTGRID_ENDPOINT"]
+    topic_key = os.environ["EVENTGRID_KEY"]
+    topic_name = os.environ["EVENTGRID_TOPIC_NAME"]
+    sub = os.environ["EVENTGRID_EVENT_SUBSCRIPTION_NAME"]
+
+    credential = AzureKeyCredential(topic_key)
+    client = EventGridPublisherClient(topic_endpoint, credential, namespace_topic=topic_name)
+
+    async with client:
+        await client.send([
+        {
+            "type": "Contoso.Items.ItemReceived",
+            "source": "/contoso/items",	
+            "data": {	
+                "itemSku": "Contoso Item SKU #1"	
+            },	
+            "subject": "Door1",	
+            "specversion": "1.0",	
+            "id": "randomclouduuid11"
+        }
+    ])
+
 if __name__ == '__main__':
     asyncio.run(publish())

sdk/eventgrid/azure-eventgrid/samples/async_samples/sample_publish_cncf_cloud_events_async.py

@@ -20,6 +20,7 @@
 from azure.core.credentials import AzureKeyCredential
 from cloudevents.http import CloudEvent
 
+# To Event Grid Basic
 topic_key = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_KEY"]
 endpoint = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_ENDPOINT"]
 
@@ -39,5 +40,26 @@ async def publish():
         )
     ])
 
+# To Event Grid Namespaces
+
+    topic_endpoint = os.environ["EVENTGRID_ENDPOINT"]
+    topic_key = os.environ["EVENTGRID_KEY"]
+    topic_name = os.environ["EVENTGRID_TOPIC_NAME"]
+
+    credential = AzureKeyCredential(topic_key)
+    client = EventGridPublisherClient(topic_endpoint, credential, namespace_topic=topic_name)
+
+    async with client:
+        await client.send([
+            CloudEvent(
+                attributes={
+                    "type": "cloudevent",
+                    "source": "/cncf/cloud/event/1.0",
+                    "subject": "testing-cncf-event"
+                },
+                data=b'This is a cncf cloud event.',
+            )
+        ])
+
 if __name__ == '__main__':
     asyncio.run(publish())

sdk/eventgrid/azure-eventgrid/samples/sync_samples/sample_publish_cloud_event_using_dict.py

@@ -16,9 +16,11 @@
     "https://<YOUR-TOPIC-NAME>.<REGION-NAME>.eventgrid.azure.net/api/events".
 """
 import os
-from azure.eventgrid import EventGridPublisherClient
+from azure.eventgrid import EventGridPublisherClient, EventGridConsumerClient
 from azure.core.credentials import AzureKeyCredential
 
+
+# To Event Grid Basic
 topic_key = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_KEY"]
 endpoint = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_ENDPOINT"]
 
@@ -39,3 +41,25 @@
     }
 ])
 # [END publish_cloud_event_dict]
+
+# To Event Grid Namespaces
+topic_endpoint = os.environ["EVENTGRID_ENDPOINT"]
+topic_key = os.environ["EVENTGRID_KEY"]
+topic_name = os.environ["EVENTGRID_TOPIC_NAME"]
+sub = os.environ["EVENTGRID_EVENT_SUBSCRIPTION_NAME"]
+
+credential = AzureKeyCredential(topic_key)
+client = EventGridPublisherClient(topic_endpoint, credential, namespace_topic=topic_name)
+
+client.send([
+    {
+        "type": "Contoso.Items.ItemReceived",
+        "source": "/contoso/items",	
+        "data": {	
+            "itemSku": "Contoso Item SKU #1"	
+        },	
+        "subject": "Door1",	
+        "specversion": "1.0",	
+        "id": "randomclouduuid11"
+    }
+])

sdk/eventgrid/azure-eventgrid/samples/sync_samples/sample_publish_cncf_cloud_events.py

@@ -19,6 +19,7 @@
 from azure.core.credentials import AzureKeyCredential
 from cloudevents.http import CloudEvent
 
+# To EventGrid Basic
 topic_key = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_KEY"]
 endpoint = os.environ["EVENTGRID_CLOUD_EVENT_TOPIC_ENDPOINT"]
 
@@ -35,3 +36,22 @@
         data=b'This is a cncf cloud event.',
     )
 ])
+
+# To Event Grid Namespaces
+topic_endpoint = os.environ["EVENTGRID_ENDPOINT"]
+topic_key = os.environ["EVENTGRID_KEY"]
+topic_name = os.environ["EVENTGRID_TOPIC_NAME"]
+
+credential = AzureKeyCredential(topic_key)
+client = EventGridPublisherClient(topic_endpoint, credential, namespace_topic=topic_name)
+
+client.send([
+    CloudEvent(
+        attributes={
+            "type": "cloudevent",
+            "source": "/cncf/cloud/event/1.0",
+            "subject": "testing-cncf-event"
+        },
+        data=b'This is a cncf cloud event.',
+    )
+])