Запрос модели в задании Flask-APScheduler вызывает контекст приложения RuntimeError

Я хочу запустить задание с Flask-APScheduler, которое запрашивает модель Flask-SQLAlchemy. Когда работа выполняется, я получаю RuntimeError: application not registered on db instance and no application bound to current context. Как запустить задание, запрашивающее базу данных.

from flask_apscheduler import APScheduler

scheduler = APScheduler()
scheduler.init_app(app)
scheduler.start()

from models import User

def my_job():
    user = User.query.first()
    print(user)

Ошибка возникает во время запроса, прежде чем его можно будет распечатать. База данных работает в остальной части приложения для других запросов.

Я попытался добавить with app.app_context(): при настройке расширения, но это не сработало.

with app.app_context()
    scheduler = APScheduler()
    scheduler.init_app(app)
    scheduler.start()

Полная трассировка:

ERROR:apscheduler.executors.default:Job "run_in (trigger: interval[0:00:10], next run at: 2016-10-18 23:00:53 CEST)" raised an exception
Traceback (most recent call last):
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/apscheduler/executors/base.py", line 125, in run_job
    retval = job.func(*job.args, **job.kwargs)
  File "/Users/user/Documents/myfolder/myfolder/myfile.py", line 19, in myjob
    user = User.query.all()
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/flask_sqlalchemy/__init__.py", line 454, in __get__
    return type.query_class(mapper, session=self.sa.session())
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/sqlalchemy/orm/scoping.py", line 71, in __call__
    return self.registry()
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/sqlalchemy/util/_collections.py", line 878, in __call__
    return self.registry.setdefault(key, self.createfunc())
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/flask_sqlalchemy/__init__.py", line 704, in create_session
    return SignallingSession(self, **options)
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/flask_sqlalchemy/__init__.py", line 149, in __init__
    self.app = db.get_app()
  File "/Users/user/.virtualenvs/myfolder/lib/python2.7/site-packages/flask_sqlalchemy/__init__.py", line 845, in get_app
    raise RuntimeError('application not registered on db '
RuntimeError: application not registered on db instance and no application bound to current context

Ответ 1

Flask-SQLAlchemy требует активного контекста приложения для выполнения запросов. В то время как Flask-APScheduler интегрирует APScheduler с Flask, он не нажимает контекст приложения при запуске каждого задания.

Вам нужно нажать контекст приложения в своей работе. Нажатие контекста приложения при настройке расширения ничего не делает.

def my_job():
    with app.app_context():
        ...

Вероятно, вам нужен контекст приложения для всех заданий. Вы можете подклассифицировать расширение и переопределить run_job.

from flask_apscheduler import APScheduler as _BaseAPScheduler

class APScheduler(_BaseAPScheduler):
    def run_job(self, id, jobstore=None):
        with self.app.app_context():
            super().run_job(id=id, jobstore=jobstore)
            # super(APScheduler, self) in Python 2

Ответ 2

Я исправил это, добавив приложение в мой экземпляр SQLAlchemy в приложении factory:

def create_app():
    new_app = Flask(__name__)
    new_app.config.from_object('config')
    new_app.secret_key = os.urandom(12)
    db.init_app(new_app)
    db.app = new_app
    return new_app

Я попытался использовать контекст приложения, но никогда не работал.