pipeline.src.flows.vessel_profiles

Functions

extract_profiles(→ pandas.DataFrame)
extract_port_profiles(→ pandas.DataFrame)
extract_latest_port_profiles(→ pandas.DataFrame)
extract_ports_facade(→ dict)
extract_gear_onboard(→ pandas.DataFrame)
add_latest_port_facade(→ pandas.DataFrame)
transform_profiles(profiles, profile_dimension, ...)
transform_gear_onboard(→ pandas.DataFrame)
merge_vessel_profiles(→ pandas.DataFrame)
load_vessel_profiles(vessel_profiles)	Replaces the content of the vessel_profiles table with the content of the
vessel_profiles_flow([get_utcnow_fn])

Module Contents

pipeline.src.flows.vessel_profiles.extract_profiles(profile_datetime_utc: datetime.datetime, profile_dimension: str, profile_type: str) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.extract_port_profiles(profile_datetime_utc: datetime.datetime, profile_type: str) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.extract_latest_port_profiles(profile_datetime_utc: datetime.datetime) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.extract_ports_facade() → dict

pipeline.src.flows.vessel_profiles.extract_gear_onboard(profile_datetime_utc: datetime.datetime, profile_type: str) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.add_latest_port_facade(latest_port_profiles: pandas.DataFrame, ports_facade: dict) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.transform_profiles(profiles: pandas.DataFrame, profile_dimension: str, profile_type: str)

pipeline.src.flows.vessel_profiles.transform_gear_onboard(gear_onboard: pandas.DataFrame, profile_type: str) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.merge_vessel_profiles(gear_profiles: pandas.DataFrame, species_profiles: pandas.DataFrame, fao_area_profiles: pandas.DataFrame, segment_profiles: pandas.DataFrame, port_profiles: pandas.DataFrame, recent_gear_profiles: pandas.DataFrame, recent_species_profiles: pandas.DataFrame, recent_fao_area_profiles: pandas.DataFrame, recent_segment_profiles: pandas.DataFrame, recent_port_profiles: pandas.DataFrame, latest_port_profiles: pandas.DataFrame, gear_onboard: pandas.DataFrame, recent_gear_onboard: pandas.DataFrame) → pandas.DataFrame

pipeline.src.flows.vessel_profiles.load_vessel_profiles(vessel_profiles: pandas.DataFrame)

Replaces the content of the vessel_profiles table with the content of the vessel_profiles DataFrame.

Parameters:

vessel_profiles (pd.DataFrame) – vessel profiles data to load

pipeline.src.flows.vessel_profiles.vessel_profiles_flow(get_utcnow_fn=get_utcnow)