Module pipelines.rj_cor.meteorologia.radar.precipitacao.tasks

Tasks for setting rain dashboard using radar data.

Functions

def change_predict_rain_specs(files_to_model: list, destination_path: str) ‑> None

Change name of radar files inside json file

def download_files_storage(bucket_name: str, files_to_download: list, destination_path: str) ‑> None

Realiza o download dos arquivos listados em files_to_download no bucket especificado

def get_filenames_storage(bucket_name: str = 'rj-escritorio-dev', radar: str = 'gua', files_saved_redis: list = []) ‑> list

Esc

def run_model(wait=None) ‑> Tuple[pandas.core.frame.DataFrame, Union[str, pathlib.Path]]
def save_data(dfr: pandas.core.frame.DataFrame) ‑> Union[str, pathlib.Path]

Save treated data in csv partitioned by date