Module pipelines.rj_cor.meteorologia.satelite.tasks

Tasks for emd

Functions

def create_image_and_upload_to_api(info: dict, output_filepath: pathlib.Path)

Create image from dataframe and send it to API

def download(product: str, date_hour_info: dict, band: str = None, ref_filename: str = None, redis_files: list = [], wait=None, mode_redis: str = 'prod') ‑> Union[str, pathlib.Path]

Access S3 or GCP and download the first file on this specified date hour that is not already saved on redis

def get_dates(current_time, product) ‑> str

Task para obter o dia atual caso nenhuma data tenha sido passada Subtraimos 5 minutos da hora atual pois o último arquivo que sobre na aws sempre cai na hora seguinte (Exemplo: o arquivo OR_ABI-L2-RRQPEF-M6_G16_s20230010850208_e20230010859516_c20230010900065.nc cujo início da medição foi às 08:50 foi salvo na AWS às 09:00:33).

def save_data(info: dict, mode_redis: str = 'prod') ‑> Union[str, pathlib.Path]

Concat all netcdf data and save partitioned by date on a csv

def slice_data(current_time: str, ref_filename: str = None) ‑> dict

slice data to separate in year, julian_day, month, day and hour in UTC

def tratar_dados(filename: str) ‑> dict

Convert X, Y coordinates from netcdf file to a latlon coordinates and select only the specified region on extent variable.