Колба с create app, SQLAlchemy и сельдереем

Я действительно изо всех сил пытаюсь получить правильную настройку для колбы, SQLAlchemy и сельдерея. Я много искал и пробовал разные подходы, но ничего не получалось. Либо я пропустил контекст приложения, либо не могу запустить workers, либо есть какие-то другие проблемы. Структура очень общая, так что я могу построить более крупное приложение.

Я использую: Flask 0.10.1, SQLAlchemy 1.0, Celery 3.1.13, моя текущая настройка следующее:

App/__init__.py

#Empty

App/config.py

import os

basedir = os.path.abspath(os.path.dirname(__file__))



class Config:



    @staticmethod

    def init_app(app):

        pass



class LocalConfig(Config):

    DEBUG = True

    SQLALCHEMY_DATABASE_URI = r"sqlite:///" + os.path.join(basedir, 

                                 "data-dev.sqlite")

    CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672//'





config = {

    "local": LocalConfig}

App/exstensions.py

from flask.ext.sqlalchemy import SQLAlchemy

from celery import Celery



db = SQLAlchemy()

celery = Celery()

App/factory.py

from extensions import db, celery

from flask import Flask

from flask import g

from config import config



def create_before_request(app):

    def before_request():

        g.db = db

    return before_request





def create_app(config_name):

    app = Flask(__name__)

    app.config.from_object(config[config_name])



    db.init_app(app)

    celery.config_from_object(config)



    # Register the blueprints



    # Add the before request handler

    app.before_request(create_before_request(app))

    return app

App/manage.py

from factory import create_app



app = create_app("local")



from flask import render_template

from flask import request



@app.route('/test', methods=['POST'])

def task_simple():

    import tasks

    tasks.do_some_stuff.delay()

    return ""



if __name__ == "__main__":

    app.run()

App/models.py

from extensions import db



class User(db.Model):

    __tablename__ = "user"



    id = db.Column(db.Integer, primary_key=True)

    username = db.Column(db.String(128), unique=True, nullable=False)

App/tasks.py

from extensions import celery

from celery.signals import task_prerun

from flask import g, current_app





@task_prerun.connect

def close_session(*args, **kwargs):

    with current_app.app_context():

       # use g.db

       print g



@celery.task()

def do_some_stuff():

    with current_app.app_context():

       # use g.db

       print g

В папке приложения:

• запуск веб-сервера разработки с помощью: python.exe manage.py
  


• начиная с рабочих: celery.exe worker -A tasks
  

Я получаю ошибку импорта, которая не имеет для меня никакого смысла.
Должен ли я структурировать приложение по-другому? В конце концов, я думаю, что мне нужна довольно простая настройка, например, использование Flask с фабричным шаблоном, возможность использовать расширение Flask-SQLAlchmey и иметь некоторого работника, который должен получить доступ к базе данных.

Трассировка выполняется при запуске celery worker.

Traceback (most recent call last):



  File "[PATH]scriptscelery-script.py", line 9, in <module>

    load_entry_point('celery==3.1.13', 'console_scripts', 'celery')()



  File "[PATH]libsite-packagescelery__main__.py", line 30, in main

    main()



  File "[PATH]libsite-packagescelerybincelery.py", line 81, in main

    cmd.execute_from_commandline(argv)



  File "[PATH]libsite-packagescelerybincelery.py", line 769, in execute_from_commandline

    super(CeleryCommand, self).execute_from_commandline(argv)))



  File "[PATH]libsite-packagescelerybinbase.py", line 305, in execute_from_commandline

    argv = self.setup_app_from_commandline(argv)



  File "[PATH]libsite-packagescelerybinbase.py", line 473, in setup_app_from_commandline

    user_preload = tuple(self.app.user_options['preload'] or ())

AttributeError: 'Flask' object has no attribute 'user_options'

UPDATE я изменяю код в соответствии с предложением в комментарии. Работник начинает теперь вверх но когда тестировать его с get запросом к http://127.0.0.1:5000/test. Я получаю следующую обратную связь:

Traceback (most recent call last):

  File "[PATH]libsite-packagesceleryapptrace.py", line 230, in trace_task

    args=args, kwargs=kwargs)



  File "[PATH]libsite-packagesceleryutilsdispatchsignal.py", line 166, in send

    response = receiver(signal=self, sender=sender, **named)



  File "[PATH]appstackoverflowtasks.py", line 7, in close_session

    with current_app.app_context():



  File "[PATH]libsite-packageswerkzeuglocal.py", line 338, in __getattr__

    return getattr(self._get_current_object(), name)



  File "[PATH]libsite-packageswerkzeuglocal.py", line 297, in _get_current_object

    return self.__local()



  File "[PATH]libsite-packagesflaskglobals.py", line 34, in _find_app

    raise RuntimeError('working outside of application context')

RuntimeError: working outside of application context exc, exc_info.traceback)))

Обновление основываясь на комментариях Мартина, я изменил код. Текущая рабочая версия находится под: https://gist.github.com/anonymous/fa47834db2f4f3b8b257 [52]}.
Любые дальнейшие улучшения или предложения приветствуются.