Description
Logique :
-
Récupération des nouvelles positions pour chaque
vessel_id
en se basant surposition_update_timestamp
(spire_ais_data.position_update_timestamp
>position_updates.point_in_time
) (point_in_time
dans nouvelle table à créerposition_updates
[BACKEND] Création tables position_updates : suivre la mise à jour des positions AIS par MMSI #426 ) -
Sélectionner les variables suivantes :
spire_update_timestamp
,accuracy
,collection_type
,vessel_mmsi
,position_course
,position_heading
,position_latitude
,position_longitude
,maneuver
,navigational_status
,position_rot
,position_speed
,position_timestamp
-
Filtrer les lignes dupliquées => batch
-
Sauver les lignes uniques dans
vessel_positions
:timestamp
,accuracy
,course
,heading
,position
,latitude
,longitude
,maneuver
,navigational_status
,rot
,speed
,vessel_id
,created_at
-
Pour chaque
vessel_id
, mettre à jourpoint_in_time
dans la tableposition_updates
(maxbatch.position_update_timestamp
parvessel_id
)