r - 使用 doParallel 时如何获取节点或进程 ID？

Question

我正在一个 12 节点集群上运行一个并行进程。

并且想知道是否有办法在 foreach 期间获取节点 ID 或节点编号或节点名称称呼？

像这样的东西:

foreach(i = 1:12, .combine=c) %dopar% {node.name()}

这将有助于处理文件。

Answer 1

foreach 包不提供对节点 ID 或节点名称的任何支持，但 R 具有“sys.info”功能，因此您可以使用:

foreach(i = 1:12, .combine=c) %dopar% {
  Sys.info()[['nodename']]
}

要创建唯一的工作人员 ID，您可以将节点名称与工作人员的进程 ID 结合起来:

foreach(i = 1:12, .combine=c) %dopar% {
  paste(Sys.info()[['nodename']], Sys.getpid(), sep='-')
}