Skip to content

[BACKEND] Reprendre tâche clean_positions #425

Open
@marthevienne

Description

@marthevienne

Logique :

  1. Récupération des nouvelles positions pour chaque vessel_id en se basant sur position_update_timestamp (spire_ais_data.position_update_timestamp > position_updates.point_in_time) (point_in_time dans nouvelle table à créer position_updates [BACKEND] Création tables position_updates : suivre la mise à jour des positions AIS par MMSI #426 )

  2. 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

  3. Filtrer les lignes dupliquées => batch

  4. Sauver les lignes uniques dans vessel_positions : timestamp, accuracy, course, heading, position, latitude, longitude, maneuver, navigational_status, rot, speed, vessel_id, created_at

  5. Pour chaque vessel_id, mettre à jour point_in_time dans la table position_updates (max batch.position_update_timestamp par vessel_id)

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions