pipeline.src.flows.vessel_profiles
==================================

.. py:module:: pipeline.src.flows.vessel_profiles


Functions
---------

.. autoapisummary::

   pipeline.src.flows.vessel_profiles.extract_profiles
   pipeline.src.flows.vessel_profiles.extract_port_profiles
   pipeline.src.flows.vessel_profiles.extract_latest_port_profiles
   pipeline.src.flows.vessel_profiles.extract_ports_facade
   pipeline.src.flows.vessel_profiles.extract_gear_onboard
   pipeline.src.flows.vessel_profiles.add_latest_port_facade
   pipeline.src.flows.vessel_profiles.transform_profiles
   pipeline.src.flows.vessel_profiles.transform_gear_onboard
   pipeline.src.flows.vessel_profiles.merge_vessel_profiles
   pipeline.src.flows.vessel_profiles.load_vessel_profiles
   pipeline.src.flows.vessel_profiles.vessel_profiles_flow


Module Contents
---------------

.. py:function:: extract_profiles(profile_datetime_utc: datetime.datetime, profile_dimension: str, profile_type: str) -> pandas.DataFrame

.. py:function:: extract_port_profiles(profile_datetime_utc: datetime.datetime, profile_type: str) -> pandas.DataFrame

.. py:function:: extract_latest_port_profiles(profile_datetime_utc: datetime.datetime) -> pandas.DataFrame

.. py:function:: extract_ports_facade() -> dict

.. py:function:: extract_gear_onboard(profile_datetime_utc: datetime.datetime, profile_type: str) -> pandas.DataFrame

.. py:function:: add_latest_port_facade(latest_port_profiles: pandas.DataFrame, ports_facade: dict) -> pandas.DataFrame

.. py:function:: transform_profiles(profiles: pandas.DataFrame, profile_dimension: str, profile_type: str)

.. py:function:: transform_gear_onboard(gear_onboard: pandas.DataFrame, profile_type: str) -> pandas.DataFrame

.. py:function:: 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

.. py:function:: load_vessel_profiles(vessel_profiles: pandas.DataFrame)

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

   :param vessel_profiles: vessel profiles data to load
   :type vessel_profiles: pd.DataFrame


.. py:function:: vessel_profiles_flow(get_utcnow_fn=get_utcnow)