代码

# -*- coding: utf-8 -*-
# @Author    : markadc

import aioredis


def get_async_rdb():
    link = "redis://localhost:6379/0"
    pool = aioredis.ConnectionPool.from_url(link, decode_responses=True)
    rdb = aioredis.Redis(connection_pool=pool)
    return rdb