@@ -227,13 +227,9 @@ client.send(event)
227227
228228The following sections provide several code snippets covering some of the most common Event Grid tasks, including:
229229
230- * [ Send an Event Grid Event] ( #send-an-event-grid-event )
231230* [ Send a Cloud Event] ( #send-a-cloud-event )
232231* [ 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 )
237233
238234### Send a Cloud Event
239235
@@ -318,33 +314,41 @@ client = EventGridClient(endpoint, credential, level=ClientLevel.STANDARD)
318314
319315events = client.receive_cloud_events(topic_name, sub_name, max_events = 4 )
320316
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
322328 renew_tokens = e.broker_properties.lock_token
323329 renew_result = client.renew_cloud_events_lock(
324330 topic_name = TOPIC_NAME ,
325331 subscription_name = EVENT_SUBSCRIPTION_NAME ,
326332 lock_tokens = renew_tokens,
327333 )
328334
329- release_tokens = events[ 0 ].broker_properties.lock_token
335+
330336release_result = client.release_cloud_events(
331337 topic_name = TOPIC_NAME ,
332338 subscription_name = EVENT_SUBSCRIPTION_NAME ,
333- lock_tokens = release_tokens ,
339+ lock_tokens = release_events ,
334340)
335341
336- ack_tokens = events[1 ].broker_properties.lock_token
337342ack_result = client.acknowledge_cloud_events(
338343 topic_name = TOPIC_NAME ,
339344 subscription_name = EVENT_SUBSCRIPTION_NAME ,
340- lock_tokens = ack_tokens ,
345+ lock_tokens = acknowledge_events ,
341346)
342347
343- reject_tokens = events[2 ].broker_properties.lock_token
344348reject_result = client.reject_cloud_events(
345349 topic_name = TOPIC_NAME ,
346350 subscription_name = EVENT_SUBSCRIPTION_NAME ,
347- lock_tokens = reject_tokens ,
351+ lock_tokens = reject_events ,
348352)
349353
350354```
0 commit comments