由于没有人提供这个帖子的解决方案以及我迫切需要一个解决方法的事实,这里是我的情况和一些抽象的解决方案/想法供辩论.
我的堆栈:
- 龙卷风
- 芹菜
- MongoDB的
- Redis的
- 的RabbitMQ
我的问题:为Tornado找到一种方法来调度芹菜任务(已解决),然后异步收集结果(任何想法？).
场景1 :(请求/响应黑客加上webhook)
- Tornado接收(用户)请求,然后在本地内存(或Redis)中保存{jobID :(用户)请求}以记住传播响应的位置,并使用jobID触发芹菜任务
- 当芹菜完成任务时,它会在某个网址上执行webhook并告诉龙卷风这个jobID已经完成(加上结果)
- Tornado检索(用户)请求并将响应转发给(用户)
这会发生吗？它有任何逻辑吗？
场景2 :(龙卷风加长轮询)
- Tornado调度celery任务并将一些主json数据返回给客户端(jQuery)
- jQuery在收到主json后进行一些长轮询,比方说,每隔x微秒,龙卷风根据某个数据库标志回复.当celery任务完成时,此数据库标志设置为True,然后jQuery"loop"结束.
这有效吗？
还有其他想法/架构吗？