标签：celery python

是否可以在不轮询的情况下监视芹菜任务的状态？

例如,如果我有一个任务会使用update_state定期更新其状态：

@task(bind=True)
def my_task(self):
    for x in range(100):
        time.sleep(1)
        self.update_state(state='PROGRESS', meta={'x': x})

是否可以在不轮询的情况下从另一个进程监视该状态？

解决方法:

我还没有自己做,所以这不是一个完整的答案,但是我有兴趣解决相同的问题.我有三个值得考虑的想法：

>使用on_failure,on_retry和on_success之类的内置handler states可以在您的用例中使用吗？
>另一个是将Task子类化(此处是简单的示例：Callback for celery apply_async),并添加on_ *处理程序,这些处理程序将传递自定义状态的回调函数.也许甚至没有必要
>最好是write a custom event receiver.我认为这就是他们的“Real-time Celery web-monitor”示例的工作方式.与此相关的SO帖子是：Implementing Twisted style local multiple deferred callbacks in Celery.

标签：celery,python
来源： https://codeday.me/bug/20191120/2041386.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。