如何使用Python通过云端数据流将CSV文件导入云Bigtable？

import csv
from google.cloud import bigtable

# 连接到Bigtable实例
client = bigtable.Client(project='your-project-id', admin=True)
instance = client.instance('your-instance-id')
table = instance.table('your-table-id')

# 创建表和列族（如果不存在）
if not table.exists():
    table.create()
    table.column_family('your-column-family').create()

# 打开CSV文件并逐行读取数据
with open('your-csv-file.csv', 'r') as file:
    reader = csv.reader(file)
    next(reader)  # 跳过标题行
    rows = []
    for row in reader:
        # 转换每行数据为Bigtable行键和列值
        row_key = row[0]
        column_value = {
            'your-column-family:column1': row[1],
            'your-column-family:column2': row[2],
            # 可根据CSV文件的列数添加更多列
        }
        rows.append((row_key, column_value))

        # 批量插入数据到Bigtable表
        if len(rows) == 100:  # 每100行插入一次
            table.mutate_rows(rows)
            rows = []

    if rows:
        table.mutate_rows(rows)

# 关闭CSV文件和Bigtable客户端实例
file.close()
client.close()