1

我正在为 datastax 的发行版使用cassandra python 驱动程序。麻麻编码...

from cassandra.io.libevreactor import LibevConnection
from cassandra.cluster import Cluster
cluster = Cluster(['some ip addr'])
cluster.connection_class = LibevConnection

失败：

   session = cluster.connect('demodb')
   session.execute("INSERT INTO colFamName(attr1, attr2) VALUES ('123jkd', 'sdflkj')")
   session.execute("SELECT attr1 FROM colFamName")

通过：

   session = cluster.connect('demodb')
   session.execute("INSERT INTO colFamName(attr1, attr2) VALUES ('123jkd', 'sdflkj')")
   session.set_keyspace('demodb')
   session.execute("SELECT attr1 FROM colFamName")

错误：

  File "build/bdist.linux-x86_64/egg/cassandra/cluster.py", line 995, in execute
  File "build/bdist.linux-x86_64/egg/cassandra/cluster.py", line 2195, in result
cassandra.InvalidRequest: code=2200 [Invalid query] message="unconfigured columnfamily <my_columnfamily_name>"

只要我自上次 session.execute 调用以来“重置”了键空间，连续的 session.execute 调用就可以工作。我不应该在每次 session.execute 调用后重置它。

想法？（我已经在github提交了issue，收到回复后会更新）

4

0 回答 0