celery 停止_celery 停止执行中 task

原因

因为最近项目需求中需要提供对异步执行任务终止的功能，所以在寻找停止celery task任务的方法。这种需求以前没有碰到过，所以，只能求助于百度和google，但是找遍了资料，都没找到相关的能停止celery task任务的方法(网上找到的一个方法实测不能用，可能是celery版本的原因，我的项目目前使用的是celery 4.0.2)

解决过程

由于网上找不到解决办法，于是只能自己想办法了。

想到celery 管理工具flower里面好像有停止celery task的功能，于是去找flower的源码，找到接口的源码如下:

logger.info("Revoking task '%s'", taskid)

terminate = self.get_argument('terminate', default=False, type=bool)

self.capp.control.revoke(taskid, terminate=terminate)

self.write(dict(message="Revoked '%s'" % taskid))

核心代码是self.capp.control.revoke 想到去celery里面找寻revoke函数，发现有两处比较可疑，第一个是celery.worker.control.revoke，第二个是celery.app.control.Control.revoke，直觉来看，应该是第二个方法，但是第二个方法是在一个类里面的，要调用这个方法首先需要获取到celery app的实例，后来去celery 配置里面找，发现在__init__.py文件里面有__all__ = [‘celery_app‘]这么一句，于是找到突破点了，引用这个包就能获取到celery_app了。

from test.ceyery_proj import celery_app

celery_app.control.revoke(task_id, terminate=True)

通过这个方法就能终止正在执行的task，至于task_id在执行任务的时候返回了，我将这个id存储在数据库中，这样就可以被拿来控制task的执行了。

写这篇文档的目的主要是帮助小伙伴们不要再踩这个坑了，也为celery提供一点文档补充吧。

celery 停止_celery 停止执行中 task相关推荐

celery 停止任务_celery 停止执行中 task
原因因为最近项目需求中需要提供对异步执行任务终止的功能,所以在寻找停止celery task任务的方法.这种需求以前没有碰到过,所以,只能求助于百度和google,但是找遍了资料,都没找到相关的能停 ...
celery 停止执行中 task
目录原因解决过程原因因为最近项目需求中需要提供对异步执行任务终止的功能,所以在寻找停止celery task任务的方法.这种需求以前没有碰到过,所以,只能求助于百度和google,但是找遍了资 ...
Celery在Django 项目中如何使用
创建目录celery_pro,并在celery_pro下创建下面两个文件 celery.py # celery.py # -*- coding:utf8 -*- from __future__ imp ...
celery 停止_如何解决django-celery启动后迅速关闭
日志中也没有打印什么明显的错误,只是显示连接了rabbitmq后就关闭了 [2019-09-11 06:08:45,729: INFO/Beat] beat: Starting... [2019-09 ...
魔坊APP项目-25-种植园，植物的状态改动、当果树种植以后在celery的异步任务中调整浇水的状态、客户端通过倒计时判断时间,显示浇水道具
种植园植物的状态改动一.当果树种植以后在celery的异步任务中调整浇水的状态在进行果树种植的时候, 在服务端设置当前果树到等待浇水的redis变量中.通过celery不断进行周期任务的处理, ...
Spark中Task，Partition，RDD、节点数、Executor数、core数目（线程池）、mem数
Spark中Task,Partition,RDD.节点数.Executor数.core数目的关系和Application,Driver,Job,Task,Stage理解 from:https://bl ...
c#中Task线程的用法
1.Task的优势 ThreadPool相比Thread来说具备了很多优势,但是ThreadPool却又存在一些使用上的不方便.比如: ◆ ThreadPool不支持线程的取消.完成.失败通知等交互性 ...
为了热爱Jeez，请停止在软件中使用正则表达式
如果使用正则表达式无法做到,那么我们将无法做到! 您知道什么是代码混淆器吗? 它是一个小程序或一部分编译器工具链,可以将您的程序代码带入一个看似随机的字母和符号中,从而使其他人无法阅读(不使用互惠工具 ...
verilog中task、function和moudle的区别
verilog中task.function和moudle的区别 task可以启动其他任务或者函数:而function不能启动任务 task可以定义自己的仿真时间,而function不可以: funct ...

celery 停止_celery 停止执行中 task

celery 停止_celery 停止执行中 task相关推荐

最新文章

热门文章