文档章节

Flask 中 MongoDB 的使用

AllenOR灵感
 AllenOR灵感
发布于 2017/09/10 01:24
字数 1009
阅读 7
收藏 1

1. Flask 应用的外部脚本:Flask-Script

Flask-Script 是一个可以在 flask 应用外部编写脚本的扩展。它有一些常用的功能如下:

  • 运行一个开发的服务器
  • Python shell 中操作数据库
  • 命令行任务

首先,我们需要安装 Flask-Script,在Linux系统下,我们可以通过 pip install flask-script 命令行来安装。

我们还是先来看一下,我们目录下面的文件:

192:test ming$ tree
.
├── app.py
├── static
└── templates

2 directories, 1 file

之后,我们来创建一个文件用来存放我们的 web 脚本,一般我们将它命名为 manage.py。然后在里面编写一个 hello world 的脚本,如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from flask_script import Manager
from app import app

# 实例化
manager = Manager(app)

# 修饰器
@manager.command
def hello():
    print 'hello world'

if __name__ =="__main__":
    manager.run()

然后再终端中运行这个脚本 python manage.py hello ,结果如下

192:test ming$ python manage.py hello
hello world

我们在运行命令中,也是可以从终端传入一些参数的,我们修改一下代码,实现参数的传入,如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from flask_script import Manager
from app import app

# 实例化
manager = Manager(app)

# 修饰器
@manager.command
def hello():
    print 'hello world'

@manager.option('-m', '--msg', dest='msg_val', default='world')
def hello_world(msg_val):
    print 'hello ' + msg_val

if __name__ =="__main__":
    manager.run()

现在,我们来运行一下这个程序。首先,我们不传入任何的参数来运行这个程序,运行结果如下:

192:test ming$ python manage.py hello_world
hello world

之后,我们从终端中传入参数 ming ,使其能打印 hello ming,运行结果如下:

192:test ming$ python manage.py hello_world -m ming
hello ming

其实,细心的你肯定发现了,我们的运行脚本是

python manage.py <方法名>

至此,我们已经学会了如何简单的去操作 Flask 应用的外部脚本。

2. MongoDB 的使用

如果你对 MongoDB 还不了解,那么可以先查看这篇博客,做一个入门学习。

python 与 MongoDB 之间的交互有很多种的方法,在这里我们选择 pymongo 来进行连接。

首先,我们来查看一下,我们创建的文件,如下:

192:test ming$ tree
.
├── app.py
├── manage.py
├── models.py
├── static
└── templates

2 directories, 3 files

我们开始编写文件,先来编写 models.py 中的模型代码,如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import pymongo

# 返回一个 collection
def get_coll():

    client = pymongo.MongoClient('127.0.0.1', 27017)
    db = client.test
    user = db.user_collection

    return user


class User(object):

    def __init__(self, name, email):
        self.name = name
        self.email = email

    def save(self):
        user = {"name": self.name, "email": self.email}
        coll = get_coll()
        id = coll.insert(user)
        print id

    @staticmethod
    def query_users():
        users = get_coll().find()
        return users

之后,编写编写脚本文件,如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from flask_script import Manager
from app import app
from models import User

# 实例化
manager = Manager(app)

# 修饰器
@manager.command
def save():
    user = User('ming', 'ming@hehe.com')
    user.save()

@manager.command
def query_users():
    users = User.query_users()
    for user in users:
        print user


if __name__ =="__main__":
    manager.run()

接下来,我们可以查看一下我们的程序,首先是保存脚本,结果如下:

192:test ming$ python manage.py save
58234f769f5a725d8dda373e

返回了一个 ID ,说明保存成功了。接下来,我们运行一下查询脚本,查询结果如下:

192:test ming$ python manage.py query_users
{u'_id': ObjectId('58234f769f5a725d8dda373e'), u'name': u'ming', u'email': u'ming@hehe.com'}

接下来,我们来学习 MongoDB 中的ORM。MongoDB 的 ORM 有很多种,在本博客中我们 MongoEngine 来实现。

首先,我们需要修改 app.py 程序,将 MongoEngine 导入程序中,如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from flask import Flask 
from flask.ext.mongoengine import MongoEngine 

app = Flask(__name__)

# test 是链接的数据库
app.config['MONGODB_SETTINGS'] = {'db': 'test'}

# 实例化
db = MongoEngine(app)

@app.route('/')
def index():
    return 'Hello World!'


if __name__ == "__main__":
    app.run()

之后,我们修改 models.py 程序,添加两个字段 nameemail。如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from app import db

# 类名定义 collection
class User(db.Document):
    # 字段
    name = db.StringField()
    email = db.StringField()

    def __str__(self):
        return "name:{} - email:{}".format(self.name, self.email)

最后,我们修改脚本文件 manage.py ,如下:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from flask_script import Manager
from app import app
from models import User

# 实例化
manager = Manager(app)

# 修饰器
@manager.command
def save():
    user = User(name = 'ming02', email = 'ming02@hehe.com')
    user.save()

@manager.command
def query_users():
    users = User.objects.all()
    for user in users:
        print user


if __name__ =="__main__":
    manager.run()

现在,你可以运行 python manage.py savepython manage.py query_users 命令来测试程序了。

本文转载自:http://www.jianshu.com/p/1ece494e5ead

共有 人打赏支持
AllenOR灵感
粉丝 11
博文 2635
码字总数 83001
作品 0
程序员
私信 提问
社区模板的 python 后端实现 - PyFly

项目介绍 PyFly 是 Flask + Layui Fly Template实现的一个社区项目,使用flask-admin实现了简单的后台管理功能,数据库使用Mongodb,前台实现功能:用户注册、登录、邮件激活、发帖、回帖、...

981764793
04/28
0
0
981764793/PyFly

PyFly 项目介绍 Flask + Layui Fly Template实现的一个社区项目,使用flask-admin实现了简单的后台管理功能,数据库使用Mongodb,前台实现功能:用户注册、登录、邮件激活、发帖、回帖、点赞...

981764793
04/28
0
0
Flask / MongoDB 搭建简易图片服务器

1、前期准备 通过 pip 或 easy_install 安装了 pymongo 之后, 就能通过 Python 调教 mongodb 了. 接着安装个 flask 用来当 web 服务器. 当然 mongo 也是得安装的. 对于 Ubuntu 用户, 特别是使...

大数据之路
2013/10/09
0
1
Mongodb 查询性能提高问题

简单描述: 我做的项目用到了mongoDB, 主要是查询和插入操作。前端用的基于jinja框架的flask.目前有一个接口,调用的时候会从mongodb 查询数据然后在网页前端显示。 问题: 打开网页的速度有...

hi_water
2016/12/13
274
3
PHP与MongoDB:类库、框架与工具介绍

本文来自MongoDB官方,文中把PHP与MongoDB相关的类库、框架、工具做了汇总和介绍,如果你正使用PHP并在关注MongoDB,那么这篇文章可能对你有用。 架构相关 CakePHP CakePHP是一个非常受欢迎的...

kisshua
2012/08/31
0
0

没有更多内容

加载失败,请刷新页面

加载更多

转换 bytes 为 kb/mb/gb/tb/pb…

智能转换 bytes 为 kb/mb/gb/tb/pb… 用到了 math 模块中的一些函数 #!/usr/bin/env python# -*- coding: utf-8 -*-"""智能转换 bytes 为 kb/mb/gb/tb/pb..."""import mathdef conv...

郭恩洲_OSC博客
9分钟前
1
0
Mysql导出sql语句的方法及可能遇到的mysqldump: command not found

解决办法: 打开terminal    输入vi ~/.bash_profile    添加如下三行代码:    #mysql  PATH=$PATH:/usr/local/mysql/bin  export    保存并退出...

Liens
10分钟前
0
0
一文读懂,深入浅出 RPC框架

RPC 功能目标 RPC 的主要功能目标是让构建分布式计算(应用)更容易,在提供强大的远程调用能力时不损失本地调用的语义简洁性。为实现该目标,RPC 框架需提供一种透明调用机制让使用者不必显...

别打我会飞
11分钟前
0
0
sed关于打印

p命令用来打印文本行 跟替换命令中的p标记类似,p命令可以打印sed编辑器输出中的一行。 我们这主要还是用,下面的测试吧 我们可以试一下 echo 'hello world,xin!' | sed 'p' 如果我还是用tes...

woshixin
21分钟前
0
0
【转载】缓存穿透,缓存击穿,缓存雪崩解决方案分析

前言 设计一个缓存系统,不得不要考虑的问题就是:缓存穿透、缓存击穿与失效时的雪崩效应。 缓存穿透 缓存穿透是指查询一个一定不存在的数据,由于缓存是不命中时被动写的,并且出于容错考虑...

xiaomin0322
28分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部