Module pipelines.rj_escritorio.rain_dashboard.tasks

Tasks for setting rain data in Redis.

Functions

def dataframe_to_dict(dataframe: pandas.core.frame.DataFrame) ‑> List[Dict[str, Union[str, float]]]

Convert dataframe to dictionary

def get_data(query: str, mode: str = 'prod') ‑> pandas.core.frame.DataFrame

Load rain data from BigQuery

def set_redis_key(key: str, value: List[Dict[str, Union[str, float]]], host: str = 'redis.redis.svc.cluster.local', port: int = 6379, db: int = 0) ‑> None

Set Redis key