2

我已经查看了这个和这个线程以及其他一些线程，但无法找出我的解决方案。

RPostgreSQL我已经使用 R 和 Shiny 构建了一个仪表板，并且说仪表板使用包从 Postgres 数据库中提取数据。目前，所有数据拉取和分析的代码都是在shinyServer函数之外完成的，只有显示部分（output和render函数）在该shinyServer部分中。我想对其进行设置，以便定期刷新仪表板数据并更新图表。我已经研究reactivePoll并invalidateLater理解了它们，但不能完全弄清楚如何在我的代码中实现它。

这是一个简化的示例server.R代码：

library(RPostgreSQL)

drv <- dbDriver("PostgreSQL")
con <- dbConnect(drv, host='host', port='12345', dbname='mydb',
                 user='me', password='mypass')

myQuery <- "select * from table"
myTable <- dbGetQuery(con, myQuery)

foo <- nrow(myTable)
bar <- foo * 2

shinyServer(
  function(input, output, session) {
    output$foo <- renderText(foo)
    output$bar <- renderText(bar)

    session$onSessionEnded(function(){
      dbDisconnect(con)
      dbDisconnect(con2)
      dbUnloadDriver(drv)
    })
  }
)

现在，如果我想foo定期更新，那也需要我刷新dbGetQuery我拥有的命令，而且我不知道如何让它们一起工作。我是否需要重新格式化并将所有内容放入shinyServer函数中？我有大约 250 行代码，将它们全部放在那里感觉不对，并且仅仅将数据提取部分放在那里可能会打乱事物的顺序。任何帮助表示赞赏。

4

1 回答 1

3

我会使用reactivePoll而不是invalidateLater，因为它只会在有新数据的情况下重新获取整个数据。

但是，没有办法将代码放入其中以获取数据shinyServer，因为您的后续计算取决于（反应性）数据。

免责声明：我对 SQL 没有任何经验，由于缺乏合适的数据库，我无法测试我的代码，但根据我对shiny以下代码的理解，应该可以工作。

library(RPostgreSQL)

drv <- dbDriver("PostgreSQL")
con <- dbConnect(drv, host='host', port='12345', dbname='mydb',
                 user='me', password='mypass')

check_for_update <- function() {
  dbGetQuery(con, "SELECT MAX(timestamp) FROM table") # edit this part in case
  # the syntax is wrong. the goal is to create an identifier which changes
  # when the underlying data changes
}
get_data <- function() {
  dbGetQuery(con, "select * from table")
}
close_connection <- function() {
  dbDisconnect(con)
  dbUnloadDriver(drv)
}

shinyServer(
  function(input, output, session) {
    # checks for new data every 10 seconds
    data <- reactivePoll(10000, session,
                         checkFunc = check_for_update,
                         valueFunc = get_data)

    # the outputs will only be refreshed in case the data changed
    output$foo <- renderText({
      nrow(data())
    })
    output$bar <- renderText({
      bar <- data() * 2
    })

    session$onSessionEnded(close_connection)
  }
)

根据您的应用程序的结构，将计算包装到一个单独的 中可能会有所帮助reactive，您可以在多个地方重复使用它。

可以在本教程中找到有关使用 shinyApps 执行代码的一些注意事项。

如果您遇到任何问题，请发表评论，我会尝试相应地更新我的帖子。

于 2015-10-09T23:07:23.020 回答