#全局通用配置類
class Config(object):
    """項(xiàng)目配置核心類"""
    #調(diào)試模式
    DEBUG=False
?
    # 配置日志
    # LOG_LEVEL = "DEBUG"
    LOG_LEVEL = "INFO"
?
?
    # 配置redis
    # 項(xiàng)目上線以后，這個(gè)地址就會(huì)被替換成真實(shí)IP地址，mysql也是
    REDIS_HOST = 'your host'
    REDIS_PORT = your port
    REDIS_PASSWORD = 'your password'
    REDIS_POLL = 10
?
    #數(shù)據(jù)庫(kù)連接格式
    SQLALCHEMY_DATABASE_URI = "mysql+pymysql://user:password@localhost:3306/test?charset=utf8"
    # 動(dòng)態(tài)追蹤修改設(shè)置，如未設(shè)置只會(huì)提示警告
    SQLALCHEMY_TRACK_MODIFICATIONS = False
    # 查詢時(shí)會(huì)顯示原始SQL語(yǔ)句
    SQLALCHEMY_ECHO = False
    # 數(shù)據(jù)庫(kù)連接池的大小
    SQLALCHEMY_POOL_SIZE=10
    #指定數(shù)據(jù)庫(kù)連接池的超時(shí)時(shí)間
    SQLALCHEMY_POOL_TIMEOUT=10
    # 控制在連接池達(dá)到最大值后可以創(chuàng)建的連接數(shù)。當(dāng)這些額外的 連接回收到連接池后將會(huì)被斷開和拋棄。
    SQLALCHEMY_MAX_OVERFLOW=2
?
?
    #rabbitmq參數(shù)配置
    RABBITUSER="user"
    RABBITPASSWORD="password"
    RABBITHOST="your ip"
    RABBITPORT=your port

from . import Config
?
class DevelopmentConfig(Config):
    '開發(fā)模式下的配置'
    # 查詢時(shí)會(huì)顯示原始SQL語(yǔ)句
    SQLALCHEMY_ECHO = True

from . import Config
?
class ProductionConfig(Config):
    """生產(chǎn)模式下的配置"""
    DEBUG = False

# 主應(yīng)用的根目錄
app = Flask(__name__)
?
config = {
    'dev': DevelopmentConfig,
    'prop': ProductionConfig,
}
?
# 設(shè)置配置類
Config = config['dev']
?
# 加載配置
app.config.from_object(Config)
?
# 創(chuàng)建數(shù)據(jù)庫(kù)連接對(duì)象
db = SQLAlchemy(app)

# 配置對(duì)象，里面定義需要給 APP 添加的一系列配置
class Config(object):
    DEBUG = True
?
?
app = Flask(__name__)
?
# 從配置對(duì)象中加載配置
app.config.from_object(Config)
app.run()

app = Flask(__name__)
?
# 從配置對(duì)象中加載配置
app.config.from_pyfile("config.ini")
app.run()

app = Flask(__name__)
# 從環(huán)境變量中加載
app.config.from_envvar("FLASKCONFIG")
app.run()

from application import db
?
class Wdtest(db.Model):
    __tablename__ = "wdtest" #設(shè)置表名
    id = db.Column(db.String(100), primary_key=True, comment="主鍵ID")
    name = db.Column(db.String(20), index=True, comment="姓名" )
    age = db.Column(db.Integer, default=True, comment="年齡")

#給app取別名為 'index'
index_blu=Blueprint('index',__name__,template_folder='templates',static_folder='static')
?
from .views import *

from application.settings.dev import DevelopmentConfig
from application.settings.prop import ProductionConfig
?
# 主應(yīng)用的根目錄
app = Flask(__name__)
?
config = {
    'dev': DevelopmentConfig,
    'prop': ProductionConfig,
}
?
# 設(shè)置配置類
Config = config['dev']
?
# 加載配置
app.config.from_object(Config)
?
# 創(chuàng)建數(shù)據(jù)庫(kù)連接對(duì)象
db = SQLAlchemy(app)
?
# todo 注冊(cè)藍(lán)圖
from .apps.app1 import index_blu
app.register_blueprint(index_blu, url_prefix='/index')

def __init__(
        self,
        import_name,
        static_url_path=None,
        static_folder="static",
        static_host=None,
        host_matching=False,
        subdomain_matching=False,
        template_folder="templates",
        instance_path=None,
        instance_relative_config=False,
        root_path=None,
    ):pass

student = Wdtest(id=ids , name=name, age=age)
try:
    application.db.session.add(student)
    application.db.session.commit()
except:
    # 事務(wù)回滾
    application.db.session.rollback()

    user = Wdtest.query.first()
    application.db.session.delete(user)
    application.db.session.commit()

user = Wdtest.query.first()
user.name = name
try:
    application.db.session.commit()
except:
    # 事務(wù)回滾
    application.db.session.rollback()

# 查詢所有?戶數(shù)據(jù)
user_list=Wdtest.query.all()
?
# 查詢有多少個(gè)?戶
user_list_num=Wdtest.query.count()
# 查詢第1個(gè)?戶
user=Wdtest.query.first()
# 查詢id為3的?戶[3種?式]
user=Wdtest.query.get(3)  # 根據(jù)主鍵查詢
user_list=Wdtest.query.filter_by(id=3).all()  # 以關(guān)鍵字實(shí)參形式進(jìn)行匹配字段
user_list=Wdtest.query.filter(Wdtest.id == 3).all()  # 以恒等式形式匹配字段
?
# 查詢名字結(jié)尾字符為g的所有?戶
Wdtest.query.filter(Wdtest.name.endswith('g')).all()
?
# 查詢名字包含‘wa'的所有項(xiàng)目
user_list=Wdtest.query.filter(Wdtest.name.contains('wa')).all()
# 模糊查詢
user_list =Wdtest.query.filter(Wdtest.name.like('%a%')).all()
# 查詢名字wa開頭和age為20的所有?戶[2種?式]
user_list=Wdtest.query.filter(Wdtest.name.startswith('wa'),Wdtest.age == 20).all()
user_list=Wdtest.query.filter(and_(Wdtest.name.startswith('wa'), Wdtest.age == 20)).all()
?
# 非條件查詢查詢名字不等于wade的所有?戶[2種?式]
user_list=Wdtest.query.filter(not_(Wdtest.name == 'wade')).all()
user_list=Wdtest.query.filter(Wdtest.name != 'wade').all()
?
# in 條件查詢
user_list=Wdtest.query.filter(Wdtest.id.in_(['97124f50-0208-11ea-a66c-04ea56212bdf', '3'])).all()
?
# 所有?戶先按年齡從?到?, 再按id從?到?排序, 取前5個(gè)
user_list=Wdtest.query.order_by(Wdtest.age,Wdtest.id.desc()).limit(5).all()
?
# 分?查詢, 每?3個(gè), 查詢第2?的數(shù)據(jù)
pn = Wdtest.query.paginate(2,3)
print(pn.pages)
print(pn.page)
print(pn.items)

# 路由傳遞參數(shù)
@app.route('/user/<id>')
def user_info(id):
    return '%s' % id

@app.route('/test', methods=['GET', 'POST'])
def test():
    return "ok"

from werkzeug.routing import BaseConverter

# 自定義正則轉(zhuǎn)換器
class RegexConverter(BaseConverter):
    def __init__(self, url_map, *args):
        super(RegexConverter, self).__init__(url_map)
        # 將接受的第1個(gè)參數(shù)當(dāng)作匹配規(guī)則進(jìn)行保存
        self.regex = args[0]

app = Flask(__name__)
?
# 將自定義轉(zhuǎn)換器添加到轉(zhuǎn)換器字典中，并指定轉(zhuǎn)換器使用時(shí)名字為: regex
app.url_map.converters['regex'] = RegexConverter

@app.route('/index/<regex("[0-9]{3}"):id>')
def user_info(id):
    return "id 為 %s" % id

class RegexConverter(BaseConverter):
    def __init__(self, url_map, *args):
        super(RegexConverter, self).__init__(url_map)
        # 將接受的第1個(gè)參數(shù)當(dāng)作匹配規(guī)則進(jìn)行保存
        self.regex = args[0]
?
    def to_python(self, value):
        return int(value)

DEFAULT_CONVERTERS = {
    'default':          UnicodeConverter,
    'string':           UnicodeConverter,
    'any':              AnyConverter,
    'path':             PathConverter,
    'int':              IntegerConverter,
    'float':            FloatConverter,
    'uuid':             UUIDConverter,
}

# 配置日志
# LOG_LEVEL = "DEBUG"
LOG_LEVEL = "INFO"

FATAL/CRITICAL = 致命的，危險(xiǎn)的
ERROR = 錯(cuò)誤
WARNING = 警告
INFO = 信息
DEBUG = 調(diào)試
NOTSET = 沒有設(shè)置

#增加日志模塊
def setup_log(Config):
    #設(shè)置日志等級(jí)
    logging.basicConfig(level=Config.LOG_LEVEL)
    # 創(chuàng)建日志記錄器，指明日志保存的路徑、每個(gè)日志文件的最大大小、保存的日志文件個(gè)數(shù)上限
    file_log_handler=RotatingFileHandler('log/log',maxBytes=1024 * 1024 * 300, backupCount=10)
    # 創(chuàng)建日志記錄的格式 日志等級(jí) 輸入日志信息的文件名 行數(shù) 日志信息
    formatter = logging.Formatter('%(asctime)s: %(levelname)s %(filename)s:%(lineno)d %(message)s')
    # 為剛創(chuàng)建的日志記錄器設(shè)置日志記錄格式
    file_log_handler.setFormatter(formatter)
    # 為全局的日志工具對(duì)象（flaskapp使用的）添加日志記錄器
    logging.getLogger().addHandler(file_log_handler)

#日志啟動(dòng)
setup_log(Config)

#新增redis連接模塊
def connectRedis(Config):
    pool = redis.ConnectionPool(host=Config.REDIS_HOST, port=Config.REDIS_PORT, password=Config.REDIS_PASSWORD,
                                max_connections=Config.REDIS_POLL)
    redis_store = redis.Redis(connection_pool=pool)
    return redis_store

@index_blu.route("/redis",methods=["POST","GET"])
def add_toRedis():
    logging.info("come to here")
    key = request.args.get("key")
    application.redis_store.set(key , "1233")
    value=application.redis_store.get( key )
    print(value)
    return "12333"

# rabbitmq配置訪問
# 添加用戶名和密碼
credentials = pika.PlainCredentials(Config.RABBITUSER, Config.RABBITPASSWORD)
# 配置連接參數(shù)
parameters = pika.ConnectionParameters(host=Config.RABBITHOST, port=Config.RABBITPORT, credentials=credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

@index_blu.route("/rabitmq",methods=["POST","GET"])
def add_rabitmq():
    logging.info("come to rabiitmq")
    application.channel.queue_declare(queue='queuetest2')
?
    return "33333"

from flask import request
import application
?
# 攔截器,每次的請(qǐng)求進(jìn)來都會(huì)做的操作
@application.app.before_request
def before_action():
    # 獲取當(dāng)前請(qǐng)求的路由（路徑）
    a = request.path
    print(a)
    u = a.split('/')
    if len(a)>2:
        if u[1] == 'index':
            print('success')
    else:
        return "無(wú)權(quán)限請(qǐng)求"

#攔截器加載
requestFilter.before_action

from flask import request

class JSONResponse(Response):
?
    @classmethod
    def force_type(cls, response, environ=None):
        '''
        這個(gè)方法只有視圖函數(shù)返回非字符、非元祖、非Response對(duì)象才會(huì)調(diào)用
        :param response:是視圖函數(shù)的返回值
        :param environ:
        :return:
        '''
        print(response)
        print(type(response))
        if isinstance(response,(list,dict)):
?
            #jsonify除了將字典轉(zhuǎn)換成json對(duì)象，還將對(duì)象包裝成了一個(gè)Response對(duì)象
            response = jsonify(response)
?
        return super(JSONResponse,cls).force_type(response,environ) 
        
app.response_class = JSONResponse

@app.errorhandler(500)
def internal_server_error(e):
    return '服務(wù)器搬家了哈哈哈'
?
@app.errorhandler(404)
def internal_server_error(e):
    return '瞎請(qǐng)求什么路徑呢'

@app.errorhandler(413)
def zero_division_error(e):
    return '除數(shù)不能為0'

@index_blu.route("/exception",methods=["POST","GET"])
def exception():
    logging.info("come to exception")
    try:
        print(2)
        a=3/0
    except:
        abort(413)
    return "ooooo"

current_app.name
current_app.test_value='value'

g.name='abc'

-c CONFIG : CONFIG,配置?件的路徑，通過配置?件啟動(dòng)；?產(chǎn)環(huán)境使?； 
?
-b ADDRESS : ADDRESS，ip加端?，綁定運(yùn)?的主機(jī)； 
?
-w INT, --workers INT：?于處理?作進(jìn)程的數(shù)量，為正整數(shù)，默認(rèn)為1； 
?
-k STRTING, --worker-class STRTING：要使?的?作模式，默認(rèn)為sync異步，可以下載 
?
eventlet和gevent并指定 
?
--threads INT：處理請(qǐng)求的?作線程數(shù)，使?指定數(shù)量的線程運(yùn)?每個(gè)worker。為正整數(shù)，默認(rèn)為1。 
?
--worker-connections INT：最?客戶端并發(fā)數(shù)量，默認(rèn)情況下這個(gè)值為1000。 
?
--backlog int：未決連接的最?數(shù)量，即等待服務(wù)的客戶的數(shù)量。默認(rèn)2048個(gè)，?般不修改； 
?
-p FILE, --pid FILE：設(shè)置pid?件的?件名，如果不設(shè)置將不會(huì)創(chuàng)建pid?件 
?
--access-logfile FILE ： 要寫?的訪問?志?錄--access-logformat STRING：要寫?的訪問?志格式 
?
--error-logfile FILE, --log-file FILE ： 要寫?錯(cuò)誤?志的?件?錄。 
?
--log-level LEVEL ： 錯(cuò)誤?志輸出等級(jí)。 
?
--limit-request-line INT ： HTTP請(qǐng)求頭的?數(shù)的最???，此參數(shù)?于限制HTTP請(qǐng)求?的允 
?
許??，默認(rèn)情況下，這個(gè)值為4094。值是0~8190的數(shù)字。 
?
--limit-request-fields INT ： 限制HTTP請(qǐng)求中請(qǐng)求頭字段的數(shù)量。此字段?于限制請(qǐng)求頭字 
?
段的數(shù)量以防?DDOS攻擊，默認(rèn)情況下，這個(gè)值為100，這個(gè)值不能超過32768 
?
--limit-request-field-size INT ： 限制HTTP請(qǐng)求中請(qǐng)求頭的??，默認(rèn)情況下這個(gè)值為8190 
?
字節(jié)。值是?個(gè)整數(shù)或者0，當(dāng)該值為0時(shí)，表示將對(duì)請(qǐng)求頭??不做限制 
?
-t INT, --timeout INT：超過這么多秒后?作將被殺掉，并重新啟動(dòng)。?般設(shè)定為30秒； 
?
--daemon： 是否以守護(hù)進(jìn)程啟動(dòng)，默認(rèn)false； 
?
--chdir： 在加載應(yīng)?程序之前切換?錄； 
?
--graceful-timeout INT：默認(rèn)情況下，這個(gè)值為30，在超時(shí)(從接收到重啟信號(hào)開始)之后仍然活著 
?
的?作將被強(qiáng)?殺死；?般使?默認(rèn)； 
?
--keep-alive INT：在keep-alive連接上等待請(qǐng)求的秒數(shù)，默認(rèn)情況下值為2。?般設(shè)定在1~5秒之 
?
間。 
?
--reload：默認(rèn)為False。此設(shè)置?于開發(fā)，每當(dāng)應(yīng)?程序發(fā)?更改時(shí)，都會(huì)導(dǎo)致?作重新啟動(dòng)。 
?
--spew：打印服務(wù)器執(zhí)?過的每?條語(yǔ)句，默認(rèn)False。此選擇為原?性的，即要么全部打印，要么全部 
?
不打?。?
?
--check-config ：顯示現(xiàn)在的配置，默認(rèn)值為False，即顯示。 
?
-e ENV, --env ENV： 設(shè)置環(huán)境變量；