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-02-23 09:51:32 +08:00
parent a7b15568aa
commit 23044f1338
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
influxdb_api.py
View File

@@ -2147,7 +2147,7 @@ if __name__ == "__main__":
# store_non_realtime_SCADA_data_to_influxdb(get_history_data_end_time='2025-02-08T12:00:00+08:00')
# step3: 查询测试示例
with InfluxDBClient(url=url, token=token, org=org_name) as client:
with InfluxDBClient(url=url, token=token, org=org_name, timeout=1000*10000) as client:
# # 示例1：query_latest_record_by_ID
# bucket_name = "realtime_simulation_result" # 数据存储的 bucket 名称
@@ -2208,8 +2208,11 @@ if __name__ == "__main__":
# print("Link 数据：", link_records)
# 示例13：query_scheme_all_record
node_records, link_records = query_scheme_all_record(scheme_Type='burst_Analysis', scheme_Name='scheme1')
print("Node 数据：", node_records)
print("Link 数据：", link_records)
# node_records, link_records = query_scheme_all_record(scheme_Type='burst_Analysis', scheme_Name='scheme1')
# print("Node 数据：", node_records)
# print("Link 数据：", link_records)
results = query_all_record_by_date('2025-=02-12')
print(results)