Module pipelines.rj_cor.meteorologia.meteorologia_inmet.tasks

Tasks for meteorologia_inmet

Functions

def download(data_inicio: str, data_fim: str) ‑> pandas.core.frame.DataFrame

Faz o request na data especificada e retorna dados

def get_dates(data_inicio: str, data_fim: str) ‑> Tuple[str, str]

Task para obter o dia de início e o de fim. Se nenhuma data foi passada a data_inicio corresponde a ontem e data_fim a hoje e não estamos fazendo backfill. Caso contrário, retorna as datas inputadas mos parâmetros do flow.

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

Salvar dados em csv

def slice_data(current_time: str) ‑> str

Retorna a data e hora do timestamp de execução

def tratar_dados(dados: pandas.core.frame.DataFrame, backfill: bool = 0) ‑> pandas.core.frame.DataFrame

Renomeia colunas e filtra dados com a hora do timestamp de execução