收到错误接收到未注册的'mytasks.add'类型的任务

  • Z时代
  • 2024-01-10
  • 分类：问答

我写了一个文件 mytasks.py

from celery import Celery
celery = Celery("tasks",
                broker='redis://localhost:6379/0',
                backend='redis')
@celery.task
def add(x,y):
        return x+y

并task.py如下

from mytasks import add
add.delay(1,1)

我已经启动了redis服务器，也已经启动了celery服务器。但是当我运行task.py时，出现以下错误：

    Received unregistered task of type 'mytasks.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:
{'retries': 0, 'task': 'mytasks.add', 'eta': None, 'args': (1, 1), 'expires': None, 'callbacks': None, 'errbacks': None, 'kwargs': {}, 'id': 'a4792308-d575-4de4-8b67-26982cae2fa4', 'utc': True} (173b)
Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/celery/worker/consumer.py", line 411, in on_task_received
    strategies[name](message, body, message.ack_log_error)
KeyError: 'mytasks.add'

可能的原因是什么

回答：

嘿，我解决了我添加的一件事

CELERY_IMPORTS=("mytasks")

在我的celeryconfig.py档案中，我获得了成功。

以上是 收到错误接收到未注册的'mytasks.add'类型的任务 的全部内容， 来源链接： utcz.com/qa/426146.html

回到顶部