Celery关闭执行中的任务策略

一时失言乱红尘 2021-09-21 04:04 1202阅读 0赞

问题描述：设计的系统中需要执行一个长时间的运行的任务，这个任务可以比作是“开启机器后，机器的运行”。现在需要对机器的停止可控，于是需要研究Celery中关闭执行中的任务方法。

首先，参考文章《[celery 停止执行中 task][celery _ task]》，这篇文章中提出“celery 管理工具flower里面好像有停止celery task的功能”，于是开启Celery的flower发现，确实可通过“flower”进行控制关闭。

# 创建任务
    @app.task   
    def celery_task1():
        while True:
            time.sleep(3)
            print "this is celery task1"

这里设置一个任务，任务中循环执行语句打印，以模拟无限长的任务。（默认读者具备Celery使用的基础知识，一些基本使用方法可以参考一下我的另一篇博文：《[Celery分布式实践][Celery]》）

开启Celery服务：

> celery -A XXXX worker -l info -Q XXX

然后，开启Celery的flower控制：

> celery flower --broker=**Celery中使用的broker**

## 1、通过flower结束任务 ##

根据输出的信息，打开对应的网址，确保flower服务已开启：

![20200308224703440.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70][]

这里，我使用一个单独的py文件启动任务：

from celeryProject1 import tasks1
    
    if __name__ == "__main__":
        tasks1.celery_task1.delay()

运行，查看flower控制界面：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 2][]

按照上图箭头示意，依次点击，即可结束任务。 Celery服务监控窗口显示：

![20200308225416979.png][]

## 2、通过程序控制结束任务 ##

修改启动任务的程序：

from celeryProject1 import tasks1
    from celery.app.control import Control
    from celeryProject1.celery import app
    import time
    
    if __name__ == "__main__":
        t = tasks1.celery_task1.delay()
        print "*******task id******", str(t.id)
    
        time.sleep(20)
        # # 停止任务
        celery_control = Control(app=app) 
        celery_control.revoke(str(t.id), terminate=True)

其中，from celeryProject1.celery import app，对应程序配置文件的app设置（具体根据自己的实际情况修改）

![20200308230213175.png][]

“t.id”是获取任务的id，然后通过revoke方法停止任务的执行。

运行上述程序，观察Celery服务的输出：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 3][]

任务“celery\_task1”每3秒执行一次打印输出“"this is celery task1"”，发布任务后，主程序等待20秒后，结束任务。

另外，可以观察到主程序输出的任务id于“flower”中任务的UUID一致：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 4][]

建议阅读：

[问题：如何使用celery随时开启任务，随时关闭正在运行的任务][celery]

[celery 停止执行中 task][celery _ task]

[Celery3.1文档-revoke][Celery3.1_-revoke]

[celery _ task]: https://www.cnblogs.com/huxianglin/p/10517665.html
[Celery]: https://blog.csdn.net/qq_27378621/article/details/103413488
[20200308224703440.png]: /images/20210920/b17f64d52c10411ea91948e805d15642.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70]: /images/20210920/56a228d9097c4280a865d079e5d14b9a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 1]: /images/20210920/ba28e45ce9a5416d8c454b8af7fcde48.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 2]: /images/20210920/c5036c6631604d40b38112ca780a42da.png
[20200308225416979.png]: /images/20210920/23f0acf712fc4ef998022824e023856a.png
[20200308230213175.png]: /images/20210920/c1d5398fd9284b478cadc2ab8eb27baf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 3]: /images/20210920/bd504c858a0542338aeaa27305d6f6d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI3Mzc4NjIx_size_16_color_FFFFFF_t_70 4]: /images/20210920/b8b80222e9324c18a54450908c3fb6fe.png
[celery]: https://blog.csdn.net/caomei_huacha/article/details/97623920
[Celery3.1_-revoke]: http://docs.jinkan.org/docs/celery/reference/celery.app.control.html?highlight=revoke#celery.app.control.Control.revoke