Skip to content

segments_excursions_creation.md

Latest commit

 

History

History
59 lines (50 loc) · 2.94 KB

segments_excursions_creation.md

File metadata and controls

59 lines (50 loc) · 2.94 KB

Logique de traitement des positions pour la création des segments, des excursions et calcul des métriques

ATTENTION : dans cette logique, on ne prend pas en compte un recalcul des excursions sur la base de dim_vessel_source_mapping. À modifier par la suite en se basant sur #428

Périodicité

  • À chaque call API (toutes les 15 min)
  • pour recalcul des trajectoires :
    • par vessel_id
    • par batch temporel

Description du processus

Etape 1 : association des positions aux excursions

Positions créées après task_executions.point_in_time

graph LR;
    ISTART[START<br>**PROCESS <br>NEW VESSEL POSITION**]-->I000
    I000[New vessel position  <br>stg_vessel_position]-->I001{If stg_vessel_position  <br>in port}
    I001-->|Yes|I002{If last excursion  <br>is closed}
    I002-->|Yes|I004[Update <br>last_vessel_position_in_port]
    I002-->|No|I005[Update <br>last excursion]
    I001-->|No|I006{If last excursion  <br>is closed}
    I007[Associate excursion id <br>to stg_vessel_position]
    I005-->I007
    I006-->|No|I007
    I006-->|Yes|I008[Create new excursion]-->I010[Associate  <br>excursion id <br> to last_vessel_position_in_port]-->I009[Add <br>last_vessel_position_in_port <br>to batch stg_vessel_positions]-->I007
    I007-->I011[Add stg_vessel_position <br>to batch stg_vessel_positions]
Loading

Etape 2 : création des segments et mise à jour des excursions

Propriétés d'un segment à calculer : distance, duration, average_speed, in_amp_zone, in_zone_with_no_fishing_rights, in_territorial_waters

ATTENTION : les règles de pêche dans une zone sont dépendantes du pavillon du navire. Toutefois, un navire peut changer de pavillon. Ses droits de pêche par zone sont donc ancrés dans le temps. Pour l'instant, nous utilisons le dim_vessel.country_iso3 mais il faudra réflechir à changer d'angle pour garder en mémoire à quels pays appartenait un navire et quand (proposition dans #428)

graph TD;
    ISTART[START<br>**PROCESS <br>BATCH VESSEL POSITIONS**]-->I000
    I000[New vessel positions <br>stg_vessel_positions]-->I002
    I001[Add end position of <br>last vessel segments]-->I002
    I002[Batch vessel positions]
    I002-->I016[Sort positions <br>by increasing timestamp <br>and vessel_id]
    I016-->I003[Group stg_vessel_positions  <br>by excursion id]
    I003-->I004[For each group]
    I004-->I005{If size group > 1}
    I005-->|Yes|I006[Convert to segments]
    I005-->|No|I007[Duplicate position  <br>with lag -1s]-->I006
    I006-->I008[Concatenate segments]
    I008-->I014[Compute segments <br>variables]
    I014-->I009[Create segments and <br>segment-zone relations]
    I009-->I013[Calculate metrics*]
    I013-->I010[Update last segments]
    I010-->I011[Update excursions]
    I011-->I015[Update task_executions]
Loading

*processus indépendant de la création des segments et des excursions