在java web应用程序中将avro文件转换为csv

import org.apache.avro.Schema;
import org.apache.avro.file.DataFileReader;
import org.apache.avro.file.FileReader;
import org.apache.avro.generic.GenericDatumReader;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.io.DatumReader;
import com.opencsv.CSVWriter;
import java.io.FileWriter;
import java.io.IOException;

public class AvroToCsvConverter {
    public static void main(String[] args) {
        String avroFilePath = "path/to/avro/file.avro";
        String csvFilePath = "path/to/csv/file.csv";

        try {
            // 读取Avro文件
            DatumReader<GenericRecord> datumReader = new GenericDatumReader<>();
            FileReader<GenericRecord> fileReader = DataFileReader.openReader(new File(avroFilePath), datumReader);

            // 获取Avro模式
            Schema avroSchema = fileReader.getSchema();

            // 创建CSV文件写入器
            CSVWriter csvWriter = new CSVWriter(new FileWriter(csvFilePath));

            // 写入CSV文件表头
            csvWriter.writeNext(avroSchema.getFields().stream().map(Schema.Field::name).toArray(String[]::new));

            // 遍历Avro文件中的数据记录
            for (GenericRecord record : fileReader) {
                // 将Avro数据记录转换为CSV格式
                String[] csvRecord = record.getSchema().getFields().stream()
                        .map(field -> record.get(field.name()).toString())
                        .toArray(String[]::new);

                // 写入CSV文件
                csvWriter.writeNext(csvRecord);
            }

            // 关闭文件读写器
            fileReader.close();
            csvWriter.close();

            System.out.println("Avro文件已成功转换为CSV格式！");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}