小编Ene*_*eek的帖子

我无法使用python Cassandra-Driver连接

我可能会失踪什么?我无法使用python Cassandra-Driver进行连接,但是在使用CQL模块时我似乎能够正常连接.

cluster = Cluster(
contact_points=['10.x.x.xx',],
port=9160)

session = cluster.connect()
session.set_keyspace("mykeyspace")
Run Code Online (Sandbox Code Playgroud)

输出:

cassandra.cluster.NoHostAvailable :('无法连接到任何服务器',{'10 .0.x.xx':ConnectionShutdown('连接到10.0.x.xx已关闭',)})

另外,如果重要的话,我正在从一个具有单个节点的虚拟机托管cassandra.

virtual-machine cassandra python-2.7

5
推荐指数
1
解决办法
6544
查看次数

Python 多处理帮助条件退出

我正在用 Python 进行多处理,但我对这个主题没有任何运气。基本上我有一个运行起来很耗时的程序。我需要在 1 到 100 的范围内运行它,但是一旦满足我正在寻找的条件,我想中止所有进程。条件是返回值 == 90。

这是一个非多进程代码块。谁能给我一个例子,说明他们如何将其转换为多进程函数,一旦满足“90”条件,代码将退出所有进程?

def Addsomething(i):
    SumOfSomething = i + 1    
    return SumOfSomething

def RunMyProcess():
    for i in range(100):
        Something = Addsomething(i)
        print Something
    return

if __name__ == "__main__":
    RunMyProcess()
Run Code Online (Sandbox Code Playgroud)

编辑:

我在测试第三个版本时遇到了这个错误。知道是什么原因造成的吗?

Exception in thread Thread-3:
Traceback (most recent call last):
  File "C:\Python27\lib\threading.py", line 554, in __bootstrap_inner
    self.run()
  File "C:\Python27\lib\threading.py", line 507, in run
    self.__target(*self.__args, **self.__kwargs)
  File "C:\Python27\lib\multiprocessing\pool.py", line 379, in _handle_results
    cache[job]._set(i, obj)
  File "C:\Python27\lib\multiprocessing\pool.py", line 527, in _set
    self._callback(self._value)
  File "N:\PV\_Proposals\2013\ESS - …
Run Code Online (Sandbox Code Playgroud)

python multiprocessing multiprocess python-multithreading

2
推荐指数
1
解决办法
3832
查看次数