从csv到Cassandra的无效插入

问题描述 投票:0回答:1

我正在尝试将大的csv文件导入Cassandra,我将向您显示该表和csv行:

查询创建表

create table listings_detail (id bigint PRIMARY KEY, name text, neighbourhood text, bedrooms float, amenities text, price float, number_of_reviews float, calculated_host_listings_count float);

要导入到表中的查询

COPY listings_detail (id, name, neighbourhood, bedrooms, amenities, price, number_of_reviews, calculated_host_listings_count) FROM 'listings_detail.csv' WITH DELIMITER = ',' AND HEADER = TRUE;

csv的标题和第一行的副本

_ id,名称,社区,卧室,设施,价格,评论数,计算的主机列表数量

18461891,明亮舒适的1B工作室,应有尽有!,阿斯托里亚,0,“ {TV”“无线互联网”“”“空调”“厨房”“烟雾探测器”“”一氧化碳探测器“”“”急救箱“”“”“安全卡”“必需品”“吹风机”“”“”翻译缺失:en.hosting_amenity_49“”“”“翻译缺失:en.hosting_amenity_50”“}”,110.00,0,1

最后是所有行的CQL输出。

无法导入1行:ParseError-无法解析{TV“ Cable TV”“。Internet。”“ Wireless Internet”“。厨房。”“允许吸烟”“。”“蜂鸣器/无线对讲机”“。加热。 Essentials.Shampoo。“” 24小时登记入住“”“。衣架。”“吹风机”“。”“笔记本电脑友好的工作空间”“”。“”缺少翻译:en.hosting_amenity_49“”。“”缺少翻译:zh。 Hosting_amenity_50“”}“:无法将字符串转换为浮点数:{TV” Cable TV“”。Internet。“”无线互联网“”。厨房。“”允许吸烟“”。“”蜂鸣器/无线对讲机“”。加热。 Essentials.Shampoo。“” 24小时入住“”“。衣架。”“吹风机”“。”“便携式电脑友好,不重试就放弃了

无法导入20行:InvalidRequest-来自服务器的错误:code = 2200 [Invalid query] message =“字符串未通过验证。”,尝试5次后放弃无法导入4行:InvalidRequest-来自服务器的错误:code = 2200 [Invalid query] message =“字符串未验证。”,稍后将重试,尝试5次中的3次无法导入20行:InvalidRequest-来自服务器的错误:code = 2200 [Invalid query] message =“ String not validate。”,稍后将重试,尝试5次中的4次无法导入20行:InvalidRequest-来自服务器的错误:code = 2200 [Invalid query] message =“字符串未验证。”,5次尝试后放弃

我不知道csv在“便利设施”列中有一个错误,这是一个失败的想法。

csv cassandra cqlsh
1个回答
0
投票

您可以发布.csv的内容吗?对我来说,您似乎遇到了文件中未转义的“”字符的问题。

我认为您需要检查copy命令的QUOTE和ESCAPE选项:https://docs.datastax.com/en/archived/cql/3.3/cql/cql_reference/cqlshCopy.html

© www.soinside.com 2019 - 2024. All rights reserved.