Module pipelines.rj_smtr.br_rj_riodejaneiro_stpl_gps.tasks

Tasks for br_rj_riodejaneiro_stpl_gps

Functions

def pre_treatment_br_rj_riodejaneiro_stpl_gps(status_dict, timestamp)

Parse data from status_dict['data'] to DataFrame as partially nested table.

Args

status_dict : dict

Contains data, run time timestamp and any previous error

key_column : str

Unique key field from each dict within data

Returns

dict

"df" contains the transformed DataFrame from data, "error" contains any caught error

during execution.