- added info.is_delta to indicate delta record. First record has is_delat=False

- fixed eval_records to care for delta records
This commit is contained in:
2024-10-18 22:25:38 +02:00
parent b1b9a7d385
commit ffd1451024
2 changed files with 10 additions and 2 deletions
+1 -1
View File
@@ -80,7 +80,7 @@ def main():
vehicle_data_last = vehicle_data vehicle_data_last = vehicle_data
# Put vehicle data difference onto record list # Put vehicle data difference onto record list
record_list.append({'info': {'record_id': record_id, 'timestamp': timestamp}, 'data': vehicle_data_diff}) record_list.append({'info': {'record_id': record_id, 'timestamp': timestamp, 'is_delta': (record_id > 0)}, 'data': vehicle_data_diff})
# Store record list # Store record list
print(f"{timestamp}: Store record #{record_id:04d}") print(f"{timestamp}: Store record #{record_id:04d}")
+9 -1
View File
@@ -1,12 +1,13 @@
import json import json
import os import os
from datetime import datetime from datetime import datetime
from deep_diff import deep_merge
BASE = "results" BASE = "results"
VIN = 'WVWZZZE1ZMP010760' VIN = 'WVWZZZE1ZMP010760'
YEAR = 2024 YEAR = 2024
MONTH = 10 MONTH = 10
DAY = "18" DAY = ['18']
class Endpoint: class Endpoint:
@@ -113,6 +114,13 @@ for day in day_list:
with open(file_path, "r") as fp: with open(file_path, "r") as fp:
records = json.load(fp) records = json.load(fp)
for record in records: for record in records:
try:
if record['info']['is_delta']:
record = deep_merge(last, record['data'])
except KeyError:
pass
last = record
try: try:
for end_point in end_points: for end_point in end_points:
end_point.assign(record) end_point.assign(record)