问我可以在运行时定义任务的celery队列属性吗？
EN

Stack Overflow用户

提问于 2012-03-23 04:15:37

回答 1查看 3.4K关注 0票数 5

使用案例：

class MyTask(Task):
    queue = 'default_queue'

    def run(self):
        # do work

正常情况下，我会运行以下命令，它将使用指定的'default_queue‘。

MyTask.delay()

我需要做的是：

if hours_since_last_login > 24:
    MyTask.delay()   # using the queue 'high_priority_queue'
else:
    MyTask.delay()   # using the 'default_queue'

我知道我可以子类化MyTask来覆盖queue属性，但是有没有办法在运行时定义它呢？

这是下面的正确方法吗？

task = MyTask()
task.queue = 'high_priority_queue'
task.delay()

回答已采纳

发布于 2012-03-23 05:11:06

在IRC上的askol中：

MyTask.apply_async(args=[], kwargs={}, queue='high_priority_queue')

票数 8

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/9829806

复制

相似问题

问我可以在运行时定义任务的celery队列属性吗？EN