处理多个AVRO (avsc文件)，这些AVRO(avsc文件)位于不同的目录中，并使用python (fastavro)相互引用

import fastavro

# 读取AVRO文件
with open('path/to/file.avro', 'rb') as avro_file:
    reader = fastavro.reader(avro_file)
    for record in reader:
        # 处理AVRO记录
        print(record)

import os

# 获取目录中的AVRO文件
directory = 'path/to/directory'
avro_files = [os.path.join(directory, file) for file in os.listdir(directory) if file.endswith('.avro')]

# 处理每个AVRO文件
for avro_file in avro_files:
    with open(avro_file, 'rb') as file:
        reader = fastavro.reader(file)
        for record in reader:
            # 处理AVRO记录
            print(record)

import fastavro

# 加载AVRO Schema文件
with open('path/to/schema.avsc', 'rb') as schema_file:
    schema = fastavro.load_schema(schema_file)

# 读取AVRO文件并解析引用的数据结构
with open('path/to/file.avro', 'rb') as avro_file:
    reader = fastavro.reader(avro_file, schema=schema)
    for record in reader:
        # 处理AVRO记录
        print(record)