我正在尝试使用 MPI4py 和 OpenMPI 在多个主机上生成一组工作进程,但 spawn 命令似乎忽略了我的主机文件。我已经发布了我的完整测试,但这里是关键部分:
基于论坛讨论,我的经理脚本调用 spawnhostfile
选项:
mpi_info = MPI.Info.Create()
mpi_info.Set("hostfile", "worker_hosts")
comm = MPI.COMM_SELF.Spawn(sys.executable,
args=['testworker.py'],
maxprocs=args.worker_count,
info=mpi_info).Merge()
在worker_hosts
文件中,我列出了 Scyld Beowulf 集群中的节点:
myhead1 slots=2
mycompute1 slots=2
mycompute2 slots=2
mycompute3 slots=2
mycompute4 slots=3
经理和工人都打电话MPI.Get_processor_name()
,但他们都报告“myhead1”。如果我使用相同的主机文件,mpirun
它可以工作:
> mpirun -hostfile worker_hosts -np 3 python -c "from mpi4py import MPI; print MPI.Get_processor_name()"
myhead1
myhead1
mycompute1
如果我将主机文件的名称更改为不存在的名称,例如bogus_file
,我会收到错误消息:
--------------------------------------------------------------------------
Open RTE was unable to open the hostfile:
bogus_file
Check to make sure the path and filename are correct.
--------------------------------------------------------------------------
[Bulbasaur:86523] [[3458,0],0] ORTE_ERROR_LOG: Not found in file base/rmaps_base_support_fns.c at line 83
[Bulbasaur:86523] [[3458,0],0] ORTE_ERROR_LOG: Not found in file rmaps_rr.c at line 82
[Bulbasaur:86523] [[3458,0],0] ORTE_ERROR_LOG: Not found in file base/rmaps_base_map_job.c at line 88
[Bulbasaur:86523] [[3458,0],0] ORTE_ERROR_LOG: Not found in file base/plm_base_launch_support.c at line 105
[Bulbasaur:86523] [[3458,0],0] ORTE_ERROR_LOG: Not found in file plm_rsh_module.c at line 1173
所以 OpenMPI 注意到了这个hostfile
选项,它似乎没有使用它。该hostfile
选项列在OpenMPI 文档中。
Key Type Description
--- ---- -----------
host char * Host on which the process should be spawned.
See the orte_host man page for an
explanation of how this will be used.
hostfile char * Hostfile containing the hosts on which
the processes are to be spawned. See
the orte_hostfile man page for an
explanation of how this will be used.
如何为生成请求指定主机文件?