欢迎光临
我们一直在努力

python celery 用法总结

1 启动 celery -A cele worker –loglevel=info –beat

上面的cele 实际为需要执行的任务的文件 cele.py ,当前的任务文件是在当前目录下,

# cele.py
import celery
from celery.schedules import crontab
from datetime import timedelta
from predict import make_predict

app = celery.Celery(‘cele’, broker=’redis://localhost:6379′)

@app.task
def predict_daily_visit():
make_predict()

app.conf.beat_schedule = {
‘test_api’: {
‘task’: ‘cele.predict_daily_visit’,
‘schedule’: crontab(hour=23, minute=45)
}
}

然后cele.py里面内容如上, 其中make_predict()为要执行任务的函数

然后schedule为执行任务的时间设置,可以有两种方式,一种是每隔多少时间执行,或者定时执行

每隔多少时间执行: timedelta(seconds=1200) 如此,则可间隔20分钟执行一次,

定时执行 crontab(hour=23, minute=45) 定于每天的23点45分执行,当然 要先安装并启动redis,这里redis的端口为默认的6379

赞(0) 打赏
未经允许不得转载:乌西塔 » python celery 用法总结

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

觉得文章有用就打赏一下文章作者

微信扫一扫打赏