OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refine

Browse Source
This commit is contained in:
DingZQ
2025-04-19 17:48:57 +08:00
parent 7dca6685d1
commit 34d915404f
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
influxdb_api.py
View File

@@ -3324,6 +3324,7 @@ def upload_cleaned_SCADA_data_to_influxdb(file_path: str, bucket: str="SCADA_dat
write_api = client.write_api(write_options=SYNCHRONOUS) write_api = client.write_api(write_options=SYNCHRONOUS)
# 写入数据 # 写入数据
for data in data_list: for data in data_list:
print(data)
# 创建Point对象 # 创建Point对象
point = ( point = (
Point(data['measurement']) # measurement为mpointName Point(data['measurement']) # measurement为mpointName