Plumber2异步端点无法继承全局环境：是否有内置解决方案？

问题背景 #

当在Plumber2中使用默认mirai评估器并设置async = TRUE时，异步工作进程无法继承主R会话全局环境中的资源（如已加载的库、全局对象、数据库连接等），导致处理请求时出现找不到函数/对象的错误。

解决方案 #

Plumber2目前没有内置的自动同步主环境的方法，但可以通过以下两种方式解决：

方案1：预初始化mirai工作进程（推荐） #

利用mirai::daemons()的init参数，在启动工作进程时执行初始化代码，一次性加载所有需要的依赖和全局资源。

修改后的完整代码：

library(plumber2)
library(dplyr)
library(mirai)

# 定义初始化逻辑：加载依赖、配置全局资源
init_logic <- quote({
  library(dplyr)
  # 可添加其他初始化操作：读取环境变量、加载机器学习模型、创建数据库连接等
})

# 启动mirai工作进程时绑定初始化逻辑
mirai::daemons(2, init = init_logic)

# 定义API端点
pa <- api() |>
  api_get("/test", handler = function() {
    tryCatch({
      my_data <- tibble(x = 1:5)
      my_data |> dplyr::filter(x > 3)
    }, error = function(e) {
      list(error = conditionMessage(e))
    })
  }, async = TRUE)

# 启动API
pa |> api_run(port = 8000, block = FALSE)

执行后调用curl http://localhost:8000/test，会返回正确的过滤结果：[{"x":4},{"x":5}]。

方案2：自定义异步评估器 #

如果需要更灵活的动态初始化，可以自定义评估器，在每次处理请求前确保工作进程已加载必要资源。

示例代码：

library(plumber2)
library(dplyr)
library(mirai)

# 自定义mirai评估器
custom_evaluator <- function(expr, envir) {
  mirai::mirai({
    # 检查并加载依赖
    if (!"dplyr" %in% .packages()) {
      library(dplyr)
    }
    # 执行请求处理逻辑
    eval(expr, envir = envir)
  })
}

# 定义API并使用自定义评估器
pa <- api() |>
  api_get("/test", handler = function() {
    tryCatch({
      my_data <- tibble(x = 1:5)
      my_data |> dplyr::filter(x > 3)
    }, error = function(e) {
      list(error = conditionMessage(e))
    })
  }, async = TRUE, evaluator = custom_evaluator)

# 启动mirai工作进程
mirai::daemons(2)

# 启动API
pa |> api_run(port = 8000, block = FALSE)

原理说明 #

mirai的工作进程是独立的R会话，默认采用隔离设计，不会自动继承主会话的全局环境。Plumber2的默认mirai评估器未内置环境同步逻辑，因此需要通过预初始化或自定义评估器的方式，手动将主会话的必要资源同步到工作进程中。

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