【发布时间】:2014-07-06 16:22:50
【问题描述】:
我正在考虑实现一个轻量级的分布式处理框架,它与Python中的multiprocessing有类似的api。一个例子如下:
#! /usr/bin/env python
#
# distributed processing demo api
#
from dprocessing import Pool, SSHBackend
def woker(*args, **kwargs):
print args
print kwargs
ssh_config = {
'artisans': [
{'host': '172.18.217.1', 'username': 'user',
'password': 'pass', 'cores': 2},
{'host': '172.18.217.2', 'username': 'user',
'password': 'pass', 'cores': 4},
],
}
backend = SSHBackend(**ssh_config)
pool = Pool(backend)
pool.map(woker, range(10)) # run 10 jobs in 6 processes by 2 artisans
these projects 是否可以通过简单的 api 实现在多台计算机上运行作业的目标?您能给我一些实施框架的建议吗?
【问题讨论】:
标签: python multiprocessing distributed-computing