无法导入在\uu init_uu.py中定义的变量

Question

我正在尝试按照http://flask.pocoo.org/docs/0.12/patterns/celery/中的说明操作，这样我就可以在芹菜任务中执行烧瓶/socketIO操作。我的目录结构有点不同，但我没有任何运气导入。在

我的目录结构如下：

├── app
│   ├── __init__.py
│   ├── __pycache__
│   ├── auth.py
│   ├── ctasks.py
│   ├── helper.py
│   ├── saml.py
│   ├── socks.py
│   ├── templates
│   ├── threads.py
│   └── views.py
├── app.py
├── config.py
├── requirements.txt
└── saml
    ├── dev
    └── prod

我从app.py调用应用程序

^{pr2}$

__init__.py

from flask import Flask, request
from flask_socketio import SocketIO
from .ctasks import subtaskcaller, make_celery
from .helper import wait_to_finish

async_mode = None

app = Flask(__name__)
app.config.from_object('config')
socketio = SocketIO(app, async_mode=async_mode)
cel = make_celery(app)

from .auth import SamlManager
saml_manager = SamlManager()
saml_manager.init_app(app) 
from app import views, socks, saml, helper, ctasks

ctasks.py

from celery import Celery
from config import *
from .helper import wait_to_finish, emitter
import time
from app import cel


def make_celery(app):
    c = Celery(app.import_name, backend=CELERY_RESULT_BACKEND, broker=CELERY_BROKER_URL)
    c.conf.update(app.config)
    taskbase = c.Task

    class ContextTask(taskbase):
        abstract = True

        def __call__(self, *args, **kwargs):
            with app.app_context():
                return taskbase.__call__(self, *args, **kwargs)

    c.Task = ContextTask
    return c

@cel.task(name='tasks.tester', serializer='pickle')
def tester():
    emitter('emit from subsubtask')
    for i in range(1, 50):
        time.sleep(1)
        print('test {0}'.format(i))
    x = True
    return x

@cel.task(name='task.subtaskcaller', serializer='pickle')
def subtaskcaller():
    emitter('emit from subtask')
    finished = tester.delay()
    wait_to_finish(finished)
    return finished

尝试从ctasks.py中的应用程序导入cel时出错：

ImportError: cannot import name 'cel'

Answer 1

在你的__init__.py中，你只有cel。您的__init__文件中没有名为celery的对象，因此无法将其导入其他文件。你可以试试from app import cel

编辑：

在__init__你from .ctasks import subtaskcaller, make_celery

但在ctasks中，您从app导入{}（此时还不存在，只有Flask、request和SocketIO存在于该时间点）。在

因此，您需要将@cel修饰的函数放入另一个脚本中，您可以在__init__的底部导入该脚本