[avro] 파이썬을 이용한 avro 예제

파이썬을 이용한 avro를 이용하기 전에 pip를 이용해서 먼저 설치해야 합니다.

pip3 install avro

 

파이썬을 이용한 avro 예제는 다음과 같이 구현합니다.

 

오류 처리

파이썬2에서는 다음과 같은 오류가 발생할 수 있습니다. 파이썬 3로 실행하면 다음 오류는 해결됩니다.

Traceback (most recent call last):
  File "a.py", line 8, in <module>
    writer.append({"name": "Alyssa", "favorite_number": 256})
  File "/home/deploy/.local/lib/python2.7/site-packages/avro/datafile.py", line 227, in append
    self.datum_writer.write(datum, self.buffer_encoder)
  File "/home/deploy/.local/lib/python2.7/site-packages/avro/io.py", line 979, in write
    raise AvroTypeException(self.writers_schema, datum)
avro.io.AvroTypeException: The datum {'favorite_number': 256, 'name': 'Alyssa'} is not an example of the schema {
  "namespace": "example.avro",
  "type": "record",
  "name": "User",
  "fields": [
    {
      "type": "string",
      "name": "name"
    },
    {
      "type": [
        "int",
        "null"
      ],
      "name": "favorite_number"
    },
    {
      "type": [
        "string",
        "null"
      ],
      "name": "favorite_color"
    }
  ]
}