Module pipelines.utils.georeference.tasks

Tasks for georeferencing tables

Functions

def dataframe_to_csv(dataframe: pandas.core.frame.DataFrame, filename: str = 'data.csv') ‑> None

Save dataframe to csv

def georeference_dataframe(new_addresses: pandas.core.frame.DataFrame, log_divider: int = 60) ‑> pandas.core.frame.DataFrame

Georeference all addresses in a dataframe

def get_new_addresses(source_dataset_id: str, source_table_id: str, source_table_address_column: str, destination_dataset_id: str, destination_table_id: str, georef_mode: str, current_flow_labels: List[str]) ‑> Tuple[pandas.core.frame.DataFrame, bool]

Get new addresses from source table

def validate_georeference_mode(mode: str) ‑> None

Validates georeference mode