0

我希望在 R 中实现以下模式，但运气不佳：

后台作业（无限 while 循环）将轮询 API 以检索检索结果。此函数必须将结果传递回主 R 会话。我最初认为这可能是一个函数，一旦将结果分配给全局变量，就会递归调用自身（这可能是错误的方法）：

listen <- function() {
  x <<- 1
  listen()
}
listen()
# Error: C stack usage  15926544 is too close to the limit

从 API 检索消息后，将生成一个长时间运行的数据处理任务（这可能需要 10 到 20 秒之间的任何时间）。我还没有完全弄清楚的一件事是如何在不同的 R 进程之间传递数据，我想像 Redis 这样的东西或者svSocket需要参与。

现在，棘手的一点是让 API 知道（不时地）数据处理仍在积极进行，以避免重新发送消息。

4

0 回答 0