Module pipelines.rj_rioaguas.saneamento_drenagem.nivel_lagoa.tasks

Tasks para pipeline de dados de nível da Lagoa Rodrigo de Freitas. Fonte: Squitter.

Functions

def download_file(download_url)

Função para download de tabela com os dados.

Args: download_url (str): URL onde a tabela está localizada.

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

Salvar dados em csv.

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

Tratar dados para o padrão estabelecido.