Flask项目示例目录

　　Flask不同于Django，Django在创建程序时自动得到必要的目录文件，而Flask则只有一个空文件夹，所以关于Flask项目的目录我们需要自行配置。

　　首先利用pycharm创建一个项目，在根目录下创建一个app文件夹（app文件）、一个utils文件夹（用于放数据库连接池）、一个manage.py文件和一个settings.py文件。这里我还创建了一个auth文件夹，写了一个验证登录的py文件

　　首先，我们要在app文件夹下依次创建一下内容：

    • 　　static文件夹：用于放静态文件
    • 　　templates文件夹：用于放置html模板文件
    • views文件夹：用于放置视图函数
    • __init__.py文件：注册app到启动文件，一会儿我们会在这里大做文章
    • models.py文件：用于放置创建表的类

　　在__init__.py中，需要做的是引入Flask-SQLAlchemy、创建app、设置配置文件、注册蓝图和注册组件

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Flask

from auth.auth import Auth
from flask_session import Session

# 1. 引入Flask-SQLAlchemy
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()#实例化SQLAlchemy

from .views.account import account
from .views.main import main
from .views.user import user

# 3. 导入models中的表
from .models import *

#创建app
def create_app():
    app = Flask(__name__)
    app.debug = True
    app.secret_key = ‘sdiusdfsdf‘#自定义的session秘钥
    # 设置配置文件
    app.config.from_object(‘settings.DevelopmentConfig‘)

    # 注册蓝图
    app.register_blueprint(account)
    app.register_blueprint(user)
    app.register_blueprint(main)

    # 注册组件
    # Session(app)
    Auth(app)

    # 2. 注册 Flask-SQLAlchemy
    # 这个对象在其他地方想要使用
    # SQLAlchemy(app)
    db.init_app(app)

    return app
#得到了一个app

app文件夹下的_init__.py

　　然后，在启动文件manage.py中导入创建的app，创建自定义命令后写下run

#!/usr/bin/env python
# -*- coding:utf-8 -*-
"""
被毙掉了
    # 5. 创建和删除表
    以后执行db.create_all()
    以后执行db.drop_all()
新第5步：
    安装 pip3 install Flask-Migrate
"""

import os
from flask_script import Manager, Server
# 5.1 导入
from flask_migrate import Migrate, MigrateCommand
from app import create_app, db

app = create_app()
manager = Manager(app)
# 5.2 创建migrate示例
migrate = Migrate(app, db)

@manager.command
def custom(arg):
    """
    自定义命令
    python manage.py custom 123
    :param arg:
    :return:
    """
    print(arg)

@manager.option(‘-n‘, ‘--name‘, dest=‘name‘)
@manager.option(‘-u‘, ‘--url‘, dest=‘url‘)
def cmd(name, url):
    """
    自定义命令
    执行： python manage.py  cmd -n wupeiqi -u http://www.oldboyedu.com
    :param name:
    :param url:
    :return:
    """
    print(name, url)

@manager.command
def import_news(path):
    """
    批量导入
    :param name:
    :param url:
    :return:
    """
    import xlrd
    from xlrd.book import Book
    from xlrd.sheet import Sheet
    from xlrd.sheet import Cell
    workbook = xlrd.open_workbook(path)
    sheet_names = workbook.sheet_names()
    # sheet = workbook.sheet_by_name(‘工作表1‘)
    sheet = workbook.sheet_by_index(0)

    # 循环Excel文件的所有行
    for row in sheet.get_rows():
        # print(row)
        # 循环一行的所有列
        for col in row:
            # 获取一个单元格中的值
            print(col.value, end=‘;‘)
        print(‘‘)

"""
# 数据库迁移命名
    python manage.py db init
    python manage.py db migrate
    python manage.py db upgrade
"""
# 5.3 创建db命令，以后在数据库操作的时候都可使用db
manager.add_command(‘db‘, MigrateCommand)

"""
# 自定义命令
    python manage.py runserver
"""
manager.add_command("runserver", Server())

"""
生成当前环境的所有依赖： requirements.txt
    pip3 freeze > requirements.txt

生成当前程序的所有依赖： requirements.txt
    pip3 install pipreqs
    pipreqs ./

"""

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

manage.py

　　接下来在settings.py文件中配置好相应的数据库信息，在utils文件夹下创建文件，写入数据库连接池的内容

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

class BaseConfig(object):
    SESSION_TYPE = ‘redis‘  # session类型为redis
    SESSION_KEY_PREFIX = ‘session:‘  # 保存到session中的值的前缀
    SESSION_PERMANENT = False  # 如果设置为True，则关闭浏览器session就失效。
    SESSION_USE_SIGNER = False  # 是否对发送到浏览器上 session:cookie值进行加密

    SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:[email protected]:3306/flask_cata?charset=utf8"
                                             #数据库用户名:密码@host:port/数据库名?编码
    SQLALCHEMY_POOL_SIZE = 2
    SQLALCHEMY_POOL_TIMEOUT = 30
    SQLALCHEMY_POOL_RECYCLE = -1

    # 追踪对象的修改并且发送信号
    SQLALCHEMY_TRACK_MODIFICATIONS = False

class ProductionConfig(BaseConfig):
    pass

class DevelopmentConfig(BaseConfig):
    pass

class TestingConfig(BaseConfig):
    pass

settings.py

import time
import pymysql
import threading
from DBUtils.PooledDB import PooledDB, SharedDBConnection
POOL = PooledDB(
    creator=pymysql,  # 使用链接数据库的模块
    maxconnections=6,  # 连接池允许的最大连接数，0和None表示不限制连接数
    mincached=2,  # 初始化时，链接池中至少创建的空闲的链接，0表示不创建
    maxcached=5,  # 链接池中最多闲置的链接，0和None不限制
    maxshared=3,  # 链接池中最多共享的链接数量，0和None表示全部共享。PS: 无用，因为pymysql和MySQLdb等模块的 threadsafety都为1，所有值无论设置为多少，_maxcached永远为0，所以永远是所有链接都共享。
    blocking=True,  # 连接池中如果没有可用连接后，是否阻塞等待。True，等待；False，不等待然后报错
    maxusage=None,  # 一个链接最多被重复使用的次数，None表示无限制
    setsession=[],  # 开始会话前执行的命令列表。如：["set datestyle to ...", "set time zone ..."]
    ping=0,
    # ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
    # host=‘47.93.4.198‘,
    host=‘127.0.0.1‘,#本机host
    port=3306,#数据库默认端口即3306
    user=‘root‘,#数据库用户名
    password=‘123‘,#数据库密码
    database=‘flask_cata‘,#数据库名
    charset=‘utf8‘
)

utils\pool\db_pool.py

"""

# 方式一
# helper = SQLHelper()
# helper.open()
# result = helper.fetchone(‘select * from users where name=%s and pwd = %s‘,[request.form.get(‘user‘),request.form.get(‘pwd‘),])
# helper.close()
# 方式二：
# with SQLHelper() as helper:
#     result = helper.fetchone(‘select * from users where name=%s and pwd = %s‘,[request.form.get(‘user‘),request.form.get(‘pwd‘),])
# if result:
#     current_app.auth_manager.login(result[‘name‘])
#     return redirect(‘/index‘)

"""

from utils.pool import db_pool
import pymysql

class SQLHelper(object):
    def __init__(self):
        self.conn = None
        self.cursor = None

    def open(self, cursor=pymysql.cursors.DictCursor):
        self.conn = db_pool.POOL.connection()
        self.cursor = self.conn.cursor(cursor=cursor)

    def close(self):
        self.cursor.close()
        self.conn.close()

    def fetchone(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchone()

        return result

    def fetchall(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchall()
        return result

    def __enter__(self):
        self.open()
        return self

    def __exit__(self, exc_type, exc_val, exc_tb):
        self.close()

        # with SQLHelper() as obj:
        #
        #     print(obj)
        #     print(‘正在执行‘)

utils\pool\sqlhelper.py

到这里，程序的基本框架就设定好了。

接下来就是具体项目的内容，这里举一个简单的栗子

　　在models.py中创建表

"""

# 方式一
# helper = SQLHelper()
# helper.open()
# result = helper.fetchone(‘select * from users where name=%s and pwd = %s‘,[request.form.get(‘user‘),request.form.get(‘pwd‘),])
# helper.close()
# 方式二：
# with SQLHelper() as helper:
#     result = helper.fetchone(‘select * from users where name=%s and pwd = %s‘,[request.form.get(‘user‘),request.form.get(‘pwd‘),])
# if result:
#     current_app.auth_manager.login(result[‘name‘])
#     return redirect(‘/index‘)

"""

from utils.pool import db_pool
import pymysql

class SQLHelper(object):
    def __init__(self):
        self.conn = None
        self.cursor = None

    def open(self, cursor=pymysql.cursors.DictCursor):
        self.conn = db_pool.POOL.connection()
        self.cursor = self.conn.cursor(cursor=cursor)

    def close(self):
        self.cursor.close()
        self.conn.close()

    def fetchone(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchone()

        return result

    def fetchall(self, sql, params):
        cursor = self.cursor
        cursor.execute(sql, params)
        result = cursor.fetchall()
        return result

    def __enter__(self):
        self.open()
        return self

    def __exit__(self, exc_type, exc_val, exc_tb):
        self.close()

        # with SQLHelper() as obj:
        #
        #     print(obj)
        #     print(‘正在执行‘)

models.py

　　通过python manage.py db init 　　   python manage.py db migrate 　　   python manage.py db upgrade三条命令进行数据库迁移创建表，得到migrations文件夹

　　在views文件夹下创建视图函数，并配置路由。在templates文件夹下创建模板html，在static下创建静态文件，基本项目就成型了

views：

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Blueprint, request, render_template, redirect, session, current_app
from app import models
from app import db
from sqlalchemy import orm

account = Blueprint(‘account‘, __name__)

@account.route(‘/login‘, methods=[‘GET‘, ‘POST‘])
def login():
    if request.method == ‘GET‘:

        """
        执行SQL
        方式一：
            result = db.session.query(models.User.id,models.User.name).all()
            db.session.remove()
        方式二：
            result = models.Users.query.all()
        """
        """
        示例：
            # 通配符
            ret = db.session.query(Users).filter(Users.name.like(‘e%‘)).all()
            ret = db.session.query(Users).filter(~Users.name.like(‘e%‘)).all()

            # 限制
            ret = db.session.query(Users)[1:2]

            # 排序
            ret = db.session.query(Users).order_by(Users.name.desc()).all()
            ret = db.session.query(Users).order_by(Users.name.desc(), Users.id.asc()).all()

            db.session.remove()

        """
        return render_template(‘login.html‘)
    else:
        return render_template(‘login.html‘)

account.py

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Blueprint, request, render_template, redirect

main = Blueprint(‘main‘, __name__)

@main.route(‘/index‘)
def index():
    # with SQLHelper() as helper:
    #     user_list = helper.fetchall(‘select * from users‘,[])

    return render_template(‘index.html‘)

main.py

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import Blueprint

user = Blueprint(‘user‘, __name__)

@user.route(‘/users‘)
def users():
    return ‘users‘

user.py

templates:

{% extends ‘layout.html‘ %}

{% block title %}首页{% endblock %}

{% block body %}
<table>
    <h1>欢迎登录：{{ session.get(‘user‘) }}</h1>
    <ul>
        {% for row in user_list %}
        <li>{{ row }}</li>
        {% endfor %}
    </ul>
</table>
{% endblock %}

index.html

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>{% block title %}{% endblock %}</title>
    <!-- <link rel="stylesheet" href="/static/css/commons.css" /> -->
    <link rel="stylesheet" href="{{ url_for(‘static‘,filename=‘css/commons.css‘) }}" />

    {% block css %}{% endblock %}
</head>
<body>
    <div class="pg-header"></div>
    <div class="pg-body">
        {% block body %}{% endblock %}
    </div>

    {% block js %}{% endblock %}
</body>
</html>

layout.html(基板)

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<form method="post">
    <input type="text" name="user">
    <input type="text" name="pwd">
    <input type="submit" value="提交">
</form>
</body>
</html>

login.html

附：

alembic==0.9.6
blinker==1.4
certifi==2017.11.5
chardet==3.0.4
click==6.7
DBUtils==1.2
docopt==0.6.2
Flask==0.12.2
Flask-Migrate==2.1.1
Flask-Script==2.0.6
Flask-Session==0.3.1
Flask-SQLAlchemy==2.3.2
idna==2.6
itsdangerous==0.24
Jinja2==2.10
Mako==1.0.7
MarkupSafe==1.0
pipreqs==0.4.9
PyMySQL==0.8.0
python-dateutil==2.6.1
python-editor==1.0.3
PyTyrion==1.0.1
requests==2.18.4
six==1.11.0
SQLAlchemy==1.2.0
urllib3==1.22
Werkzeug==0.14.1
WTForms==2.1
xlrd==1.1.0
yarg==0.1.9

requirement.txt

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from flask import request, session,redirect

# 登录成功时 _request_ctx_stack.top.user = user

class Auth(object):
    def __init__(self, app=None):
        self.app = app
        if app:
            self.init_app(app)

    def init_app(self, app):
        app.auth_manager = self

        app.before_request(self.check_login)
        app.context_processor(self.auth_context_processor)

    def auth_context_processor(self):
        name = session.get(‘user‘)
        return dict(current_user=name)

    def check_login(self):
        # print(request.url)
        # print(request.path)
        if request.path == ‘/login‘:
            return None

        if session.get(‘user‘):
            return None
        return redirect(‘/login‘)

    def permission(self):
        pass

    def login(self,data):
        session[‘user‘] = data

auth.py

　　

　　

原文地址：https://www.cnblogs.com/zhuminghui/p/8386991.html

时间： 2024-11-04 00:50:48

Flask项目示例目录的相关文章

python2.7环境下的flask项目导入模块失败解决办法

如下一个flask项目的目录: 这个flask项目在python3.6环境下可以正常启动,但是在python2.7环境下如下报错提示: 提醒模块找不到.如下解决方法: 只需要在views目录里面加一个空的__init__.py文件. 执行结果如下: 结束! 原文地址:https://www.cnblogs.com/aaronthon/p/9937715.html

应用程序框架实战三十八:项目示例VS解决方案的创建(一)

进行项目开发的第一步,是创建出适合自己团队习惯的VS解决方案,虽然我已经提供了项目示例,但毕竟是我创建的,你直接使用可能并不合适,另外你如果尝试模仿重新创建该示例,中间可能碰到各种障碍,特别是项目间的依赖关系. 本文的目的是帮助.Net架构初学者能顺利搭建起适合自己的VS解决方案,我会在本文演示曾经用过的几种不同风格的目录结构,你可以根据自己的习惯选择一种并自行修改. 本系列假定你已经熟悉如何创建.NET类库等基础知识,并具有.Net开发经验,我不会详细到每一个细节.如果你是.Net初学者,尚未

flask项目部署到阿里云 ubuntu16.04

title: flask项目部署到阿里云 ubuntu16.04 date: 2018.3.6 项目地址: 我的博客 部署思路参考: Flask Web开发>的个人部署版本,包含学习笔记. 开始之前 购买阿里云ecs一周版, 参考 购买万网域名(也是阿里家的) 过程: # apt update # apt upgrade # apt install python-virtualenv # apt install nginx git 下载源码: # git clone 我的博客源码地址 &&a

使用Nginx和uwsgi部署Flask项目

前言 之前用Flask框架开发了一个Python的Web项目,使用Nginx和uWSGI部署起来感觉挺麻烦,过程中还因为对Flask框架的不熟悉,花了好长时间才把应用完全部署起来.下面分享部署成功的相关配置以及部署Flask项目时极可能犯的一个小错误. 一. 配置 1. Flask Web项目源码 Nginx使用的版本是1.6.1,uWSGI是2.0.8,Flask是0.10.1.在Linux环境下安装好Nginx.uWSGI和Flask之后,将使用Flask框架开发的web项目源码放到Linu

windows环境隐藏命令行窗口运行Flask项目

Linux下可以使用nohub来使Flask项目在后台运行,而windows环境下没有nohub命令,如何让Flask项目在windows中在后台运行而不显示命令行窗口呢? 1.写一个.bat脚本来启动Flask程序 # app.py是Flask项目启动入库 python app.py 2.写一个.vbs脚本来启动.bat # app.py, run.bat 和 runbat.vbs放在同一个目录下,如果不是同一目录下则用绝对路径 CreateObject("WScript.Shell"

flask项目部署

1.安装 安装ssh 新版本安装位 apt/apt-get 老版本为 apt-get 安装以后 ifconfig查看当前的ip地址 如果网络不在同一个ip段 将网络模式设置为桥接 安装pip3 sudo apt install python3-pip 在要安装项目的目录创建虚拟环境 virtualenv venv source activate # 开启虚拟开发环境模式 退出 deactivate pip3 install uwsgi # 安装uwsgi 2.配置 uwsgi配置文件支持很多格式

Ubuntu16.04下搭建mysql + uwsgi + nginx环境启动flask 项目

1.安装mysql Sudo apt-get install mysql 配置mysql的数据存储路径,默认在 /var/lib/mysql sudo cp -R /var/lib/mysql/* /home/applex/mysqldb sudo chown -R mysql:mysql home/applex/mysqldb sudo gedit /etc/mysql/mysql.conf.d/mysqld.cnf 将 [mysqld] 组下的 datadir改为: datadir = /h

Web开发入门教程：Pycharm轻松创建Flask项目

Web开发入门教程:Pycharm轻松创建Flask项目 打开Pycharm的file,选择创建新的项目,然后弹出对话框,我们可以看到里面有很多的案例,Flask.Django等等,我们选择生成Flask的demo程序 选择创建之后一个简易的Flask项目就出现在我们眼前,第一个是入口程序,还有一个static的静态目录,templates是模板存放的位置 我们可以手动来启动这个Flask项目,但是这不是很理智的,在Pycharm上面有个run,我们可以选择run来启动Flask的服务,默认打开

Flask项目中向Mysql存入Emoji表情引起的Bug

Bug背景 之前在写Flask入门项目Flask Mega项目的时候,一直都是用SQLite,后面切换到Mysql数据库发现在存入一些EMOJI表情符号的时候,会出现如下的报错. Bug解决思路 刚开始觉得应该是数据库的编码的问题,因为之前也遇到数据库存入特殊符号的时候发生报错.那先查看服务器上面的数据库编码格式. show variables like '%char%'; 通过查看数据库编码发现都是utf8格式.然后查阅有关的资料,以及翻阅之前做过的笔记发现,Mysql中的utf8编码格式最多