pipeline.src.flows.missing_trip_numbers

Functions

reset_computed_trip_numbers()

extract_computed_trip_numbers(→ pandas.DataFrame)

Extract a computed trip_number for ERS messages of type 'DAT' that do not have a

load_computed_trip_numbers(computed_trip_numbers)

Updates the logbook_reports table. Computed trip numbers are added to the trip_number

missing_trip_numbers_flow([reset_trip_numbers])

Module Contents

pipeline.src.flows.missing_trip_numbers.reset_computed_trip_numbers()[source]
pipeline.src.flows.missing_trip_numbers.extract_computed_trip_numbers() → pandas.DataFrame[source]

Extract a computed trip_number for ERS messages of type ‘DAT’ that do not have a trip number.

For each vessel and each year, a new trip is detected when a DEP or a LAN message occurs.

Returns:

Dataframe of computed trip numbers with id and

trip_number columns

Return type:

pd.DataFrame

pipeline.src.flows.missing_trip_numbers.load_computed_trip_numbers(computed_trip_numbers: pandas.DataFrame)[source]

Updates the logbook_reports table. Computed trip numbers are added to the trip_number column of the table.

Parameters:

computed_trip_numbers (pd.DataFrame) – output of extract_computed_trip_numbers. Dataframe of computed trip numbers with id and trip_number columns

pipeline.src.flows.missing_trip_numbers.missing_trip_numbers_flow(reset_trip_numbers: bool = False)[source]