我的任务是在Wowza媒体服务器中添加一个新流,该流必须在用户指定的时间进行。目前,我正在为此目的将crontab与http提供程序一起使用。我想要一个celery.beat
实现。谁能帮忙?
如果这是在特定时间执行的一次性任务,则无需使用定期任务(celerybeat)。
相反,您可以使用 eta/countdown 参数来task.apply_async
:
task.apply_async(eta=datetime(2012, 07, 1, 14, 30))
task.apply_async(countdown=30) # in 30 seconds
在这里阅读更多内容:
http://celery.github.com/celery/userguide/calling.html