ScalePlan CloudEvents for Python

Unofficial Python implementation for CloudEvents v1.0. Check out the CloudEvents spec.

This package has no dependencies beyond the Python standard library with the base install. Optionally depends on the avro package for Avro encode/decode functionality.

Features

• Implements CloudEvents 1.0 spec.
• JSON and JSON batch encoding/decoding.
• Avro encoding/decoding.
• Simple API.

News

0.2.3 - (2020-09-30)

• Added support for encoding/decoding batch events in JSON.

0.2.2 - (2020-09-29)

• First public release.

Install

Requirements:

• Python 3.6 or above

Install with JSON codec:

pip install spce

Install with JSON and Avro codecs:

pip install spce[avro]

Usage:

Creating Events

Create a CloudEvent with required attributes:

fromspceimportCloudEventevent=CloudEvent(
type="OximeterMeasured",
source="oximeter/123",
id="1000"
)

The id field is required, it won't be auto-generated if blank.

Create a CloudEvent with optional attributes:

event=CloudEvent(
type="OximeterMeasured",
source="oximeter/123",
id="1000",
subject="subject1",
dataschema="https://particlemetrics.com/schema",
time="2020-09-28T21:33:21Z",
data='{\"spo2\": 99})',
datacontenttype="application/json"
)

The time field can be an RFC3336 compatible timestamp string or a datetime.datetime object. If left out, it won't be automatically set. If you need to set the time field to the current time, you can use the datetime.utcnow method:

fromdatetimeimportdatetimenow=datetime.utcnow()
event=CloudEvent(
type="OximeterMeasured",
source="oximeter/123",
id="1000",
time=now
)

Check https://github.com/scaleplandev/spce-python/blob/master/tests/cloudevents_test.py for a few examples that set the time.

Required and optional attributes can be directly accessed:

assertevent.type=="OximeterMeasured"assertevent.time=="2020-09-28T21:33:21Z"

Create a CloudEvent with extension attributes:

event=CloudEvent(
type="OximeterMeasured",
source="oximeter/123",
id="1000",
external1="foo/bar"
)

Extension attributes can be accessed using the attribute method:

assertevent.attribute("external1") =="foo/bar"

Encoding/Decoding Events in JSON

Encode an event in JSON:

fromspceimportJsonencoded_event=Json.encode(event)

Note that blank/unset attributes won't be encoded.

Encode a batch of events in JSON:

fromspceimportCloudEvent, Jsonevent_batch= [
CloudEvent(
type="OximeterMeasured",
source="oximeter/123",
id="1000",
datacontenttype="application/json",
data=r'{"spo2": 99})',
),
CloudEvent(
type="OximeterMeasured",
source="oximeter/123",
id="1001",
datacontenttype="application/json",
data=b'\x01binarydata\x02',
),
]
encoded_batch=Json.encode(event_batch)

Decode an event in JSON:

fromspceimportJsontext=""" { "type": "OximeterMeasured", "source": "oximeter/123", "id": "1000", "specversion": "1.0", "datacontenttype": "application/json", "subject": "subject1", "dataschema": "https://particlemetrics.com/schema", "time": "2020-09-28T21:33:21Z", "data": "{\"spo2\": 99})" }"""decoded_event=Json.decode(text) 

Decode a batch of events in JSON:

text=r''' [ { "type":"OximeterMeasured", "source":"oximeter/123", "id":"1000", "specversion":"1.0", "datacontenttype": "application/json", "data": "{\"spo2\": 99}" }, { "type":"OximeterMeasured", "source":"oximeter/123", "id":"1001", "specversion":"1.0", "datacontenttype": "application/json", "data_base64": "AWJpbmFyeWRhdGEC" } ]'''decoded_events=Json.decode(text) 

Encoding/Decoding Events in Avro

Encode an event in Avro:

fromspceimportAvroencoded_event=Avro.encode(event)

Note that blank fields won't be encoded.

Decode an event in Avro:

fromspceimportAvroencoded_event= \
(b'\n\x08type\x06 OximeterMeasured\x0csource\x06\x18oximeter/123\x04id'b'\x06\x081000\x16specversion\x06\x061.0\x1edatacontenttype\x06 application'b'/json\x00\x0c\x18{"spo2": 99}')
decoded_event=Avro.decode(encoded_event) 

License

(c) 2020 Scale Plan Yazılım A.Ş. https://scaleplan.io

Licensed under Apache 2.0. See the LICENSE.

Copyright 2020 Scale Plan Yazılım A.Ş.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.