根据用户输入使用 django-celery 安排任务

Question

我正在使用 django 构建一个报告门户。在此门户中，我需要让用户能够安排报告定期运行。我一直在研究 django-celery 并了解您可以使用 periodical_task 装饰器来安排重复发生的任务，但在所有示例中我都看到 cron 计划信息被硬编码到装饰器中。

@periodic_task(run_every=crontab(hours=7, minute=30, day_of_week="mon"))

有没有一种方法使用 django-celery 根据用户的输入动态地安排重复发生的任务？

例如，用户使用表单来选择他们想要运行的报表，提供报表所需的所有参数以及他们想要运行报表的时间表。处理完表单后，是否可以调用方法或函数来将 run_report 任务添加到计划中？如果是这样，有没有办法检索数据库中存储的所有当前时间表以便显示它们？

Answer 1

在管理界面中查看 djcelery：
http://localhost:8000/admin/djcelery/

尝试是否可以构建所需的任务设置那里（使用 crontabs/间隔/定期任务）
如果是的话，您很有可能可以快速建立起来。

Answer 2

http://celery.readthedocs.org/en/latest/userguide/calling.html

例如：-

from celery import task

@task.task(ignore_result=True)
def T(message=None ):
    print message

。

T.apply_async(countdown=10, message="hi")

从现在起 10 秒后执行。

T.apply_async(eta=now + timedelta(seconds=10),message="hi")

从现在起 10 秒后执行，使用 eta 指定

T.apply_async(countdown=60, expires=120,message="hi")

从现在起一分钟内执行，但在 2 分钟后过期。

Answer 3

覆盖模型中的保存方法。每当用户输入喜欢启动流程/任务时，他都会修改触发任务启动的模型。

your_app/models.py：

class My_Model(models.Model):
customer = models.ForeignKey(User, related_name='original_customer_id')
start_task = models.BooleanField(default=False, blank=True)

def save(self, *args, **kwargs):
    super(NewProject, self).save(*args, **kwargs)
    from .tasks import my_task
    my_task.apply_async(args=[self.pk, self.status, self.file_type],)

your_app/tasks.py

@celery.task()
def my_task(foo, bar):
    #do something