diff --git a/influxdb_api.py b/influxdb_api.py index 853db97..be01eb9 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1378,6 +1378,8 @@ def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_r for record in table.records: # print(record.values) # 打印完整记录内容 measurement = record["_measurement"] + print(measurement) + # 处理 node 数据 if measurement == "node": node_records.append({