Потоковая система () выводит на Shiny интерфейс (непрерывно) - PullRequest
Новая
       9

Потоковая система () выводит на Shiny интерфейс (непрерывно)

0 голосов
/ 01 июня 2018

Как я могу получить выходные данные текущей операции system() и передать ее на внешний интерфейс Shiny в режиме реального времени?

intern=T захватывает весь вывод в символьном векторе, но я бы предпочел «прослушать» вывод системы, как это происходит.

library(shiny) 
ui <- fluidPage(
   titlePanel("Stream the system output"),
   sidebarLayout(
      sidebarPanel(
         actionButton("btn1",label = "Let's stream")
      ),
      mainPanel(
         textOutput("textstream_output")
      )
   )
)
server <- function(input, output, session) {
  rv <- reactiveValues("textstream"=c(""))
  output$textstream_output <- renderText({
    rv$textstream
  })
  observeEvent(input$btn1,{
  # problem: is evaluated after finish, not during operation  
    rv$textstream <- system("Rscript -e \"for(i in 1:5){ print(Sys.time()); Sys.sleep(1);  };\"",
                            intern = T)
  })
}
shinyApp(ui = ui, server = server)

При запуске команды system с intern=F консоль R непрерывно обновляется один раз в секунду.Как я могу установить это в Shiny, в идеале, без необходимости разбивать вызов system на более мелкие куски?

enter image description here

Возможно, связано:

1 Ответ

0 голосов
/ 03 июня 2018

reactiveTimer обеспечивает один подход.Я предполагаю, что ваш подход не работает, потому что observeEvent обновляет реактивный объект только после завершения вычисления выражения.Вот мой подход.Я создаю скрипт, который хочу запустить в фоновом режиме, so_script.R, и перенаправляю вывод в so_output.txt.Мы хотим видеть содержимое so_output.txt во время работы скрипта. 

cat('sink(file = "so_output.txt")
  for (i in 1:10) {
    cat(format(Sys.time(), format = "%H:%M:%S"), "\n")
    Sys.sleep(1)
  }
  cat("*** EOF ***\n")
  sink()
', file = "so_script.R")

Вот приложение Shiny: 

library(shiny) 
ui <- fluidPage(
   titlePanel("Stream the system output"),
   sidebarLayout(
      sidebarPanel(
         actionButton("btn_start",label = "Let's stream"),
         actionButton("btn_stop",label = "Stop")
      ),
      mainPanel(
         htmlOutput("textstream_output")
      )
   )
)
server <- function(input, output, session) {
  rv <- reactiveValues(textstream = c(""),
                       timer = reactiveTimer(1000),
                       started = FALSE)
  observeEvent(input$btn_start, { 
    rv$started <- TRUE
    system2("Rscript", "so_script.R", wait = FALSE)
  })
  observeEvent(input$btn_stop, { rv$started <- FALSE })
  observe({
    rv$timer()
    if (isolate(rv$started))
      rv$textstream <- paste(readLines("so_output.txt"), collapse = "<br/>")
  })
  output$textstream_output <- renderUI({
    HTML(rv$textstream)
  })
}
shinyApp(ui = ui, server = server)

Каждый раз, когда срабатывает таймер, мы читаем содержимоеso_output.txt, если потоковая передача началась.Выход:

enter image description here

...