R Shiny 在不同的进程中运行任务/脚本答案

【问题标题】：R Shiny run task/script in different processR Shiny 在不同的进程中运行任务/脚本
【发布时间】：2018-02-26 05:25:32
【问题描述】：

在我的 Shiny 应用程序中，用户可以生成大量的 powerpoint 报告。当它包含大量幻灯片时，可能需要超过 30 分钟才能完成。因此，我想在独立的进程/任务中处理这些任务，即使在应用程序关闭时也可以工作 - 例如用户单击按钮生成报告，关闭应用程序，当报告准备好时，应用程序通过电子邮件通知用户。是否有任何好的做法或经过验证的解决方案可以做到这一点？

我的第一个想法是使用带有plan(multisession) 设置的future 包 - 但我不确定当用户关闭应用程序时会发生什么 - future 会话是否也关闭？

【问题讨论】：

mcparallel 适合您吗？ stat.ethz.ch/R-manual/R-devel/library/parallel/html/…
@Roman Luštrik，是的，但 mcparallel 是否让我创建独立会话，即使在我关闭应用程序后也能正常工作？
我无法访问 unix 机器，所以我无法真正测试它。
@Taz 你在 github 上有这个吗？我正在尝试做一些非常相似的事情（让用户使用闪亮构建一个 ppt），这可能会给我很大的帮助。
@Richard Lusch 我在客户的应用程序中使用的是此版本的开发版本：github.com/Tazovsky/shiny-async-demo + officer R 包。如果您需要任何详细信息，请给我发电子邮件；）

标签： r asynchronous parallel-processing shiny officer

【解决方案1】：

我很幸运这周能参加伦敦 EARL，我认为我在那里看到的最好的演讲之一就是关于这个（由 Joe Cheng）。您需要promises 包才能使其工作，并且正如文档中所说，支持异步编程的闪亮devtools::install_github("rstudio/shiny@async") 的特殊版本。

您可以通过使用dplyr 和promises 找到第一个文档here（future 也兼容）。

作为一个小例子（取自文档），使用以下内容运行密集计算：

read.csv.async("data.csv") %...>%
  filter(state == "NY") %...>%
  arrange(median_income) %...>%
  head(10) %...>%
  View()

基本上会返回控制台光标，允许您运行任何其他您想要的命令，并在完成后自动打开View 选项卡。稍等片刻我可能会找到一个闪亮的例子，但请记住，这仍在开发中，将在今年年底之前发布（我想会有更全面的文档）。

【讨论】：

未来的作者在这里；我正在确认乔在这里的工作将解决这个问题。（OP 想要关闭应用程序并稍后返回它的部分比较棘手；我的待办事项列表上支持持久可序列化和可重新加载的期货，但这需要一些时间）

【解决方案2】：

所以我使用future 包做了一些示例解决方法。即使应用程序关闭，代码也会在单独的会话（集群）中执行。我认为下一步只是弄清楚应用程序应该如何检查进程是否仍在运行或已完成。有什么想法吗？

library(future)
cl <- parallel::makeCluster(2L)
plan(cluster, workers = cl)

server <- function(input, output) {
  observeEvent(input$run, {

    iteration <- as.numeric(input$iteration)
    path <- input$path

    future::future({
      writeLog <- function(n, path) {
        file.remove(path)
        for (i in 1:n) {
          cat("#", i, "-",  as.character(Sys.time()), "\n", file = path, append = TRUE)
          Sys.sleep(1)
        }
      }
      writeLog(iteration, path)
    }, globals = c("iteration", "path"))
  })
}

ui <- fluidPage(
  sidebarLayout(
    sidebarPanel(
      tags$div("This app writes to file in cluster which means it is computed in parallel to this session. 
               It will execute even when app is closed.")
      , br()
      , shiny::textInput("path", "Path to log file", value = "/src/dev/export_performance/future.log")
      , shiny::textInput("iteration", "Iteration number", value = 60)    
    ),
    mainPanel(
      br()
      , actionButton("run", "Run future")
    )
  )
)

shinyApp(ui = ui, server = server)

【讨论】：