python - Celery PeriodicTask 参数

Question

如何以编程方式更改传递给 Celery 的参数？我必须在以下代码中进行哪些更改：

from celery.task import PeriodicTask

class MyTask(PeriodicTask):
    run_every = timedelta(seconds=1)
    value = ''
    def run(self, **kwargs):
        print 'Passed value %s' % value

我希望能够在应用程序生命周期内更改 value 属性。该值可能是一个字典，但我怀疑它是否会改变任何东西。

Answer 1

为什么要改变论点？每次谁来传递论点？调度程序在指定的调度时间调用 run 方法。

您可以简单地从数据库或其他任何内容中读取“值”。

def run(self, **kwargs):
    value = get_value_from_database()
    print 'Passed value %s' % value

否则 - 您可能需要按照此处所述创建自定义调度程序类：http: //celery.github.com/celery/userguide/periodic-tasks.html#using-custom-scheduler-classes，并覆盖其一些方法。 .