celery 有失败任务，怎么回事？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

推荐学习书目

› Learn Python the Hard Way

Python Sites

› PyPI - Python Package Index

› http://diveintopython.org/toc/index.html

› Pocoo

值得关注的项目

› PyPy

› Celery

› Jinja2

› Read the Docs

› gevent

› pyenv

› virtualenv

› Stackless Python

› Beautiful Soup

› 结巴中文分词

› Green Unicorn

› Sentry

› Shovel

› Pyflakes

› pytest

Python 编程

› pep8 Checker

Styles

› PEP 8

› Google Python Style Guide

› Code Style from The Hitchhiker's Guide

这是一个创建于 2717 天前的主题，其中的信息可能已经有所发展或是发生改变。

flask 项目

celery = Celery(name, broker=CELERY_BROKER, include=CELERY_IMPORTS)

只用了个 broker 没有用 backend ，broker 是用的 redis

上面是用 Flower 的观察结果，大概是每创建 3 次任务，只有一次任务成功。

求解怎么回事？

Celery

broker

任务

backend

9 条回复 • 2019-10-24 14:36:49 +08:00

scriptB0y

2017-07-18 18:36:53 +08:00

贴日志出来

akmonde

2017-07-19 07:56:07 +08:00

兄弟你这不贴错误日志和报错，别人怎么帮你。

lauix

2017-07-19 10:01:29 +08:00

@scriptB0y
@akmonde
日记无任何错误，找到原因了，supervisor stop 关闭不了 celery 进程，然后用手动启动了个，所以一会成功，一会失败。

0ZXYDDu796nVCFxq

2017-07-19 10:20:19 +08:00

前面两个任务，有错误没有处理好啊
不要用 one(), 如果数据库有做约束，那就 first()
或者简单点 one_or_none()

Kcelone

2018-09-27 10:27:43 +08:00

请问你这个后面是怎么解决的？我现在遇到个类似问题，就是任务有时候会注册不成功，redis 中返回结果是 "result": {
"exc_type": "NotRegistered",
"exc_message": "'tasks.excel.excel_to_db'"
},请问知道是哪里出了问题吗？

CyJaySong

2019-04-18 09:22:32 +08:00

@Kcelone 我也遇到这个问题，您解决了没

CyJaySong

2019-04-18 09:24:12 +08:00

@lauix 我也是使用的 supervisor 启动 celery，任务有时候能执行有时候报 NotRegistered。。您是怎么解决的呢

eteryao

2019-10-21 19:54:18 +08:00

@Kcelone 请问解决了么。。。

Kcelone

2019-10-24 14:36:49 +08:00

@eteryao 解决了，检查自己的任务函数，发现点问题，换了种方式，然后就正常了。