2017-02-27 5 views
1

既存のスキーマに基づいてAvroを作成しようとしていますが、hereというチュートリアルの構文を使用しているときにエラーが発生します。コンソールは、 'bytes'オブジェクトに属性 'to_json'はありませんが、Avroライブラリの深いところにあると言っています。このエラーを解決するための適切な回避策または方法はありますか?Avro Writer in Python 3.5

全エラー:

Traceback (most recent call last): 
File "build_data.py", line 15, in <module> 
al.create_avro(logs) 
File "AppLog.py", line 57, in create_avro 
writer = DataFileWriter(open("new.avro", "wb"), DatumWriter(), schema) 
File "/usr/local/lib/python3.5/dist-packages/avro_python3-1.8.1-py3.5.egg/avro/datafile.py", line 151, in __init__ 
self.SetMeta('avro.schema', str(writer_schema).encode('utf-8')) 
File "/usr/local/lib/python3.5/dist-packages/avro_python3-1.8.1-py3.5.egg/avro/schema.py", line 266, in __str__ 
return json.dumps(self.to_json()) 
File "/usr/local/lib/python3.5/dist-packages/avro_python3-1.8.1-py3.5.egg/avro/schema.py", line 808, in to_json 
to_dump['items'] = item_schema.to_json(names) 
AttributeError: 'bytes' object has no attribute 'to_json' 

コード:あなたの助けを

schema = avro.schema.ArraySchema(open("AppLogs.avsc", "rb").read()) 
writer = DataFileWriter(open("new.avro", "wb"), DatumWriter(), schema) 

感謝。

答えて

0

in the questionにリンクされているドキュメントは古くなっています。私はスキーマメソッドの呼び出しをParseに変更し、bを "open"から削除することで上記を修正できました。

ここで更新されたコードです:

schema = avro.schema.Parse(open("AppLogs.avsc", "r").read()) 
writer = DataFileWriter(open(new_avro, "wb"), DatumWriter(), schema) 
は、