pipeline.src.flows.beacons

Functions

extract_beacons(→ pandas.DataFrame)	Extract beacon numbers of all vessels from Poseidon.
extract_satellite_operators()
transform_beacons(→ pandas.DataFrame)	Maps Posedion beacon status to Monitorfish BeaconStatus and maps the
transform_satellite_operators(→ pandas.DataFrame)
load_beacons(beacons)
load_satellite_operators(satellite_operators)
beacons_flow()

Module Contents

pipeline.src.flows.beacons.extract_beacons() → pandas.DataFrame

Extract beacon numbers of all vessels from Poseidon.

pipeline.src.flows.beacons.extract_satellite_operators()

pipeline.src.flows.beacons.transform_beacons(beacons: pandas.DataFrame) → pandas.DataFrame

Maps Posedion beacon status to Monitorfish BeaconStatus and maps the 1, 0 and np.nan values in is_coastal to True, False and None respectively.

Parameters:

beacons (pd.DataFrame) – DataFrame of beacons extracted from Poseidon

Returns:

beacons with status mapped to BeaconStatus and is_coastal

mapped to True, False and None.

Return type:

pd.DataFrame

pipeline.src.flows.beacons.transform_satellite_operators(satellite_operators: pandas.DataFrame) → pandas.DataFrame

pipeline.src.flows.beacons.load_beacons(beacons)

pipeline.src.flows.beacons.load_satellite_operators(satellite_operators)

pipeline.src.flows.beacons.beacons_flow()