mysqlxa序列化_MYSQL的数据序列化Api接口详情

MYSQL 的数据序列化Api接口详情

发布时间&＃xff1a;2020-04-29 17:02:59

来源&＃xff1a;亿速云

阅读&＃xff1a;158

作者&＃xff1a;三月

本文主要给大家介绍MYSQL 的数据序列化Api接口详情&＃xff0c;文章内容都是笔者用心摘选和编辑的&＃xff0c;MYSQL 的数据序列化Api接口详情具有一定的针对性&＃xff0c;对大家的参考意义还是比较大的&＃xff0c;下面跟笔者一起了解下主题内容吧。

from flask import Flask

from flask import request, Response

app &＃61; Flask(__name__)

import os

def getApolloconf(k):

import requests

env &＃61; os.environ.get("RUNTIME_ENV") or "dev"

getApolloconfig &＃61; requests.get(

&＃39;http://configserver-{env}.chj.cloud/configs/op-bmc-api/default/application&＃39;.format(env&＃61;env))

data &＃61; getApolloconfig.json()["configurations"]

return data.get(k)

#######获取配置插入数据库#########

def mysqlConfig(sql):

import pymysql

import json

USERNAME &＃61; getApolloconf("USERNAME")

PASSWORD &＃61; getApolloconf("PASSWORD")

HOST &＃61; getApolloconf("HOST")

DATABASE &＃61; getApolloconf("NGINXDATABASE")

dbconfig &＃61; pymysql.connect(HOST, USERNAME, PASSWORD, DATABASE)

try:

cursor &＃61; dbconfig.cursor()

try:

cursor.execute(sql)

results &＃61; cursor.fetchall()

reultData&＃61;[]

columnList&＃61;["run_type","upstreamname","front_listen","domain_name","backend_ip"]

for row in results:

reultData.append(dict(zip(columnList, list(row))))

str1&＃61;(json.dumps(reultData, ensure_ascii&＃61;False))

return str1

except Exception as e:

pass

except Exception as err:

print(err)

def nginxtbale():

try:

sql &＃61; "select run_type,upstreamname,front_listen,domain_name,backend_ip from  nginxManager_dj_nginx_conf order by create_time"

return mysqlConfig(sql)

except Exception as e:

# 如果发生错误则回滚

print(e)

&＃64;app.route(&＃39;/&＃39;)

def index():

import json

return Response(json.dumps(nginxtbale()), mimetype&＃61;&＃39;application/json&＃39;)

if __name__ &＃61;&＃61; &＃39;__main__&＃39;:

app.run(

host&＃61;"192.168.1.1",

port&＃61;8008,

debug&＃61;True

)

看完以上关于MYSQL 的数据序列化Api接口详情&＃xff0c;很多读者朋友肯定多少有一定的了解&＃xff0c;如需获取更多的行业知识信息 &＃xff0c;可以持续关注我们的行业资讯栏目的。