Django - Celery：@transaction 和 @task 不叠加

Question

我想运行带有手动事务管理的 Django - Celery 任务，但注释似乎不堆叠。

例如

def ping():
    print 'ping'
    pong.delay('arg')

@task(ignore_result=True)
@transaction.commit_manually()
def pong(arg):
    print 'pong: %s' % arg
    transaction.rollback()

，结果是，

TypeError: pong() got an unexpected keyword argument 'task_name'

而反向注释顺序结果是，

---> 22     pong.delay('arg')

AttributeError: 'function' object has no attribute 'delay'

这是有道理的，但我很难找到一个好的解决方法。 Django 文档没有提到注释的替代方案，并且当我不需要时，我不想为每个 celery 任务创建一个类。

有什么想法吗？

Answer 1

以前 Celery 有一些魔力，其中一组默认关键字参数
如果任务接受了它们，则将其传递给该任务。

从 2.2 版开始，您可以禁用此行为，但最简单的方法是
从 celery.task 而不是 celery.decorators 导入 task 装饰器：

from celery.task import task

@task
@transaction.commit_manually
def t():
    pass

decorators 模块已被弃用，并将被在3.0中完全删除，
和“魔法关键字参数”相同

注意：
对于自定义任务类，您应该将 accept_magic_kwargs 属性设置为 False：

class MyTask(Task):
    accept_magic_kwargs = False

注意 2：确保您的自定义装饰器使用 functools.wraps 保留函数的名称，否则任务将结束起错名字了。

Answer 2

任务装饰器从您的函数生成一个 class x(Task) ，并将 run 方法作为您的目标。建议您定义类并装饰方法。

未经测试例如：

class pong(Task):
  ignore_result = True

  @transaction.commit_manually()
  def run(self,arg,**kwargs):
    print 'pong: %s' % arg
    transaction.rollback()