123456789101112131415161718192021222324252627282930313233 |
- 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()
|