登录  /  注册
使用celery和redis遇到问题
PHPz
PHPz 2017-04-22 08:59:28
[Redis讨论组]
 '__main__.add'.
The message has been ignored and discarded.

Did you remember to import the module containing this task?
Or maybe you are using relative imports?
Please see http://bit.ly/gLye1c for more information.

The full contents of the message body was:
{'callbacks': None, 'eta': None, 'kwargs': {}, 'id': 'ad766baf-c8d5-46ec-934c-e73d07b57930', 'args': (45, 789), 'errbacks': None, 'utc': True, 'taskset': None, 'task': '__main__.add', 'retries': 0, 'timelimit': (None, None), 'chord': None, 'expires': None} (260b)
Traceback (most recent call last):
  File "/home/hawk/g/f3/lib/python3.3/site-packages/celery/worker/consumer.py", line 455, in on_task_received
    strategies[name](message, body,
KeyError: '__main__.add'

这里是运行文件:

from flask import Flask
from celerycfg import make_celery

app = Flask(__name__)
###############################################################
app.config.update(
    CELERY_BROKER_URL='redis://localhost:6379',
    CELERY_RESULT_BACKEND='redis://localhost:6379'
)
celery = make_celery(app)
@celery.task()
def add_together(a, b):
    return a + b

@celery.task()
def add(x, y):
    return (x + y) * 100    
###############################################################
@app.route('/')
def hello_world():
    return 'Hello World!' + str(add_together.delay(45, 789))

@app.route('/sum')
def sum():
    return 'sum-----' + str(add.delay(45, 789).get())

@app.route('/hello')
def hello():
    res = add.delay(456, 789)
    return "Result: %d " % res.wait()
###############################################################
if __name__ == '__main__':
    app.run()

这里是使用得到的结果:
http://127.0.0.1:5000/sum

======================================================

Traceback (most recent call last):
      File "/home/hawk/g/f3/lib/python3.3/site-packages/celery/worker/consumer.py", line 455, in on_task_received
        strategies[name](message, body,
    KeyError: 'app.fcelery.fcelery.add'
    [2015-01-06 12:41:07,485: ERROR/MainProcess] Received unregistered task of type 'app.fcelery.fcelery.add'.
    The message has been ignored and discarded.

Did you remember to import the module containing this task?
Or maybe you are using relative imports?
Please see http://bit.ly/gLye1c for more information.

The full contents of the message body was:
{'kwargs': {}, 'id': '283c4ec5-043a-4cc6-b857-7eb1160feb25', 'utc': True, 'taskset': None, 'callbacks': None, 'chord': None, 'timelimit': (None, None), 'expires': None, 'retries': 0, 'task': 'app.fcelery.fcelery.add', 'eta': None, 'args': (5678, 890), 'errbacks': None} (272b)
Traceback (most recent call last):
  File "/home/hawk/g/f3/lib/python3.3/site-packages/celery/worker/consumer.py", line 455, in on_task_received
    strategies[name](message, body,
KeyError: 'app.fcelery.fcelery.add'
    sum-----ad766baf-c8d5-46ec-934c-e73d07b57930

book/app/models
        /blog()
        /media/controllers.py
              /models.py
              /....
        /fcelery/fcelery.py
                /tasks.py
                /__init__.py
        /templates  
    /run.py

这是一个flask app的目录, 里面有多个blueprint, 在蓝图的controllers.py里面使用celery, 也是同样的报错。。。

    [2015-01-06 12:53:30,961: ERROR/MainProcess] Received unregistered task of type 'app.fcelery.tasks.add'.
The message has been ignored and discarded.

Did you remember to import the module containing this task?
Or maybe you are using relative imports?

Please see http://bit.ly/gLye1c for more information.

The full contents of the message body was:
{'expires': None, 'utc': True, 'id': '7138afa4-19ee-477d-9fc5-ab081ea94519', 'kwargs': {}, 'callbacks': None, 'taskset': None, 'eta': None, 'errbacks': None, 'task': 'app.fcelery.tasks.add', 'retries': 0, 'timelimit': (None, None), 'chord': None, 'args': (5678, 890)} (270b)
Traceback (most recent call last):
  File "/home/hawk/g/f3/lib/python3.3/site-packages/celery/worker/consumer.py", line 455, in on_task_received
    strategies[name](message, body,
KeyError: 'app.fcelery.tasks.add'

哪里出错了?

补充一下:
我看到官方的大体意思是celery使用flask-app的配置等等
而我是使用独立的celery,也就是说:

../fcelery/这里是独立的celery配置 , 和 flask app 无关
          /。。。

../app/blog/controllers.py
      在这里  from fcelery.tasks import add
        res = add.delay(5678, 890)
        return "posts list---- %d "  % res.get()                 

 没有使用官方的那种flask-extension式的配置, 应该没有问题吧?
PHPz
PHPz

学习是最好的投资!

热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2024 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号