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

Question

我写了一个文件 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'

可能的原因是什么

Answer 1

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

CELERY_IMPORTS=("mytasks")

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