Module pipelines.rj_cor.meteorologia.precipitacao_websirene.tasks

Tasks for precipitacao_alertario

Functions

def download_dados() ‑> pandas.core.frame.DataFrame

Faz o request e salva em um dataframe

def salvar_dados(dfr: pandas.core.frame.DataFrame) ‑> Union[str, pathlib.Path]

Salvar dados tratados em csv para conseguir subir pro GCP

def tratar_dados(dfr: pandas.core.frame.DataFrame, dataset_id: str, table_id: str, mode: str = 'dev') ‑> Tuple[pandas.core.frame.DataFrame, bool]

Faz o request e salva dados localmente