为从 CSV 文件导入的每一行添加 UUID

我们想要将 .csv 文件中的 10 万行导入到 Cassandra 表中。

每行没有唯一的值，因此我们想要向每个导入的行添加 UUID，在从 CSV 文件导入数据时如何自动执行此操作。

.CSV 文件中的示例行（第一行是列名称）

DateTime,Latitude,Longitude,Depth,Magnitude,MagType,NbStations,Gap,Distance,RMS,Source,EventID,Version
2014-09-11T12:36:11.000+00:00,67.689,-162.763,14.6,3.9,ml,,,,0.79,ak,ak11387003,1410441826879

想要将 UUID 添加到每一行，如下所示

UID, DateTime,Latitude,Longitude,Depth,Magnitude,MagType,NbStations,Gap,Distance,RMS,Source,EventID,Version
c37d661d-7e61-49ea-96a5-68c34e83db3a,2014-09-11T12:36:11.000+00:00,67.689,-162.763,14.6,3.9,ml,,,,0.79,ak,ak11387003,1410441826879

无法直接从 CQL 执行此操作复制命令，但您可以先在 Cassandra 外部处理 CSV 文件。

例如，下面是一个 Python 脚本，它将从文件 in.csv 中读入，将 UUID 列附加到每行，然后写入 out.csv：

#!/usr/bin/python
# read in.csv adding one column for UUID

import csv
import uuid

fin = open('in.csv', 'rb')
fout = open('out.csv', 'w')

reader = csv.reader(fin, delimiter=',', quotechar='"')
writer = csv.writer(fout, delimiter=',', quotechar='"')

firstrow = True
for row in reader:
    if firstrow:
        row.append('UUID')
        firstrow = False
    else:
        row.append(uuid.uuid4())
    writer.writerow(row)

可以使用 CQL COPY 导入生成的文件（在相应地创建架构之后）。如果您使用此示例，请务必阅读Python 的 uuid 函数选择您需要的一个（可能uuid1 or uuid4).