基于Flask开发企业级REST API应用(四)

关于我
一个有思想的程序猿,终身学习实践者,目前在一个创业团队任team lead,技术栈涉及Android、Python、Java和Go,这个也是咱们团队的主要技术栈。
Github:github.com/hylinux1024
微信公众号:终身开发者(angrycode)linux

0x00 配置缓存服务

几乎如今全部应用都会用到缓存技术,而在服务器端redis是不少实现缓存的首选技术。git

对于咱们这个应用也是须要使用缓存技术提升接口访问速度。github

首先安装redis,并启动redis服务。redis

下载并编译安装sql

wget http://download.redis.io/releases/redis-5.0.5.tar.gz
tar xzf redis-5.0.5.tar.gz
cd redis-5.0.5
make
复制代码

启动服务数据库

src/redis-server
复制代码

使用redis命令行客户端链接测试json

src/redis-cli
redis> set foo bar
OK
redis> get foo
"bar"
复制代码

建议详细的配置能够参阅相关官方文档。本文的重点仍是关注在项目中的使用。flask

安装依赖

安装缓存

pip install redis
复制代码

(固然,你也可使用Flask-Cache这个插件,使用起来也挺方便,不过本文延续以前的一些历史代码,就是直接使用redis这个库)bash

而后对redis作了一个简单的封装,分别是建立实例,设置缓存和获取缓存共三个静态方法。

import redis
import json
import datetime

# 建立链接池
pool = redis.ConnectionPool(host='127.0.0.1', port=6379)

class Redis:
 @staticmethod
    def connect(db=0):
        """默认使用0号库"""
        r = redis.Redis(connection_pool=pool, db=db)
        return r

    # 将内存数据二进制经过序列号转为文本流,再存入redis
 @staticmethod
    def set(r, key: str, data, ex=None):
        r.set(key, json.dumps(data, cls=CJsonEncoder), ex=ex)

    # 将文本流从redis中读取并反序列化,返回
 @staticmethod
    def get(r, key: str):
        data = r.get(key)
        if data is None:
            return None

        return json.loads(data)
复制代码

在须要使用缓存的模块中经过如下方式进行获取redis实例

r_cache = redis_helper.Redis.connect(db=5)
复制代码

因为我本机中还有其它的服务在开发,因此我选择5号库做为缓存,避免与其它服务发生冲突。

0x01 SQLAlchemy中实体关系的表示

前面几讲对模型中的关系在SQLAlchemy中的表示没有详细的说明,今天来拆解一下。

咱们以用户表(UserInfo)与受权表(UserAuth)进行说明。

class UserInfo(db.Model):
    """用户基本信息"""
    __tablename__ = 'user_info'

    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    email = db.Column(db.String(64))  # email
    nickname = db.Column(db.String(64))
    phone = db.Column(db.String(16))
    gender = db.Column(db.Integer)  # 1男2女0未知
    ...

class UserAuth(db.Model):
    """受权登陆表"""
    __tablename__ = 'user_auth'

    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    user_id = db.Column(db.Integer, db.ForeignKey('user_info.id'))
    user_basic = db.relationship(UserInfo, backref=db.backref('user_auth', uselist=False))
    ...
复制代码

UserInfoUserAuth是一对一的关系。即一个用户对应一个受权信息,在SQLAlchemy中表示关系是使用db.relationship()接口

UserAuth中定义外键user_id时须要指定db.ForeignKey('user_info.id'))参数,说明是关联的是user_info表中的id字段。经过外键关联了这两张表,但在实际的开发使用中,咱们但愿在查询到UserAuth实例的时候,但愿可以直接就可以获得对应的用户信息UserInfo的实例,这时候就能够用db.relationship()接口。在UserAuth就指定了这个关系

user_basic = db.relationship(UserInfo, backref=db.backref('user_auth', uselist=False))
复制代码

说明在UserAuth的实体中定义了一个user_basic的字段,当查询到UserAuth实例时,能够直接获得UserInfo的信息,而不须要程序猿再去经过外键user_id去数据库中查询用户信息。

db.relationship()中的第一个参数表示要关联的哪张表,能够传类名或表名称的字符串;第二个参数backref的意思是在UserInfo中也定义一个user_auth的属性,方便查询到用户信息时,能够经过这个属性获得对应的受权信息。uselist=False的意思是user_authuser_info是一对一的关系,若是是一对多的关系,这里uselist=True,不传参数时默认uselistTrue

0x03 总结

本文对前面几讲中的涉及到的模型定义中关系的表示和缓存的使用作一个补充说明。

0x04 引用

相关文章
相关标签/搜索