无法使用“ COPY from”命令将数据导入Cassandra表/列系列。
我们尝试了
cqlsh> copy eqdata from '/home/swiftguy/cassandra/earthquakedata/weather-data-with-uuid.csv';
Bad Request: line 1:298 no viable alternative at input ')'
Aborting import at record #0 (line 1). Previously-inserted values still present.
表格详情
创建表格地震数据(eqtime时间戳,经度浮点,纬度浮点,深度浮点,幅值浮点,MagType文本,NbStations浮点,Gapv浮点,距离浮点,RMS浮点,源文本,EventID文本,Version文本,id uuid,主键(eqtime , ID));
这是我们尝试导入的csv文件
请帮帮我。提前致谢。
从http://www.datastax.com/documentation/tutorials/gis.zip下载gis.zip和地震数据,然后将CSV与您使用的CSV进行比较。有一个标头,逗号用作分隔符,但从可用的公共数据中基本上没有改变。在cqlsh中,记住要在COPY命令中调整'path / earthquakes.csv'并使用默认的COPY选项:
创建表格地震( 日期时间文字PRIMARY KEY, 纬度加倍, 经度双倍, 深度加倍 数量级增加一倍 输入文字, nbstations int, 差距加倍, 距离加倍, 均方根 源文本, eventid int ); 从'path / earthquakes.csv'WITH HEADER ='true'复制地震(日期时间,纬度,经度,深度,大小,磁型,nbstations,间隙,距离,均方根,震源,事件id);
运行Brian的python脚本添加UUID,并为UUID调整表后,运行以下命令将导入所有行:
cqlsh:mykeyspace>使用'HEADER / HEADER / COPY / COPY / COPY / COPY_REQUEST_NAME>复制地震(日期时间,纬度,经度,深度,震级,磁型,nbstations,间隔,距离,均方根,源,eventid,newid) ='true'; 在2分钟35.913秒内导入了77037行。
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句