基于Flask开发企业级REST API应用（四）

阳仔

发布于 2019-08-21 17:59:18

5570

发布于 2019-08-21 17:59:18

文章被收录于专栏：终身开发者

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

0x00 配置缓存服务

几乎现在所有应用都会用到缓存技术，而在服务器端redis是很多实现缓存的首选技术。

对于我们这个应用也是需要使用缓存技术提高接口访问速度。

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

下载并编译安装

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命令行客户端连接测试

src/redis-cli
redis> set foo bar
OK
redis> get foo
"bar"

建议详细的配置可以参阅相关官方文档。本文的重点还是关注在项目中的使用。

安装依赖

安装

pip install redis

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

然后对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))
    ...

UserInfo与UserAuth是一对一的关系。即一个用户对应一个授权信息，在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_auth与user_info是一对一的关系，如果是一对多的关系，这里uselist=True，不传参数时默认uselist是True。