如何获取celery任务的ID号并在必要的时候进行关闭

如何获取celery任务的ID号并在必要的时候进行关闭
Page content

我们都知道celery常用于异步任务，而当我在工作中尝试在方法内获取其任务ID的时候，遇到了难题，在这里简单记录下。

🍺本篇文章大约需要20秒来阅读。届时你将学到：

  • 在celery任务方法内获取ID
  • 根据ID终止任务

本次代码应用于**celery 4.3.0**

获取celeryID


@celery_app.task(bind=True)
def tasks(self):
    celery_id = self.request.id.__str__()

根据ID终止任务

from celery.tasks.control import revoke

revoke(celery_id,terminate=True)