import pandas as pd

paquetesMaskcam_DF = pd.read_csv ('/work/Datasets/paquetes_maskcam_01_09_2021__01_10_2021.csv') Ubicaciones_DF = pd.read_csv ('/work/Datasets/maskcam_tabasco_ubicaciones.csv')

paquetesMaskcam_DF.dtypes

paquetesMaskcam_DF['hora_recepcion']=pd.to_datetime(paquetesMaskcam_DF['hora_recepcion']) paquetesMaskcam_DF.dtypes

IndicadoresRedPorHora = pd.DataFrame(columns=['fecha', 'hora', 'total_personas_detectadas_por_hora', 'total_personas_con_cubrebocas_por_hora', 'total_personas_sin_cubrebocas_por_hora', 'id_ubicacion_mayor_afluencia', 'total_personas_en_mayor_afluencia', 'personas_sin_cubrebobas_en_mayor_afluencia', 'personas_con_cubrebobas_en_mayor_afluencia', 'id_ubicacion_menor_uso_cubrebocas', 'total_personas_en_menor_uso_cubrebocas', 'personas_sin_cubrebobas_en_menor_uso_cubrebocas', 'personas_con_cubrebobas_en_menor_uso_cubrebocas',])

AgrupadoPorDispositivo_df = paquetesMaskcam_DF.groupby(paquetesMaskcam_DF["id_dispositivo"]); AgrupadoPorDispositivo_df

AgrupadoPorDispositivo_df["personas_detectadas"].max()

AgrupadoPorDispositivo_df.get_group('iotdev1')

AgrupadoPorHora_df= paquetesMaskcam_DF.groupby(paquetesMaskcam_DF['hora_recepcion'].dt.floor('h'))

AgrupadoPorHora_df["personas_con_cubrebocas"].max()

AgrupadoPorHora_df.get_group("2021-09-01 02:00:00")

#len(AgrupadoPorHora_df) AgrupadoPorHora_df.ngroups

for hora, grupo in AgrupadoPorHora_df: print(hora)

for hora, grupo in AgrupadoPorHora_df: AgrupadoPorDispositivo_df = grupo.groupby(grupo["id_dispositivo"]); print(AgrupadoPorDispositivo_df["personas_detectadas"].max())

for hora, grupo in AgrupadoPorHora_df: AgrupadoPorDispositivo_df = grupo.groupby(grupo["id_dispositivo"]); for dispositivo, grupo in AgrupadoPorDispositivo_df: print(dispositivo,grupo["personas_detectadas"].sum())

for hora, grupoHora in AgrupadoPorHora_df: #AgrupadoPorDispositivo_df = grupoHora.groupby(grupoHora["id_dispositivo"]); UbicacionConMayorAfluencia=grupoHora.nlargest(1,["personas_detectadas"]) UbicacionMenosUsoCubrebocas=grupoHora.nlargest(1,["personas_sin_cubrebocas"]) IndicadoresRedPorHora = IndicadoresRedPorHora.append({ 'fecha':hora.strftime('%Y-%m-%d'), 'hora':hora.strftime('%H:%M:%S'), 'total_personas_detectadas_por_hora':grupoHora["personas_detectadas"].sum(), 'total_personas_con_cubrebocas_por_hora':grupoHora["personas_con_cubrebocas"].sum(), 'total_personas_sin_cubrebocas_por_hora':grupoHora["personas_sin_cubrebocas"].sum(), 'id_ubicacion_mayor_afluencia':UbicacionConMayorAfluencia.iloc[0]['id_dispositivo'], 'total_personas_en_mayor_afluencia':UbicacionConMayorAfluencia.iloc[0]['personas_detectadas'], 'personas_sin_cubrebobas_en_mayor_afluencia':UbicacionConMayorAfluencia.iloc[0]['personas_sin_cubrebocas'], 'personas_con_cubrebobas_en_mayor_afluencia':UbicacionConMayorAfluencia.iloc[0]['personas_con_cubrebocas'], 'id_ubicacion_menor_uso_cubrebocas':UbicacionMenosUsoCubrebocas.iloc[0]['id_dispositivo'], 'total_personas_en_menor_uso_cubrebocas':UbicacionMenosUsoCubrebocas.iloc[0]['personas_detectadas'], 'personas_sin_cubrebobas_en_menor_uso_cubrebocas':UbicacionMenosUsoCubrebocas.iloc[0]['personas_sin_cubrebocas'], 'personas_con_cubrebobas_en_menor_uso_cubrebocas':UbicacionMenosUsoCubrebocas.iloc[0]['personas_con_cubrebocas'] },ignore_index=True)

IndicadoresRedPorHora

IndicadoresRedPorHora.to_csv("IndicadoresRedPorHora.csv")