sanic(4)：增加mysql数据库与redis支持

超级大猪

发布于 2019-11-21 20:33:18

4.7K0

发布于 2019-11-21 20:33:18

文章被收录于专栏：大猪的笔记

项目结构

依据上文，我们已经可以做出后台，也能使用jinja2来渲染页面。下面简单讲讲如何给sanic项目添加mysql和redis支持。

|-- README.md
|-- app.py
|-- handlers
|   |-- __init__.py
|   |-- __pycache__
|   |-- admin_api
|   |-- index.py
|-- run_qb_games.py
|-- shutdown.sh
|-- sql.txt
|-- srvconf.py
|-- templates
|   |-- 404_v3.html
|   |-- 500_v3.html
|   `-- web
|       |-- index.html

安装插件

sanic可以开心的使用异步mysql与异步redis，首先需要的是安装插件，当然，mysql和redis的服务是必须有的。本文就不涉及了。

python3.6 -m pip install aioredis
python3.6 -m pip install aiomysql

初始化

安装完毕后，打开app.py文件。在之前的setup_db_redis函数中添加内容：

@app.listener('before_server_start')
async def setup_db_redis(app, loop):
    app.db = await aiomysql.create_pool(
    host=srvconf.mysql_host,
    port=srvconf.mysql_port,
    user=srvconf.mysql_user,
    password=srvconf.mysql_password,
    db=srvconf.database, loop=loop, charset='utf8', autocommit=True)

    app.redis_pool = await aioredis.create_pool(
        (srvconf.redis_host, srvconf.redis_port),
        minsize=5,
        maxsize=10,
        loop=loop
    )
    ...

在项目运行的时候，将db pool和redis pool保存到app对象中。

项目结束关闭资源

创建了pool，在项目关闭的时候就得把资源释放。在app.py中添加代码如下：

@app.listener('after_server_stop')
async def close_db_redis(app, loop):
    app.db.close()
    await app.db.wait_closed()

    app.redis_pool.close()
    await app.redis_pool.wait_closed()

mysql操作

涉及到数据库话题就很大了，在本文中，只讲简单的操作，不涉及高级用法，具体见aiomysql的文档。

查询

使用mysql pool创建一个查询，代码如下：

async with app.db.acquire() as conn:
    async with conn.cursor(aiomysql.DictCursor) as cur:
        await cur.execute(self.sql, self.values)
        r = await cur.fetchall()

注意，在self.sql中是需要参数化传值的。用%s做占位符。 r返回一个数组，每行是一个字典。字典的Key为数据库字段，值为数据值。

删除、修改

    async with app.db.acquire() as conn:
        async with conn.cursor() as cur:
            await cur.execute(self.sql, self.values)
            ret = await conn.commit()
            return ret

新增

如果插入一个行新的内容，希望得到自动增长的ID。此时，可以使用lastrowid获取:

async with app.db.acquire() as conn:
    async with conn.cursor() as cur:
        await cur.execute(self.sql, self.values)
        await conn.commit()
        ret = cur.lastrowid
        return ret

redis使用

安装好了redis和相关的py插件，就能在sanic中轻松使用了。

get值

async with app.redis_pool.get() as redis:
    response = await redis.get(key)

set值，并设置timeout

async with app.redis_pool.get() as redis:
    await redis.setex(key, timeout, response_cached)

还有一些其它的高级用法，请查看aioredis的文档吧。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2017-07-17 ，如有侵权请联系 cloudcommunity@tencent.com 删除

云数据库 Redis

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度