import json from MyUtils.ConfigUtils import ConfigUtils import datetime,pymysql import requests SELECT_SQL="select * from `%s`.saas_employee" datetimenow = datetime.datetime.now().strftime("%Y-%m-%d %H:%M") config = ConfigUtils("config.xml") mysql = config.readTopDict("mysql", ["host", "port", "user", "passwd", "database"]) mysql["port"] = int(mysql["port"]) database = mysql["database"] url = config.readTop("config",["url"])[0] #连接mysql conn = pymysql.connect(**mysql) mysql_cur = conn.cursor() mysql_cur.execute(SELECT_SQL % (database)) #获取列名 column_list = [] column = mysql_cur.description for i in column: column_list.append(i[0]) datas = mysql_cur.fetchall() lst = [] for line in datas: lst.append(dict(zip(column_list,list(line)))) for i in range(0,len(lst),100): dataranges = lst[i:i + 100] data_json = json.dumps(dataranges) r = requests.post(url=url,headers={'Content-Type': 'application/json;charset=UTF-8'},data=data_json) print(r.text) mysql_cur.close() conn.close()