在上导入自定义模块IPython.parallel带有sync_imports（）的引擎

Question

我一直在玩IPython.parallel我想使用我自己的一些自定义模块，但未能如the cookbook使用dview.sync_imports()中所述做到这一点。唯一对我有用的是

def my_parallel_func(args):
    import sys
    sys.path.append('/path/to/my/module')
    import my_module
    #and all the rest

然后主要是为了

^{pr2}$

我认为正确的方法应该是

 with dview.sync_imports():
     import sys
     sys.path.append('/path/to/my/module')
     import my_module

但这会抛出一个错误，说明没有名为my_module的模块。在

那么，使用dview.sync_imports()的正确方法是什么？？在

Answer 1

问题是您只在运行客户端的本地进程中更改PYTHONPATH，而不是在运行{}的远程进程中更改{}。在

如果运行下一个和平代码，您可以观察到这种行为：

from IPython.parallel import Client

rc = Client()
dview = rc[:]

with dview.sync_imports():
    import sys
    sys.path[:] = ['something']

def parallel(x):
    import sys
    return sys.path

print 'Local: ', sys.path
print 'Remote: ', dview.map_sync(parallel, range(1))

基本上，所有要与sync_imports一起使用的模块必须已经在PYTHONPATH中。在

如果它不在PYTHONPATH中，则必须将其添加到远程执行的函数中的路径中，然后在函数中导入模块。在