【发布时间】:2017-08-22 02:51:57
【问题描述】:
当我尝试从 python 运行以下命令时(我正在使用带有 Python 2.7.6 的 Cassandra Datastax Python 驱动程序)
cluster = Cluster([CASSANDRA_HOST], port=CASSANDRA_PORT, cql_version=CASSANDRA_CQL_VERSION, protocol_version=3)
session = cluster.connect(CASSANDRA_KEYSPACE)
NEW_ID = "9999999999"
CQL_FILE_NAME = "FNAME-"+NEW_ID+".cql"
cql_cmd = "SOURCE '~/dev/cql_files/"+ CQL_FILE_NAME + "'"
session.execute(cql_cmd)
我收到以下错误:
File "/usr/local/lib/python2.7/dist-packages/cassandra/cluster.py", line 2012, in execute
return self.execute_async(query, parameters, trace, custom_payload, timeout, execution_profile, paging_state).result()
File "/usr/local/lib/python2.7/dist-packages/cassandra/cluster.py", line 3801, in result
raise self._final_exception
cassandra.protocol.SyntaxException: <Error from server: code=2000 [Syntax error in CQL query] message="line 1:0 no viable alternative at input 'SOURCE' ([SOURCE]...)">
但是当我从 cqlsh 运行相同的字符串时,它运行良好。关于我应该改变什么的任何想法?谢谢!
字符串如下所示:
"SOURCE '~/dev/cql_files/FNAME-9999999999.cql'"
【问题讨论】:
标签: python cassandra datastax cql cqlsh