Module pipelines.rj_smtr.br_rj_riodejaneiro_brt_gps.tasks

Tasks for br_rj_riodejaneiro_brt_gps

Functions

def pre_treatment_br_rj_riodejaneiro_brt_gps(status: dict, timestamp)

Basic data treatment for brt gps data. Converts unix time to datetime, and apply filtering to stale data that may populate the API response.

Args

status_dict : dict

dict containing the status of the request made to the

API. Must contain keys: data, timestamp and error

Returns

df

pandas.core.DataFrame containing the treated data.