Module pipelines.rj_rioaguas.saneamento_drenagem.nivel_lamina_agua.tasks

Tasks para pipeline de dados de nível de lâmina de água em via.

Functions

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

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(dados: pandas.core.frame.DataFrame, dataset_id: str, table_id: str, mode: str = 'prod') ‑> pandas.core.frame.DataFrame

Tratar dados para o padrão estabelecido e filtrar linhas para salvarmos apenas as medições que foram contratadas pela prefeitura.