如何清理从csv文件读取的数据之前，流插入到bigquery表？

from google.cloud import bigquery

# 读取CSV文件
with open('data.csv', 'r') as file:
    csv_data = file.read()

# 数据清洗
cleaned_data = clean_csv_data(csv_data)

# 初始化BigQuery客户端
client = bigquery.Client()

# 创建BigQuery表
table_ref = client.dataset('my_dataset').table('my_table')
schema = [
    bigquery.SchemaField('column1', 'STRING'),
    bigquery.SchemaField('column2', 'INTEGER'),
    # 定义其他字段
]
table = bigquery.Table(table_ref, schema=schema)
table = client.create_table(table)

# 插入数据
rows_to_insert = []
for row in cleaned_data:
    rows_to_insert.append(tuple(row.values()))

client.insert_rows(table, rows_to_insert)