Forum Discussion
Microsoft Fabric Notebook - API - WABI
Endpoint URL - wabi-east-us-redirect.analysis.windows.net/metadata/monitoringhub Hello Everyone, I would like to know how can i get access in this endpoint cause when i try to connect i get a m...
Hello Anonymous ,
Thank you for the answer, bellow im putting the code about the API
API_ENDPOINT = "wabi-east-us-redirect.analysis.windows.net"
def obtener_token():
return mssparkutils.credentials.getToken("pbi")
return mssparkutils.credentials.getToken("pbi")
def cargar_datos(engine, tipo_carga😞
"""Carga los datos de manera histórica o incremental según el tipo de carga"""
if tipo_carga == "historical":
print("Iniciando carga histórica")
fecha_inicio = datetime(1970, 1, 1)
fecha_fin = datetime.utcnow()
else:
print("Iniciando carga incremental")
max_start_time = obtener_max_start_time(engine)
if max_start_time is None:
print("No se encontró fecha máxima. Realizando carga histórica.")
cargar_datos(engine, "historical")
return
fecha_inicio = max_start_time
fecha_fin = datetime.utcnow()
uri = "metadata/monitoringhub/histories"
params = {
"endTime": fecha_fin.isoformat() + 'Z',
"startTime": fecha_inicio.isoformat() + 'Z',
"limit": 50000,
}
datos = invocar_api_fabric("GET", uri, params=params)
if 'error' in datos:
print(f"Error al obtener datos: {datos['error']}")
return
print(f"Datos obtenidos: {len(datos)} registros")
df = normalizar_datos(datos)
df_refinado = refinar_datos(df)
if tipo_carga == "incremental":
df_existente = obtener_datos_existentes(engine, fecha_inicio)
df_refinado_existente = refinar_datos(df_existente)
df_refinado = pd.concat([df_refinado_existente, df_refinado]).drop_duplicates(keep=False)
guardar_dataframe_en_bd(df_refinado, engine, 'logs')
print(f"Finalizada la carga {tipo_carga}")