【发布时间】:2017-03-24 13:52:17
【问题描述】:
我已经尝试过前面提到的here 和here 的解决方案。我正在通过 datastax 使用 cassandra-driver。我的 cassandra 版本是 2.2.8。我在其中创建了键空间 CT_KEYSPACE 和 CT_TABLE。我通过cqlsh 提示在 CT_TABLE 中插入了值。以下是检索行的python代码
from cassandra.cluster import Cluster
cluster = Cluster()
session = cluster.connect('CT_KEYSPACE')
result = session.execute("select * from CT_TABLE")
print result.attribute, result.value
以下是 DESCRIBE CT_KEYSPACE 的输出:
cqlsh> describe ct_keyspace
CREATE KEYSPACE ct_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '1'} AND durable_writes = true;
CREATE TABLE ct_keyspace.ct_table (
attribute text PRIMARY KEY,
value int
) WITH bloom_filter_fp_chance = 0.01
AND caching = '{"keys":"ALL", "rows_per_partition":"NONE"}'
AND comment = ''
AND compaction = {'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy'}
AND compression = {'sstable_compression': 'org.apache.cassandra.io.compress.LZ4Compressor'}
AND dclocal_read_repair_chance = 0.1
AND default_time_to_live = 0
AND gc_grace_seconds = 864000
AND max_index_interval = 2048
AND memtable_flush_period_in_ms = 0
AND min_index_interval = 128
AND read_repair_chance = 0.0
AND speculative_retry = '99.0PERCENTILE';
以下是我得到的错误:
Traceback (most recent call last):
File "connection.py", line 4, in <module>
result = session.execute("select * from CT_TABLE")
File "/usr/local/lib/python2.7/dist-packages/cassandra/cluster.py", line 1998, 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 3781, in result
raise self._final_exception
cassandra.cluster.NoHostAvailable: ('Unable to complete the operation against any hosts', {})
非常感谢任何帮助。
【问题讨论】: