pipeline.src.flows.controls_open_data
=====================================

.. py:module:: pipeline.src.flows.controls_open_data


Functions
---------

.. autoapisummary::

   pipeline.src.flows.controls_open_data.extract_controls_open_data
   pipeline.src.flows.controls_open_data.extract_fleet_segments_open_data
   pipeline.src.flows.controls_open_data.transform_controls_open_data
   pipeline.src.flows.controls_open_data.transform_fleet_segments_open_data
   pipeline.src.flows.controls_open_data.controls_open_data_flow


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

.. py:function:: extract_controls_open_data() -> pandas.DataFrame

.. py:function:: extract_fleet_segments_open_data() -> pandas.DataFrame

.. py:function:: transform_controls_open_data(controls) -> pandas.DataFrame

.. py:function:: transform_fleet_segments_open_data(fleet_segments) -> pandas.DataFrame

.. py:function:: controls_open_data_flow(dataset_id: str = CONTROLS_STATISTICS_DATASET_ID, controls_resource_id: str = CONTROLS_STATISTICS_CSV_RESOURCE_ID, controls_resource_title: str = CONTROLS_STATISTICS_CSV_RESOURCE_TITLE, fleet_segments_resource_id: str = FLEET_SEGMENTS_CSV_RESOURCE_ID, fleet_segments_resource_title: str = FLEET_SEGMENTS_CSV_RESOURCE_TITLE, is_integration: bool = IS_INTEGRATION)