Module pipelines.rj_escritorio.waze.tasks

Tasks for emd

Functions

def fecth_waze(areas: pandas.core.frame.DataFrame, wait=None) ‑> list

Fetch data from waze.

def load_geometries(wait=None) ‑> pandas.core.frame.DataFrame

Loads the geometries from the database.

def normalize_data(responses: list, wait=None) ‑> pandas.core.frame.DataFrame

Normalize data.

def upload_to_native_table(dataset_id: str, table_id: str, dataframe: pandas.core.frame.DataFrame, wait=None) ‑> None

Upload data to native table.