带有 if 语句的 ReactiveTimer R-Shiny

Posted 2023-03-24

【中文标题】带有 if 语句的 ReactiveTimer R-Shiny

【英文标题】：ReactiveTimer with if statement R-Shiny

【发布时间】：2018-04-19 13:19:28

【问题描述】：

我制作了一个在 linux 服务器上运行的 R-Shiny 应用程序。 我需要的所有数据都来自使用 API 和库（coinmarketcapr）的网站。

应用每 5 分钟检索一次最新数据，并将其保存在服务器上的 csv 文件中。

但现在我遇到的问题是，每次重新加载页面时，应用程序都会检索新数据，而我的时间序列中总是有重复的值。

我使用 ReactiveTimer，设置为 5 分钟。

ReactiveTimer 是否有可能检查 csv 文件中最后一个条目的时间并将其与当前系统时间进行比较？如果 csv 文件中的时间应该比系统时间早 5 分钟或更早，他应该执行代码，否则不执行。

我还想问是否有人知道你是否可以运行一个闪亮的应用程序而无需在浏览器中打开它，即。 e.代码不断运行并收集数据？

编辑：

应用开启：http://srv-lab-t-416.zhaw.ch/shiny/Crypto10/

R-代码：

autoInvalidate3 <- reactiveTimer((5*60*1000), session)

          Crypto10 <- reactive(
                    Crypto10 <- rep(NA,length(Index.Daten$Date))
                    z = 0
                    for(i in length(Index.Daten$Date):1)
                              z = z +1

                              # Price
                              P.i = c(Index.Daten$BTC.Price[i],Index.Daten$BCH.Price[i],Index.Daten$ETH.Price[i],Index.Daten$DASH.Price[i],Index.Daten$MIOTA.Price[i],
                                      Index.Daten$LTC.Price[i],Index.Daten$XMR.Price[i],Index.Daten$XEM.Price[i],Index.Daten$NEO.Price[i],Index.Daten$XRP.Price[i])

                              P.0 = c(Index.Daten$BTC.Price[length(Index.Daten$Date)],Index.Daten$BCH.Price[length(Index.Daten$Date)],Index.Daten$ETH.Price[length(Index.Daten$Date)],
                                      Index.Daten$DASH.Price[length(Index.Daten$Date)],Index.Daten$MIOTA.Price[length(Index.Daten$Date)],
                                      Index.Daten$LTC.Price[length(Index.Daten$Date)],Index.Daten$XMR.Price[length(Index.Daten$Date)],
                                      Index.Daten$XEM.Price[length(Index.Daten$Date)],Index.Daten$NEO.Price[length(Index.Daten$Date)],Index.Daten$XRP.Price[length(Index.Daten$Date)])
                              # Coins
                              Q.i = c(Index.Daten$BTC.Coins[i],Index.Daten$BCH.Coins[i],Index.Daten$ETH.Coins[i],Index.Daten$DASH.Coins[i],Index.Daten$MIOTA.Coins[i],
                                      Index.Daten$LTC.Coins[i],Index.Daten$XMR.Coins[i],Index.Daten$XEM.Coins[i],Index.Daten$NEO.Coins[i],Index.Daten$XRP.Coins[i])


                              # MK.i = Preis.i * Q.i
                              MK.i = P.i*Q.i

                              # MK.0 = Preis.0 * Q.i
                              MK.0 = P.0*Q.i

                              Crypto10[z] = (sum(MK.i))/((sum(MK.0))/100)
                    
                    return(Crypto10)
          )

          output$C10 <- renderDygraph(
                    q <- data.frame(Index.Daten$Date,rev(Crypto10()))
                    dygraph(xts(q[,-1], order.by=q[,1]), xlab = "Time", ylab = "Indexpunkte") %>% dyRangeSelector()
          )

          Crypto10.V3 <- reactive(
                    autoInvalidate3()
                    if(!file.exists(paste(path,"Index.Daten.V3.csv", sep = "")))

                              Index.Daten.V3 = data.frame(Date = NA
                                                          ,BTC.Price = NA,BTC.Coins = NA
                                                          ,BCH.Price = NA,BCH.Coins = NA
                                                          ,ETH.Price = NA,ETH.Coins = NA
                                                          ,DASH.Price = NA,DASH.Coins = NA
                                                          ,MIOTA.Price = NA,MIOTA.Coins = NA
                                                          ,LTC.Price = NA,LTC.Coins = NA
                                                          ,XMR.Price = NA,XMR.Coins = NA
                                                          ,XEM.Price = NA,XEM.Coins = NA
                                                          ,NEO.Price = NA,NEO.Coins = NA
                                                          ,XRP.Price = NA,XRP.Coins = NA)

                              Sys.setenv(TZ='CET')
                              Index.Daten.V3$Date = Sys.time()

                              write.csv(Index.Daten.V3,(paste(path,"Index.Daten.V3.csv", sep = "")))

                     else

                              # Index.Daten.V3 einlesen
                              Index.Daten.V3 = subset(read.csv(paste(path,"Index.Daten.V3.csv", sep = ""),sep = ","),select = -X)
                              Index.Daten.V3$Date = as.POSIXct(Index.Daten.V3$Date)
                    

                    API.BTC = API.all()[which(API.all()$symbol == "BTC"),]
                    API.BCH = API.all()[which(API.all()$symbol == "BCH"),]
                    API.ETH = API.all()[which(API.all()$symbol == "ETH"),]
                    API.DASH = API.all()[which(API.all()$symbol == "DASH"),]
                    API.MIOTA = API.all()[which(API.all()$symbol == "MIOTA"),]
                    API.LTC = API.all()[which(API.all()$symbol == "LTC"),]
                    API.XMR = API.all()[which(API.all()$symbol == "XMR"),]
                    API.XEM = API.all()[which(API.all()$symbol == "XEM"),]
                    API.NEO = API.all()[which(API.all()$symbol == "NEO"),]
                    API.XRP = API.all()[which(API.all()$symbol == "XRP"),]

                    if(is.na(Index.Daten.V3$BTC.Price[length(Index.Daten.V3$BTC.Price)]))

                              p = length(Index.Daten.V3$Date)

                              Index.Daten.V3[p,2:21] = c(
                                        as.numeric(API.BTC$price_usd),as.numeric(API.BTC$available_supply),
                                        as.numeric(API.BCH$price_usd),as.numeric(API.BCH$available_supply),
                                        as.numeric(API.ETH$price_usd),as.numeric(API.ETH$available_supply),
                                        as.numeric(API.DASH$price_usd),as.numeric(API.DASH$available_supply),
                                        as.numeric(API.MIOTA$price_usd),as.numeric(API.MIOTA$available_supply),
                                        as.numeric(API.LTC$price_usd),as.numeric(API.LTC$available_supply),
                                        as.numeric(API.XMR$price_usd),as.numeric(API.XMR$available_supply),
                                        as.numeric(API.XEM$price_usd),as.numeric(API.XEM$available_supply),
                                        as.numeric(API.NEO$price_usd),as.numeric(API.NEO$available_supply),
                                        as.numeric(API.XRP$price_usd),as.numeric(API.XRP$available_supply)
                              )

                              # Index.Daten.V3 als CSV speichern
                              write.csv(Index.Daten.V3,(paste(path,"Index.Daten.V3.csv", sep = "")))

                    else

                              p = length(Index.Daten.V3$Date)+1

                              Index.Daten.V3[p,2:21] = c(
                                        as.numeric(API.BTC$price_usd),as.numeric(API.BTC$available_supply),
                                        as.numeric(API.BCH$price_usd),as.numeric(API.BCH$available_supply),
                                        as.numeric(API.ETH$price_usd),as.numeric(API.ETH$available_supply),
                                        as.numeric(API.DASH$price_usd),as.numeric(API.DASH$available_supply),
                                        as.numeric(API.MIOTA$price_usd),as.numeric(API.MIOTA$available_supply),
                                        as.numeric(API.LTC$price_usd),as.numeric(API.LTC$available_supply),
                                        as.numeric(API.XMR$price_usd),as.numeric(API.XMR$available_supply),
                                        as.numeric(API.XEM$price_usd),as.numeric(API.XEM$available_supply),
                                        as.numeric(API.NEO$price_usd),as.numeric(API.NEO$available_supply),
                                        as.numeric(API.XRP$price_usd),as.numeric(API.XRP$available_supply))

                              Sys.setenv(TZ='CET')
                              Index.Daten.V3$Date[p] = Sys.time()

                              # Index.Daten.V3 als CSV speichern
                              write.csv(Index.Daten.V3,(paste(path,"Index.Daten.V3.csv", sep = "")))
                    

【问题讨论】：

能否分享一个最低可重现的示例代码？

理想情况下，您希望通过 crontab 运行单独的 r 作业，例如：***.com/questions/12014837/…

【参考方案1】：

我通过使用 cronR 解决了这个问题。 API 函数的所有数学运算现在都在一个单独的文件中进行，闪亮的应用程序只收集数据并显示它。

所以现在，我不必再使用 ReactiveTimer。

【讨论】：

你找到增加闪亮应用程序等待时间的方法了吗？

@D. Iseli，我想安排任务 inshiny 应用程序。 ***.com/questions/50663500/…。我可以知道如何联系您吗？ linkedin.com/in/denis-iseli-43632413b