接上文数据库审核接口SQLE的探索使用，本次自定义接口进行调用，实现需求。
1、创建自定义审核接口
因直接调用SQLE的审核接口，会出现token过期，且审核及结果查询接口是分开的，因此，出于以上2个原因的考虑，重新编写一个接口用于调用SQLE的审核接口并返回审核结果。参考代码如下：
# coding=utf-8import requestsfrom flask import requestimport jsonfrom flask import Flaskapp = Flask(__name__)@app.route('/audit_task', methods=['post','get'])def audit_task():get_data = request.args.to_dict()v_instance = get_data.get('instance')v_schema = get_data.get('schema')v_sql = get_data.get('sql')v_token = get_token()v_headers = {'Authorization': f"{v_token}"}#print(v_headers)url = 'http://127.0.0.1:10000/v1/tasks/audits'v_data_a = {'instance_name':v_instance,'instance_schema':v_schema,'sql':v_sql}#print(v_data_a)res = requests.post(url, data=v_data_a, headers=v_headers)v_taskid=res.json()['data']['task_id']url2='http://127.0.0.1:10000/v1/tasks/audits/'+str(v_taskid)+'{/sqls?page_index=1&page_size=10&no_duplicate=false'# print(url2)res2 = requests.get(url2, headers=v_headers)audit_result = res2.json()['data'][0]['audit_result']if not(audit_result):audit_result=f'审核通过'return audit_resultdef get_token():url = 'http://127.0.0.1:10000/v1/login'data = {"username": "admin", "password": "xxxx"}# res = requests.post(url, json=data)h = {'Content-Type': 'application/json; charset=UTF-8'}res = requests.post(url, data=json.dumps(data), headers=h)t = json.loads(res.text)#print(type(json.loads(res.text)))token = t['data']['token']#print(t['data']['token'])return tokenif __name__ == '__main__':app.run(host='0.0.0.0',port=5000, debug=True)
注：使用时，需提前在SQLE中配置好实例信息。SQLE部署方式及简单配置可参考
2. 调用测试
运行以上接口，并使用postman调用进行测试
输入参数名特地调整了一下，以便于区别，测试情况如下
调用结果如下：
[]除了自增列及大字段列之外，每个列都必须添加默认值[]表必须有主键[]新建表必须加入if not exists create，保证重复执行不报错
2. mysql8.0新增用户及加密规则修改的那些事
3. 比hive快10倍的大数据查询利器-- presto
4. 监控利器出鞘：Prometheus+Grafana监控MySQL、Redis数据库
5. PostgreSQL主从复制--物理复制
6. MySQL传统点位复制在线转为GTID模式复制
原文作者：数据库干货铺；如有侵权，请联系管理员删除。
上一篇：
MySQL如何查看未提交的事务SQL
下一篇：
数据库审核工具SQLE部署及使用
请登录后发表评论
登录
全部评论
