在Celery + Python中，如何从task_revoked函数访问任务参数？

Question

我试图去清理一些东西后，我杀了一个正在运行的任务在芹菜。目前，我正在打2个问题：

1）任务吊销函数体里面，我怎么可以访问该任务调用该函数的参数：因此，例如，如果该任务被定义为：

@app.task() 
def foo(bar, baz): 
    pass 

我将如何访问bar和baz里面的task_revoked.connect代码？

2）我想杀掉一个任务，只有当它的状态不是X时，这意味着一方面检查任务，另一方面设置状态。我猜可以完成状态检查，但是我很难在头脑中围绕任务函数体内的上下文。

如果我foo定义是这样的：

@app.task(bound=True) 
def foo(self, bar, baz): 
    pass 

和发言权调用它....瓶像foo(bar, baz)，然后我会得到一个错误的第三个参数的预期，这意味着做装饰不通过self参数自动添加任何上下文。

应用提前

Answer 1

你可以从请求对象的任务参数表是简单地定义为celery.Celery()

感谢。

from celery.signals import task_revoked 

@task_revoked.connect 
def my_task_revoked_handler(sender=None, body=None, *args, **kwargs): 
    print(kwargs['request'].args) 

这将打印给任务的参数。

更新：

你必须使用bind不bound。

@app.task(bind=True) 
def foo(self, bar, baz):