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

Update cleaned data

Browse Source
This commit is contained in:
DingZQ
2025-05-05 17:31:43 +08:00
parent cca3363bda
commit 24226123d6
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
influxdb_api.py
View File

@@ -3507,9 +3507,9 @@ if __name__ == "__main__":
# step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里
query_pg_scada_info_realtime('bb')
query_pg_scada_info_non_realtime('bb')
query_corresponding_query_id_and_element_id('bb')
# query_pg_scada_info_realtime('bb')
# query_pg_scada_info_non_realtime('bb')
# query_corresponding_query_id_and_element_id('bb')
# 手动执行存储测试
@@ -3521,7 +3521,7 @@ if __name__ == "__main__":
# 示例3：download_history_data_manually
# download_history_data_manually(begin_time='2025-04-16T00:00:00+08:00', end_time='2025-04-16T23:59:00+08:00')
download_history_data_manually(begin_time='2025-05-04T00:00:00+08:00', end_time='2025-05-04T23:59:00+08:00')
# download_history_data_manually(begin_time='2025-05-04T00:00:00+08:00', end_time='2025-05-04T23:59:00+08:00')
# step3: 查询测试示例
@@ -3618,7 +3618,7 @@ if __name__ == "__main__":
# print(leakage)
# 示例：upload_cleaned_SCADA_data_to_influxdb
# upload_cleaned_SCADA_data_to_influxdb(file_path='./标准cleaned_demand_data.csv')
upload_cleaned_SCADA_data_to_influxdb(file_path='./标准cleaned_demand_data.csv')
# 示例：query_cleaned_SCADA_data_by_device_ID_and_timerange
# result = query_cleaned_SCADA_data_by_device_ID_and_timerange(query_ids_list=['9485'], start_time='2024-03-24T00:00:00+08:00',