start.py 1019 B

123456789101112131415161718192021222324252627282930313233
  1. import json
  2. from MyUtils.ConfigUtils import ConfigUtils
  3. import datetime,pymysql
  4. import requests
  5. SELECT_SQL="select * from `%s`.saas_employee"
  6. datetimenow = datetime.datetime.now().strftime("%Y-%m-%d %H:%M")
  7. config = ConfigUtils("config.xml")
  8. mysql = config.readTopDict("mysql", ["host", "port", "user", "passwd", "database"])
  9. mysql["port"] = int(mysql["port"])
  10. database = mysql["database"]
  11. url = config.readTop("config",["url"])[0]
  12. #连接mysql
  13. conn = pymysql.connect(**mysql)
  14. mysql_cur = conn.cursor()
  15. mysql_cur.execute(SELECT_SQL % (database))
  16. #获取列名
  17. column_list = []
  18. column = mysql_cur.description
  19. for i in column:
  20. column_list.append(i[0])
  21. datas = mysql_cur.fetchall()
  22. lst = []
  23. for line in datas:
  24. lst.append(dict(zip(column_list,list(line))))
  25. for i in range(0,len(lst),100):
  26. dataranges = lst[i:i + 100]
  27. data_json = json.dumps(dataranges)
  28. r = requests.post(url=url,headers={'Content-Type': 'application/json;charset=UTF-8'},data=data_json)
  29. print(r.text)
  30. mysql_cur.close()
  31. conn.close()