ImportError：无法导入名称芹菜

Question

我正在尝试使用 Celery + Redis + Flask 运行一些后台作业。

我的应用结构是：

myapp/
  celery_worker.py
  manage.py
  myapp/
    __init__.py
    app.py
    bot/
      __init__.py
      tasks.py
    accounts/
      views.py

我将 celery 初始化为 app.py 为：

celery = Celery('tasks', include=['bot.tasks'])

def create_app(config=None, app_name=None, blueprints=None):
    # more Celery and other config here like celery.conf.update()

然后通过celery_worker.py启动worker

from myapp import create_app, celery

app = create_app()
app.app_context().push()

tasks.py 包含

from myapp import celery

@celery.task(name='my_task_bot')
def my_task_bot():
     # pass

现在，当我尝试通过以下导入将任务从 tasks.py 访问到 accounts/views.py 时：

from ..bot.tasks import my_task_bot

我收到ImportError: cannot import name celery 错误。

无论我在哪里尝试导入任务，我都会收到此错误。这个celery 实例似乎是在 app.py 中初始化的实例，但没有被导入。

PS：我遵循https://github.com/ezequielo/flask_celery_exp repo 的模式，它工作正常。但不是我的应用。

编辑：

这是回溯：

Traceback (most recent call last):
  File "manage.py", line 8, in <module>
    from myapp import create_app
  File "/home/mars/myapp/myapp/__init__.py", line 3, in <module>
    from app import create_app, celery
  File "/home/mars/myapp/myapp/app.py", line 18, in <module>
    from .accounts import (accounts, AccountsAdmin) 
  File "/home/mars/myapp/myapp/accounts/__init__.py", line 7, in <module>
    from .views import accounts
  File "/home/mars/myapp/myapp/accounts/views.py", line 6, in <module>
    from ..bot.tasks import my_task_bot
  File "/home/mars/myapp/myapp/bot/tasks.py", line 14, in <module>
    from myapp import celery
ImportError: cannot import name celery

Fatal error: local() encountered an error (return code 1) while executing 'python manage.py initdb'

我在尝试启动 manage.py 或 celery_worker 时遇到上述错误。

请提出建议。

Answer 1

您的导入逻辑不正确，导致循环依赖。不要在 app.py 中连同引用模块 (accounts) 一起初始化 celery，该模块反过来导入 celery 实例。

您有多种选择：

1. 从 app.py 模块中的应用 accounts 移除依赖

2. 将 celery 初始化对象放入不引用任何其他模块，而是由/*/tasks.py 子模块引用的共享模块中。

3. 不要在任务中导入 celery，而是使用 shared_task 装饰器。更多信息请参考doc

重要提示：不要忘记将 celery 应用正确链接到您的 @shared_tasks。 Celery 应用程序应该在任何任务之前加载。因此，在 celery.py 中定义 celery 初始化，然后在 myapp/__init__.py 加载它。

from __future__ import absolute_import

from .celery import app as celery_app  # noqa

或者，您可以对此link 进行详细说明。它展示了一种将烧瓶应用程序与 celery 应用程序一起组织的好方法。

Answer 2

在初始化 Celery 的文件中，将其添加为第一行。

from __future__ import absolute_import

解释

from __future__ import absolute_import 表示如果你导入 celery，Python 会寻找一个顶级的 celery 模块，而不是 current_package.celery。这应该可以解决您遇到的错误。但要确保芹菜是 安装。值得一提的是必须安装 celery。这适用于 python 2.6以后的版本

Answer 3

tasks.py

from myapp.app import celery

https://docs.python.org/3.5/tutorial/modules.html#packages

Answer 4

我解决了这个错误，在 pycharm 中取消选中“将内容根添加到 python 路径”和“将源根添加到 python 路径”