1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
# --------------------------------------------------------------------------
"""
FILE: consume_cloud_custom_data_sample.py
DESCRIPTION:
These samples demonstrate consuming custom cloud data
USAGE:
python consume_cloud_custom_data_sample.py
Set the environment variables with your own values before running the sample:
"""
import json
from azure.eventgrid import EventGridConsumer, CloudEvent
# all types of CloudEvents below produce same DeserializedEvent
cloud_custom_dict = {
"id":"de0fd76c-4ef4-4dfb-ab3a-8f24a307e033",
"source":"https://egtest.dev/cloudcustomevent",
"data":{"team": "event grid squad"},
"type":"Azure.Sdk.Sample",
"time":"2020-08-07T02:06:08.11969Z",
"specversion":"1.0"
}
cloud_custom_string = json.dumps(cloud_custom_dict)
cloud_custom_bytes = bytes(cloud_custom_string, "utf-8")
client = EventGridConsumer()
deserialized_dict_event = client.decode_cloud_event(cloud_custom_dict)
print(deserialized_dict_event)
deserialized_str_event = client.decode_cloud_event(cloud_custom_string)
print(deserialized_str_event)
deserialized_bytes_event = client.decode_cloud_event(cloud_custom_bytes)
print(deserialized_bytes_event)
|
