pipeline.src.flows.controls_open_data

Functions

extract_controls_open_data(→ pandas.DataFrame)
extract_fleet_segments_open_data(→ pandas.DataFrame)
transform_controls_open_data(→ pandas.DataFrame)
transform_fleet_segments_open_data(→ pandas.DataFrame)
controls_open_data_flow([dataset_id, ...])

Module Contents

pipeline.src.flows.controls_open_data.extract_controls_open_data() → pandas.DataFrame

pipeline.src.flows.controls_open_data.extract_fleet_segments_open_data() → pandas.DataFrame

pipeline.src.flows.controls_open_data.transform_controls_open_data(controls) → pandas.DataFrame

pipeline.src.flows.controls_open_data.transform_fleet_segments_open_data(fleet_segments) → pandas.DataFrame

pipeline.src.flows.controls_open_data.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)