如何在R的foreach并行执行中传递脚本名至子脚本用于日志记录？

要实现给每个被执行的脚本传递自身名称的需求，你可以借助sys.source()替代source()，并利用环境变量传递的方式让脚本能访问到当前运行的脚本路径/名称。这里有两种实用的修改方式：

方式一：传递完整脚本路径 #

直接在foreach循环体内定义脚本变量，然后用sys.source()加载脚本并共享当前环境，这样脚本里就能直接读取这个变量：

cl <- makeCluster(detectCores() - 1)
registerDoParallel(cl, cores = detectCores() - 1)

dopar_output <- foreach(x=listExec, .errorhandling = "pass") %dopar% {
  # 定义当前脚本的完整路径变量
  current_script_path <- x
  # 使用sys.source加载脚本，指定当前环境，让脚本能访问current_script_path
  sys.source(x, envir = environment())
}

之后在你的目标脚本里，就可以直接用current_script_path来记录日志了，比如：

# 示例：在被执行的脚本里添加日志
cat(sprintf("Started running script: %s at %s\n", current_script_path, Sys.time()))
# ... 脚本原有逻辑 ...
cat(sprintf("Finished running script: %s at %s\n", current_script_path, Sys.time()))

方式二：传递简化的脚本文件名 #

如果日志里只需要文件名而非完整路径，可以用basename()处理路径：

cl <- makeCluster(detectCores() - 1)
registerDoParallel(cl, cores = detectCores() - 1)

dopar_output <- foreach(x=listExec, .errorhandling = "pass") %dopar% {
  # 提取脚本文件名（不含路径）
  current_script_name <- basename(x)
  sys.source(x, envir = environment())
}

对应的脚本日志可以写：

cat(sprintf("Processing script: %s\n", current_script_name))

为什么用sys.source而不是source？ #

source()默认会在全局环境执行脚本，而sys.source()可以指定执行环境（这里用environment()指定当前foreach循环的局部环境），这样能确保每个worker进程里的脚本变量是独立且正确传递的，避免全局环境变量冲突的问题。

另外，保留.errorhandling = "pass"的设置，能让你在dopar_output里看到哪个脚本执行出错，结合脚本名称变量就能快速定位问题啦。

内容的提问来源于stack exchange，提问作者Paul Gazagne