ImportError 无法导入名称 celery

Question

我正在尝试将 Celery 添加到我现有的 Flask 应用程序之上，我在下面分享了我的项目文件结构。我的项目中没有__init__.py 文件。

我在 jobs.py 有任务 run_job ，但是从 app.py 我无法导入我创建的 celery 对象。但我收到以下错误。我相信由于我的项目结构并且没有初始化文件而出现错误。有没有办法在不使用__init__.py

的情况下解决这个问题

ImportError: cannot import name 'celery'

<pre>+ root/  
  - flask-app/  
    * app.py  
    * tasks.py
    * jobs.py
    * jobs_namespace.py</pre>

我的 app.py 看起来像：

from flask import Flask
from tasks import make_celery

APP = Flask(__name__)
...
celery = make_celery(APP) # cannot import in jobs.py 

我的任务.py：

from celery import Celery
def make_celery(app):
...

我的工作.py

from app import celery
@celery.task()
def run_job():
...

我的jobs_namescape.py：

@api.route("/")
def home():
   result = jobs.run_job().apply_async(args=None, countdown=60)

Answer 1

您要么export PYTHONPATH=/path/to/your/project/root:$PYTHONPATH，然后重试，要么修改代码为from .app import celery。我谦虚地相信您为该变量选择了一个糟糕的名称。 celery_app 或不与同名 Celery 模块冲突的类似内容会更有意义。