diff --git a/influxdb_api.py b/influxdb_api.py index 553da9a..4b49cc5 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1946,7 +1946,7 @@ def query_all_records_by_date_with_type(query_date: str, query_type: str, bucket elif measurement == "link": result_records.append({ "time": record["_time"], - "linkID": record["ID"], + "ID": record["ID"], "flow": record["flow"], "velocity": record["velocity"], "headloss": record["headloss"],