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-03-09 22:43:24 +08:00
parent 43db502aa0
commit b42fa6c551
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
influxdb_api.py
View File

@@ -2724,8 +2724,8 @@ if __name__ == "__main__":
# client.close() # client.close()
# step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里 # step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里
query_pg_scada_info_realtime('bb') # query_pg_scada_info_realtime('bb')
query_pg_scada_info_non_realtime('bb') # query_pg_scada_info_non_realtime('bb')
# 手动执行存储测试 # 手动执行存储测试
# 示例1：store_realtime_SCADA_data_to_influxdb # 示例1：store_realtime_SCADA_data_to_influxdb
@@ -2764,8 +2764,8 @@ if __name__ == "__main__":
# print(curve_result) # print(curve_result)
# 示例4：query_SCADA_data_by_device_ID_and_time # 示例4：query_SCADA_data_by_device_ID_and_time
# SCADA_result_dict = query_SCADA_data_by_device_ID_and_time(globals.variable_pump_realtime_ids, query_time='2025-02-25T23:45:00+08:00') SCADA_result_dict = query_SCADA_data_by_device_ID_and_time(globals.fixed_pump_realtime_ids, query_time='2025-03-08T23:45:00+08:00')
# print(SCADA_result_dict) print(SCADA_result_dict)
# 示例5：query_SCADA_data_curve # 示例5：query_SCADA_data_curve
# SCADA_result = query_SCADA_data_curve(api_query_id='3853', start_date='2025-02-14', end_date='2025-02-16') # SCADA_result = query_SCADA_data_curve(api_query_id='3853', start_date='2025-02-14', end_date='2025-02-16')