我的代码是这样的
from celery import Celery
app = Celery('celery_tutorial', broker='amqp://guest@localhost//',backend="redis://127.0.0.1:6379/1")
app.task
def add(x, y):
return x + y
结果在启动celery时出现以下错误：
The full contents of the message body was:
'[[10, 100], {}, {"callbacks": null, "errbacks": null, "chain": null, "chord": null}]' (84b)
Traceback (most recent call last):
File "d:\program\spider_tutorial\venv\lib\site-packages\celery\worker\consumer\consumer.py", line 562, in on_task_received
strategy = strategies[type_]
KeyError: 'celery_tutorial.geting_start.add'
[2020-09-20 14:45:17,449: ERROR/MainProcess] Received unregistered task of type 'celery_tutorial.geting_start.add'.
The message has been ignored and discarded.
原因是对应的worker没有注册，查看代码发现装饰器缺少@，修改过后可以正常运行了
