Codifica un oggetto con Avro in un array di byte in Python

Question

In python 2.7, utilizzando Avro, mi piacerebbe codificare un oggetto in un array di byte.

Tutti gli esempi che ho trovato scrivono in un file.

Ho provato con io.BytesIO(), ma questo dà:

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

di esempio utilizzando io.BytesIO

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

Answer 1

La sua domanda mi ha aiutato a capire le cose, quindi grazie. Ecco un semplice esempio pitone sull'esempio pitone nella documentazione:

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)