我有一个avro文件,我想根据一些标准过滤出记录。如何在读取时从文件中删除记录?
from fastavro import reader
with open("D:///temp/load_data.avro", 'rb') as fo:
avro_reader = reader(fo)
for record in avro_reader:
if(record['NAME'] == ''):
//remove
目前这是不可能的。你需要写一个新的文件,里面有你想保留的记录。