python - 如何使用动态输入务实地安排 Celery 任务？

Question

我有这样的情况，我需要务实地安排一个任务，任务定义每次需要执行时都需要一定的输入参数。考虑以下任务函数:

@task
def add_numbers(a, b):
   sum = a + b
   return sum

现在，如果我需要在两个不同的时间实例使用不同的输入参数运行上述任务，例如 T1->add_numbers(4,5) 和 T2->add_numbers(2,2)，我该怎么做。感谢您的帮助。

环境:Django 1.4，Celery 3.0

Answer 1

我也遇到了这个问题，我想还有另一种方法可以帮助你。@narced133 的答案只有在参数的变化是有限的情况下才有效，那么如果我们有数千种参数怎么办？

解决方法:重构您的 celery 任务 以接受一个函数作为参数，该函数将生成或获取作为您的 celery 任务 的真实参数的参数:add_numbers.