相关疑难解决方法(0)

我开始尝试使用IPython并行工具并遇到问题.我启动我的python引擎:

ipcluster start -n 3

然后以下代码运行正常:

from IPython.parallel import Client

def dop(x):
    rc = Client()
    dview = rc[:]
    dview.block=True
    dview.execute('a = 5')
    dview['b'] = 10
    ack = dview.apply(lambda x: a+b+x, x)
    return ack

ack = dop(27)
print ack

按原样返回[42,42,42].但如果我将代码分成不同的文件:dop.py:

from IPython.parallel import Client

def dop(x):
    rc = Client()
    dview = rc[:]
    dview.block=True
    dview.execute('a = 5')
    dview['b'] = 10
    print dview['a']
    ack = dview.apply(lambda x: a+b+x, x)
    return ack

并尝试以下方法:

from dop import dop
ack = dop(27)
print ack

我从每个引擎得到错误:

[0:apply]: …