用python读取Avro文件创建SQL表

import avro.schema
from avro.datafile import DataFileReader
from avro.io import DatumReader
import psycopg2

# 读取Avro文件
reader = DataFileReader(open('data.avro', 'rb'), DatumReader())

# 获取Avro文件的模式
schema = reader.meta['avro.schema']
avro_schema = avro.schema.Parse(schema)

# 连接到TencentDB for PostgreSQL
conn = psycopg2.connect(database="your_database", user="your_username", password="your_password", host="your_host", port="your_port")
cur = conn.cursor()

# 创建SQL表
cur.execute("CREATE TABLE your_table (column1 datatype1, column2 datatype2, ...);")

# 插入数据
for record in reader:
    # 解析Avro记录
    data = avro.io.DatumReader(avro_schema).read(record)
    
    # 插入数据到SQL表
    cur.execute("INSERT INTO your_table VALUES (%s, %s, ...);", (data['column1'], data['column2'], ...))

# 提交事务并关闭连接
conn.commit()
cur.close()
conn.close()