python 异步连接mysql redis mqtt

Question

1.项目要求连接mysql，三个redis，以及一个mqtt
2.要实现异步连接，经度娘，有aiomysql和aioredis两个模块使用
3.用的原生的async/await
4.系统：windows10 64位 python版本：3.6
5.redis已经连接成功,但是操作总有问题，如下图

如果有做过的大神，望指点一二
(如有需要会贴代码)

Answer 1

如果是Web 我用的是 Flask+Gevent

import os
import time
import logging;

logging.basicConfig(level=logging.DEBUG)
import zzz.yyy
from flask import Flask, request, render_template,redirect,url_for,escape,session
#gevent
from gevent import monkey
from gevent.pywsgi import WSGIServer
monkey.patch_all()
#gevent end
app = Flask(__name__)
app.config['DEBUG']=True
app.secret_key=os.urandom(12)
@app.route('/asyncio',methods=['GET'])
def a():
    username = escape(session['username'])
    print(request.headers['X-Real-Ip'])
    if request.headers['X-Real-Ip'].strip():
        logging.info("IP地址:" + request.headers['X-Real-Ip'] + '的用户访问asyncio页面')
    else:
        logging.info("IP地址:" + request.remote_addr + '的用户访问asyncio页面')
    logging.info("已进入函数A")
    logging.info("进入延时")
    ccd=zzz.yyy.Person()
    console=ccd.bbb(username)
    logging.info(console)
    logging.info("延时十秒结束")
    return render_template('async.html', username=escape(session['username']))

if __name__ == '__main__':
    #app.run(host='0.0.0.0',port=8099)

    http_server=WSGIServer(('0.0.0.0',8099),app)
    logging.error('服务已启动当前为调试模式')
    

我创建了一个类叫做Person 你可以将你连接数据库的代码也创建一个实体类应该就可以