1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
| from io import BytesIO
| from avro.schema import Parse
| from avro.io import DatumReader, BinaryDecoder
|
| schema = Parse("""{
| "namespace": "org.buildroot.package.python_avro",
| "type": "record",
| "name": "Developer",
| "fields": [
| {"name": "email", "type": "string"},
| {"name": "maintainer_of", "type": "string"}
| ]
| }""")
|
| example = b'<titouan.christophe@railnova.eu\x16python_avro'
|
| reader = DatumReader(schema)
| deserialized = reader.read(BinaryDecoder(BytesIO(example)))
|
| assert deserialized == {
| 'email': 'titouan.christophe@railnova.eu',
| 'maintainer_of': 'python_avro',
| }
|
|
