diff --git a/influxdb_api.py b/influxdb_api.py index 7714e43..edb4aa9 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1186,8 +1186,9 @@ def query_all_record_by_time(query_time: str, bucket: str="realtime_simulation_r # 将北京时间转换为 UTC 时间 beijing_time = datetime.fromisoformat(query_time) utc_time = beijing_time.astimezone(timezone.utc) - utc_start_time = utc_time - timedelta(seconds=1) - utc_stop_time = utc_time + timedelta(seconds=1) + # DingZQ, 2025-02-10, set delta time to 15, original is 1 + utc_start_time = utc_time - timedelta(seconds=15) + utc_stop_time = utc_time + timedelta(seconds=15) # 构建 Flux 查询语句 flux_query = f''' @@ -1336,7 +1337,7 @@ if __name__ == "__main__": # latest_record = query_latest_record_by_ID(ID=node_id, type="node", bucket=bucket_name, client=client) # latest_record = query_latest_record_by_ID(ID=link_id, type="link", bucket=bucket_name, client=client) - latest_record = query_all_record_by_time('2025-02-09T17:30:00+08:00') + all_records = query_all_record_by_time('2025-02-09T17:30:00+08:00') if latest_record: print("最新记录:", latest_record)