如何获取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)