1、从sql读取需要的内容,作为接口的请求参数的一部分,生成请求的body,再去请求接口
1 import requests 2 import pymysql 3 import json 4 5 6 conn = pymysql.connect(host="172.16.11.118", port=3306, user="root", passwd="123456", db="digital_energy_base") 7 cur = conn.cursor(cursor=pymysql.cursors.DictCursor) 8 9 10 sql="select * from t_bus_col_point where base=1" 11 cur.execute(sql) 12 points=cur.fetchall() 13 14 url="http://172.16.11.118/api/collect-template" 15 headers = { 16 "Content-Type": "application/json;charset=UTF-8", 17 "Cookie": "JSESSIONID=8872E9F8CE58A9D3944D775F01F26534; SIGN=bearer d00c39c6c8b040bba333debd5d9014ee", 18 19 } 20 21 body={ 22 "name": "sf_modbus120-2", 23 "protocol": "MODBUS_TCP", 24 "remark": "", 25 "points": [ 26 27 ] 28 } 29 30 31 for index,point in enumerate(points): 32 # print(index,point) 33 body["points"].append( 34 { 35 36 "pointName": point["name"], 37 "mappingName": point["name"], 38 "remark": point["remark"], 39 "storageGranularity": "SECOND", 40 "readInterval": 10, 41 "functionCode": "03", 42 "dataAddress": f"{index*2}", 43 "dataType": "FLOAT32_BADC", 44 "calculateType": point["calculate_type"], 45 "calculateTypeName": point["calculate_type"], 46 "unit": point["unit"], 47 } 48 ) 49 requests.post(url,json=body,headers=headers)View Code
标签:body,cur,point,python,示例,接口,points,pymysql,name From: https://www.cnblogs.com/hushuer/p/18307293