Tag: cassandra python driver

卡桑德拉连接空转和超时

我试图使用python驱动来加载和删除Cassandra的数据。 我已经尝试了这两个使用cassandra运行在docker集装箱，并在docker版本给我的问题后本地再次。 以下是我正在做的一个例子： class Controller(object): def __init__(self): self.cluster = Cluster() self.session = self.cluster.connect('mykeyspace') def insert_into_cassandra(self): query = ('INSERT INTO mytable (mykey, indexed_key) VALUES (?, ?)') prepared = self.session.prepare(query) prepared.consistency_level = ConsistencyLevel.QUORUM params_gen = self.params_generator(fname) execute_concurrent_with_args(self.session, prepared, self.parameter_generator(), concurrency=50) def delete_param_gen(self, results): for r in results: yield [r.mykey] def delete_by_index(self, value): query = "SELECT mykey from […]