ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

python – flask 0.10 mongo在应用程序上下文之外工作

2019-08-31 16:08:55  阅读:219  来源: 互联网

标签:python mongodb flask pymongo


我知道如何处理烧瓶“在应用程序环境之外工作”的问题很少,但我无法让它为我工作

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

__init.py__

from app import create_app

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 *

extention.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()

解决方法:

要了解此错误,您需要了解application context.

有人可以编写多个Flask应用程序,这些应用程序都在同一个进程中处理它们的请求.文档give the following example…

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当前要分配给application context的应用程序是什么.

文档提供了一种方法,你可以这样做..

# 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" )

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

标签:python,mongodb,flask,pymongo
来源: https://codeday.me/bug/20190831/1776779.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有