python - 为 Celery 中的任务类指定队列

Question

当我创建函数任务时，我可以执行以下操作来指定队列:

@app.task(name='my_task', queue='my_queue')
def some_task():
    return "hey"

然后，我可以这样调用这个任务:some_task.delay()，它会将任务发送到 my_queue。

但是，如果我有一个继承自 celery.Task 类的类，则每次调用此任务时都必须指定队列:

class MyTask(Task):
    def run(self):
        return "Hey"

MyTask.apply_async(queue="my_queue")

有没有办法在类定义中指定它？像这样:

class MyTask(Task):
    queue = 'my_queue'

    def run(self):
         return "Hey"

我在文档中找不到执行此操作的方法。可能吗？

Answer 1

事实证明，这正是您要做的:

class MyTask(Task):
    queue = 'my_queue'

    def run(self):
        return "Hey"