用芹菜运行一个简单的经期任务

Question

我似乎不知道如何让它工作。我想每十秒运行一个函数

from __future__ import absolute_import, unicode_literals, print_function
from celery import Celery
import app as x # the library which hold the func i want to task
app = Celery(
    'myapp',
    broker='amqp://guest@localhost//',
)
app.conf.timezone = 'UTC'
@app.task
def shed_task():
    x.run()

@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
    # Calls say('hello') every 10 seconds.
    sender.add_periodic_task(10.0, shed_task.s(), name='add every 10')
if __name__ == '__main__':
    app.start()

然后，当我运行脚本时，它只是向我显示一堆可以与芹菜一起使用的命令。我怎样才能让它运行？我必须在命令行或其他东西中运行它吗？

此外，当我运行它时，我是否能够看到完整任务的列表以及任何错误？

Answer 1

你可以简单地使用 python 线程模块来做到这一点，如下所示

import time, threading
def foo():
    print(time.ctime())
    threading.Timer(10, foo).start()
foo()