celery使用

  • Celery任务状态

PENDING->STARTED->SUCCESS/FAILD

  1. "STARTED"状态是一个特殊状态,当task_trace_started配置被设置为True或者@task(track_started=True)选项被设置时才会有出现STARTED状态

  2. PENDING”状态实际上并不是一个记录状态,它是任何未知id的任务的默认状态,下面的例子中会出现这一状态:

from proj.celery import app
res=app.AsyncResult('this-id-does-not-exist')
res.state'PENDING'
  • cekery key erro 'async'错误解决方法
pip install -U "celery[redis]"
  • supervisor配置celery
[program:celery]
command=/usr/local/bin/celery worker -A tasks --loglevel=info
directory={tasks.py文件所在目录}
user=root
numprocs=1
;redirect_stderr=true        ; redirect proc stderr to stdout (default false)
stdout_logfile=/var/log/supervisord/celery.log
stderr_logfile=/var/log/supervisord/celery.log
autostart=true
autorestart=true
startsecs=10
stopwaitsecs = 600
killasgroup=true
priority=998
stdout_logfile_maxbytes = 20MB
stdoiut_logfile_backups = 20
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 在项目中使用celery 项目结构: proj/celery.py proj/tasks.py 启动工作进程: -...
    xncode阅读 5,752评论 0 5
  • 参考资料:celery官方教程Demo给网站做了一个留言板,留言后直接发送邮件给管理员,顺便加上celery测试了...
    今夕何夕_walker阅读 2,176评论 1 2
  • 问题:worker中使用到while死循环来遍历任务,达到调度任务的目的,所以,在使用supervisor管理ce...
    最后一次被盗阅读 3,567评论 1 0
  • 应用 需要一个celery实例,即应用。这个应用是使用所有东西的进入点,例如创建任务、管理工作进程,必须可被其他模...
    xncode阅读 1,416评论 0 1
  • Celery 进阶 前面已经对Celery的简单使用和配置做了介绍,本章将会展示Celery的更多细节 在自己的应...
    0ooops阅读 5,927评论 0 7