得到flask import 瓶
得到flask import 请求,响应
app =,瓶(__name__)
import 操作系统
def getApolloconf (k):
,,,import 请求
,,,env =, os.environ.get (“RUNTIME_ENV"),或是“dev"
,,,getApolloconfig =, requests.get (
,,,,,,,& # 39;http://configserver- {env} .chj.cloud/配置/op-bmc-api/默认应用程序# 39;.format (env=env))
,,,data =, getApolloconfig.json () (“configurations")
,,,return data.get (k)
# # # # # # #获取配置插入数据库# # # # # # # # #
def mysqlConfig (sql):
,,,import pymysql
,,,import json
,,,USERNAME =, getApolloconf (“USERNAME")
,,,PASSWORD =, getApolloconf (“PASSWORD")
,,,HOST =, getApolloconf (“HOST")
,,,DATABASE =, getApolloconf (“NGINXDATABASE")
,,,dbconfig =, pymysql.connect(主机,用户名,密码,,数据库)
,,,试一试:
,,,,,,,cursor =, dbconfig.cursor ()
,,,,,,,试一试:
,,,,,,,,,,,cursor.execute (sql)
,,,,,,,,,,,results =, cursor.fetchall ()
,,,,,,,,,,,reultData=https://www.yisu.com/zixun/[]
columnList=[“run_type”、“upstreamname”,“front_listen”、“domain_name”、“backend_ip”)
一行的结果:
reultData。追加(dict (zip (columnList、列表(行))))
str1=(json。转储(reultData ensure_ascii=False))
返回str1
除了例外e:
通过
除了例外犯错:
打印(err)
def nginxtbale ():
试一试:
sql="选择run_type、upstreamname front_listen, domain_name, backend_ip nginxManager_dj_nginx_conf order by create_time”
返回mysqlConfig (sql)
除了例外e:
#如果发生错误则回滚
打印(e)
@app.route (“/?
def指数():
进口json
返回响应(json.dumps (nginxtbale ()), mimetype=癮pplication/json”)
if __name__==癬_main__”:
app.run (
主机=" 192.168.1.1”,
端口=8008,
debug=True
)
