diff --git a/ingest_events_rev.py b/ingest_events_rev.py index 6d64de7..c444f20 100644 --- a/ingest_events_rev.py +++ b/ingest_events_rev.py @@ -57,7 +57,7 @@ def poll_alarms(): "page_size": 100 }, token) - alarms = resp.get("result", []) + alarms = resp.get("result") or [] if not alarms: continue with get_conn() as conn: diff --git a/ingest_movement_rev.py b/ingest_movement_rev.py index 36b6828..882e6b0 100644 --- a/ingest_movement_rev.py +++ b/ingest_movement_rev.py @@ -50,7 +50,7 @@ def sync_devices(): resp = api_post("jimi.user.device.list", {"target": TARGET_ACCOUNT}, token) if resp.get("code") != 0: return - devices = resp.get("result", []) + devices = resp.get("result") or [] upserted = 0 with get_conn() as conn: @@ -60,7 +60,7 @@ def sync_devices(): if not imei: continue detail_resp = api_post("jimi.track.device.detail", {"imei": imei}, token) - dtl = detail_resp.get("result", {}) if detail_resp.get("code") == 0 else {} + dtl = detail_resp.get("result") or {} if detail_resp.get("code") == 0 else {} cur.execute(""" INSERT INTO tracksolid.devices ( @@ -106,7 +106,7 @@ def poll_live_positions(): resp = api_post("jimi.user.device.location.list", {"target": TARGET_ACCOUNT, "map_type": "GOOGLE"}, token) if resp.get("code") != 0: return - positions = resp.get("result", []) + positions = resp.get("result") or [] upserted, inserted = 0, 0 with get_conn() as conn: @@ -170,7 +170,7 @@ def poll_trips(): "end_time": end_ts.strftime("%Y-%m-%d %H:%M:%S") }, token) - trips = resp.get("result", []) + trips = resp.get("result") or [] with get_conn() as conn: with conn.cursor() as cur: for t in trips: @@ -214,7 +214,7 @@ def poll_parking(): "end_time": end_ts.strftime("%Y-%m-%d %H:%M:%S"), }, token) - events = resp.get("result", []) + events = resp.get("result") or [] with get_conn() as conn: with conn.cursor() as cur: for p in events: