我可能会失踪什么?我无法使用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.
我正在用 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)