如何使用Python驱动程序在Cassandra中导入CSV

Question

我需要使用python驱动程序将CSV文件导入cassandra

import csv
with open('place_ratings.csv') as f_in:
companies = csv.load(f_in)
with open('place_ratings.csv') as f_in:
companies = csv.reader(f_in)
with open('C:apache-cassandra-3.11.7MonashMRDB_datasetsplace_ratings.csv') as f_in:
companies = csv.reader(f_in)

我尝试了上面的一切，wilr，rt和几乎所有的选项

我仍然得到错误：

File "<stdin>", line 1, in <module>
IOError: [Errno 2] No such file or directory: 'user_ratings.csv'

这里能做些什么？

Answer 1

问题似乎是CSV的路径。

使用正斜杠，这对Unix和Windows都有效。例如：

C:/apache-cassandra-3.11.7/MonashMRDB_datasets/place_ratings.csv

Windows上的另一种选择是用另一个反斜杠转义反斜杠：

C:\apache-cassandra-3.11.7\MonashMRDB_datasets\place_ratings.csv

但最好的做法是使用os.path，这样它就可以保证在任何平台上工作：

os.path.join("C:", "apache-cassandra-3.11.7MonashMRDB_datasets", "place_ratings.csv")

顺便说一句，编写用于导入CSV的新代码是在重新发明轮子。我建议您使用免费的DataStax Bulk Loader(docs，source(工具(dsbulk(。DSBulk允许您将数据从CSV或JSON加载/卸载到CSV或JSON。干杯