feat: create last position flow from ais positions

Author: maximeperraultdev

backend/src/main/resources/db/migration/internal/V0.199__create_last_position_table.sql

@@ -1,11 +1,12 @@
 CREATE TABLE public.last_positions
 (
-    id      SERIAL,
-    mmsi    INT,
-    coord   geometry,
-    status  VARCHAR,
-    course  DOUBLE PRECISION,
-    heading DOUBLE PRECISION,
-    speed   DOUBLE PRECISION,
-    ts      TIMESTAMPTZ
+    id        SERIAL,
+    mmsi      INT,
+    vessel_id INT,
+    coord     GEOMETRY,
+    status    VARCHAR,
+    course    DOUBLE PRECISION,
+    heading   DOUBLE PRECISION,
+    speed     DOUBLE PRECISION,
+    ts        TIMESTAMPTZ
 );

pipeline/config.py

@@ -123,4 +123,4 @@
 
 # Vessel repository XML
 VESSEL_FILES_GID = os.getenv("VESSEL_FILES_GID")
-VESSEL_FILES_DIRECTORY = "/data/vessel_repository"
+VESSEL_FILES_DIRECTORY = "/data/vessel_repository"

pipeline/src/deployments.py

@@ -45,6 +45,7 @@
     update_departments_and_facades_flow,
 )
 from src.flows.vessel_repository import vessel_repository_flow
+from src.flows.last_positions import last_positions_flow
 
 ################################# List flows to deploy ################################
 
@@ -132,6 +133,7 @@ class FlowAndSchedules:
     ),
     FlowAndSchedules(flow=update_departments_and_facades_flow),
     FlowAndSchedules(flow=vessel_repository_flow),
+    FlowAndSchedules(flow=last_positions_flow),
 ]
 
 deployments = []