Kodieren Sie ein Objekt mit Avro zu einem Byte-Array in Python

Question

In Python 2.7, mit Avro, möchte ich ein Objekt zu einem Byte-Array zu kodieren.

Alle Beispiele, die ich gefunden habe, schreiben in eine Datei.

Ich habe versucht mit io.BytesIO(), aber dies gibt:

AttributeError: '_io.BytesIO' object has no attribute 'write_long' 

Probe io.BytesIO mit

def avro_encode(raw, schema): 
    writer = DatumWriter(schema) 
    avro_buffer = io.BytesIO() 
    writer.write(raw, avro_buffer) 
    return avro_buffer.getvalue() 

Answer 1

Ihre Frage mich Dinge Figur geholfen, so danke. Hier ist ein einfaches Python-Beispiel basiert auf dem Python-Beispiel in der Dokumentation:

import io 
import avro.schema 
import avro.io 

test_schema = ''' 
{ 
"namespace": "example.avro", 
"type": "record", 
"name": "User", 
"fields": [ 
    {"name": "name", "type": "string"}, 
    {"name": "favorite_number", "type": ["int", "null"]}, 
    {"name": "favorite_color", "type": ["string", "null"]} 
] 
} 
''' 

schema = avro.schema.parse(test_schema) 
writer = avro.io.DatumWriter(schema) 

bytes_writer = io.BytesIO() 
encoder = avro.io.BinaryEncoder(bytes_writer) 
writer.write({"name": "Alyssa", "favorite_number": 256}, encoder) 
writer.write({"name": "Ben", "favorite_number": 7, "favorite_color": "red"}, encoder) 

raw_bytes = bytes_writer.getvalue() 
print(len(raw_bytes)) 
print(type(raw_bytes)) 

bytes_reader = io.BytesIO(raw_bytes) 
decoder = avro.io.BinaryDecoder(bytes_reader) 
reader = avro.io.DatumReader(schema) 
user1 = reader.read(decoder) 
user2 = reader.read(decoder) 

print(user1) 
print(user2)