@@ -227,13 +227,9 @@ client.send(event)
227
227
228
228
The following sections provide several code snippets covering some of the most common Event Grid tasks, including:
229
229
230
- * [ Send an Event Grid Event] ( #send-an-event-grid-event )
231
230
* [ Send a Cloud Event] ( #send-a-cloud-event )
232
231
* [ Send Multiple Events] ( #send-multiple-events )
233
- * [ Send events as Dictionaries] ( #send-events-as-dictionaries )
234
- * [ Receive events] ( #receive-events-from-namespace )
235
- * [ Consume a payload from storage queue] ( #consume-from-storage-queue )
236
- * [ Consume from ServiceBus] ( #consume-from-servicebus )
232
+ * [ Receive and Process Events from Namespace] ( #receive-and-process-events-from-namespace )
237
233
238
234
### Send a Cloud Event
239
235
@@ -318,33 +314,41 @@ client = EventGridClient(endpoint, credential, level=ClientLevel.STANDARD)
318
314
319
315
events = client.receive_cloud_events(topic_name, sub_name, max_events = 4 )
320
316
321
- for e in events:
317
+ for detail in events.value:
318
+ data = detail.event.data
319
+ broker_properties = detail.broker_properties
320
+ if data == " release" :
321
+ release_events.append(broker_properties.lock_token)
322
+ elif data == " acknowledge" :
323
+ acknowledge_events.append(broker_properties.lock_token)
324
+ else :
325
+ reject_events.append(broker_properties.lock_token)
326
+
327
+ # Renew all Locks
322
328
renew_tokens = e.broker_properties.lock_token
323
329
renew_result = client.renew_cloud_events_lock(
324
330
topic_name = TOPIC_NAME ,
325
331
subscription_name = EVENT_SUBSCRIPTION_NAME ,
326
332
lock_tokens = renew_tokens,
327
333
)
328
334
329
- release_tokens = events[ 0 ].broker_properties.lock_token
335
+
330
336
release_result = client.release_cloud_events(
331
337
topic_name = TOPIC_NAME ,
332
338
subscription_name = EVENT_SUBSCRIPTION_NAME ,
333
- lock_tokens = release_tokens ,
339
+ lock_tokens = release_events ,
334
340
)
335
341
336
- ack_tokens = events[1 ].broker_properties.lock_token
337
342
ack_result = client.acknowledge_cloud_events(
338
343
topic_name = TOPIC_NAME ,
339
344
subscription_name = EVENT_SUBSCRIPTION_NAME ,
340
- lock_tokens = ack_tokens ,
345
+ lock_tokens = acknowledge_events ,
341
346
)
342
347
343
- reject_tokens = events[2 ].broker_properties.lock_token
344
348
reject_result = client.reject_cloud_events(
345
349
topic_name = TOPIC_NAME ,
346
350
subscription_name = EVENT_SUBSCRIPTION_NAME ,
347
- lock_tokens = reject_tokens ,
351
+ lock_tokens = reject_events ,
348
352
)
349
353
350
354
```
0 commit comments