python - celery ，在指定时间运行一次任务

Question

如何在给定时间运行 celery 任务，但只运行一次？

我阅读了文档，但找不到这方面的任何示例。

Answer 1

调用任务时可以使用参数eta。示例:

from datetime import datetime, timedelta

@app.task()
def hello(self):
    return 'hello world'


tomorrow = datetime.utcnow() + timedelta(days=1)
hello.apply_async(eta=tomorrow)

文档:http://docs.celeryproject.org/en/latest/userguide/calling.html#eta-and-countdown

或者，当您想多次调用hello并且以确保一次只执行一次时，您可以使用锁定 - 文档中有更多相关信息:http://docs.celeryproject.org/en/latest/tutorials/task-cookbook.html#ensuring-a-task-is-only-executed-one-at-a-time