在连接到PostgreSQL的Shiny应用中设置数据刷新[英] Setting up data refreshing in Shiny app connected to PostgreSQL

本文是小编为大家收集整理的关于在连接到PostgreSQL的Shiny应用中设置数据刷新的处理方法,想解了在连接到PostgreSQL的Shiny应用中设置数据刷新的问题怎么解决?在连接到PostgreSQL的Shiny应用中设置数据刷新问题的解决办法?那么可以参考本文帮助大家快速定位并解决问题。

问题描述

我看过 这个this 线程和其他一些线程,但还没有能够找出我的解决方案.

我已经使用 R 和 Shiny 构建了一个仪表板,并且说仪表板使用 RPostgreSQL 包从 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 行代码,将它们全部放在那里感觉不对,并且仅仅将数据提取部分放在那里可能会打乱事物的顺序.任何帮助表示赞赏.

推荐答案

我会使用 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 执行代码的一些注意事项.

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

本文地址:https://www.itbaoku.cn/post/1764143.html