【发布时间】:2017-11-02 10:12:54
【问题描述】:
我最近创建了一个利用 sparklyr 可能性的 R 包。我从 opencpu 调用 package main 函数,并将我的所有数据作为流的 url 作为参数传递。通过 spark 以分布式方式成功分析数据流并提供一些结果。
我唯一的问题是完成执行部分需要很多时间。我尝试通过 opencpu.call 和 opencpu.rpc 调用我的包,但它们都让我等到进程结束。
由于 opencpu 是一种令人惊叹的微服务架构方法,因此具有真正异步调用的可能性将非常有用。
在不久的将来是否支持或计划支持以下内容?
选项 A:立即接收 sessionid(即使进程仍在执行)。然后客户端负责使用他的 sessionid 询问进程的状态。
选项B:定义一个ocpu服务器触发的回调url,解析过程执行完成后传递sessionid。
非常感谢您的帮助!
【问题讨论】:
标签: r asynchronous sparklyr opencpu