Module pipelines.rj_cor.meteorologia.utils

General utilities for meteorologia.

Functions

def save_updated_rows_on_redis(dfr: pandas.core.frame.DataFrame, dataset_id: str, table_id: str, unique_id: str = 'id_estacao', date_column: str = 'data_medicao', date_format: str = '%Y-%m-%d %H:%M:%S', mode: str = 'prod') ‑> pandas.core.frame.DataFrame

Acess redis to get the last time each unique_id was updated, return updated unique_id as a DataFrame and save new dates on redis