4

我知道关于如何处理烧瓶“在应用程序上下文之外工作”的问题很少，但我无法让它们为我工作

我有一个长时间运行的 mongo 聚合查询，并计划使用 apscheduler 定期运行。以下是我的应用程序结构，但任务因“RuntimeError：在应用程序上下文之外工作”而失败。ihttp://flask.pocoo.org/docs/patterns/sqlite3/ 有一些关于使用新的flask.g的例子，但想知道是否有人可以建议如何在全球范围内正确保存mongodb连接并在apscheduler中共享该连接

__init.py__

from app import create_app

应用程序.py

from flask import Flask, request, render_template,g
from .extention import mongo, redis, sched

def create_app(config=None):
"""Create a Flask app."""

    app = Flask(__name__)
    configure_extensions(app)
    return app

def configure_extensions(app):
    mongo.init_app(app) # initialise mongo connection from the config
    redis.init_app(app)

from schedule_tasks import *

扩展名.py

from flask.ext.pymongo import PyMongo
mongo = PyMongo()

from apscheduler.scheduler import Scheduler
config = {'apscheduler.jobstores.file.class': 'apscheduler.jobstores.shelve_store:ShelveJobStore',
          'apscheduler.jobstores.file.path': '/tmp/sched_dbfile'}
sched = Scheduler(config)

from flask.ext.redis import Redis
redis = Redis()

schedule_tasks.py

from .extention import mongo
@sched.interval_schedule(minutes=1)
def long_running_queries():
    ## mongo agg query ##
    mongo.db.command("aggregate", "collection", pipeline = "some query" )
sched.start()
sched.print_jobs()
4

1 回答 1

5

要了解此错误，您需要了解应用程序上下文。

有人完全有可能编写多个 Flask 应用程序，它们都在同一个进程中处理他们的请求。文档给出了以下示例...

from werkzeug.wsgi import DispatcherMiddleware
from frontend_app import application as frontend
from backend_app import application as backend

application = DispatcherMiddleware(frontend, {
    '/backend':     backend
})

请记住，在这种情况下，前端应用程序可以使用不同的 Mongo 设置，但使用完全相同的 Mongo 扩展对象。因此，当您运行脚本时，Flask 无法假定哪个是“当前”应用程序。因此，诸如url_for()MongoDB 扩展之类的扩展上的许多方法，在执行任何操作之前都需要知道哪个应用程序是“当前”应用程序。

因此，每当您尝试使用 Flask 或扩展函数来做除了设置应用程序本身（使用配置值等）之外的任何事情时，您需要明确告诉 Flask 当前应用程序分配给应用程序上下文的内容是什么。

文档提供了一种方法可以做到这一点..

# Be careful about recursive imports here
from . import app
from .extention import mongo

@sched.interval_schedule(minutes=1)
def long_running_queries():
    with app.app_context():
        mongo.db.command("aggregate", "collection", pipeline = "some query" )

因此，您需要创建应用程序对象本身，然后使用该with app.app_context()行。在 with 语句中，您的所有调用（例如对 Mongo 扩展的调用）都应该可以工作。请注意，您不需要在视图中执行任何这些操作，因为 Flask 会在处理请求时自动执行所有这些操作。

于 2013-08-30T00:00:39.377 回答