BI / Power BI

import os, requests
from datetime import date, datetime, timedelta, timezone
 
BASE = os.environ["KINMU_BASE_URL"]
KEY = os.environ["KINMU_API_KEY"]
SYNC_START = date(2026, 1, 1)   # inicio del histórico que te interesa
session = requests.Session()
session.headers.update({"Authorization": f"Bearer {KEY}"})
 
def sync(resource, since=None):
    rows, cursor = [], None
    params = {"limit": 100}
    if since:
        params["updated_since"] = since
    while True:
        if cursor:
            params["cursor"] = cursor
        r = session.get(f"{BASE}/{resource}", params=params, timeout=30)
        r.raise_for_status()
        body = r.json()
        rows.extend(body["data"])
        if not body["meta"]["has_more"]:
            break
        cursor = body["meta"]["next_cursor"]
    return rows
 
def first_day_of_previous_month(day):
    first = day.replace(day=1)
    return (first - timedelta(days=1)).replace(day=1)
 
# Marca de agua ANTES de llamar, para no perder registros escritos durante la sync
watermark = datetime.now(timezone.utc).isoformat()
today = datetime.now(timezone.utc).date()
last_watermark = load_last_watermark()          # ISO 8601 | None
 
employees = sync("employees", since=last_watermark)
 
# La ventana `from`/`to` delimita QUÉ eventos te interesan (el `timestamp` del fichaje).
# `updated_since` delimita QUÉ CAMBIOS traer (el `updated_at`): los tramos sin cambios vuelven vacíos.
# Son ejes distintos, por eso el rango arranca siempre en SYNC_START: una corrección de hoy
# sobre un fichaje de enero solo llega si el tramo de enero sigue dentro de la ventana.
checkins = []
chunk_from = SYNC_START
while chunk_from <= today:
    chunk_to = min(chunk_from + timedelta(days=91), today)
    checkins += sync(f"check-ins?from={chunk_from}&to={chunk_to}", since=last_watermark)
    chunk_from = chunk_to + timedelta(days=1)
 
# Agregados: sin `updated_since` se recarga el rango entero. Empieza en el primer día
# del MES ANTERIOR (en enero cruza al año pasado) para recoger las consolidaciones
# tardías del cierre previo.
previous_month = first_day_of_previous_month(today)
balances = []
for year in sorted({previous_month.year, today.year}):
    balances += sync(f"vacation-balances?year={year}")
summaries = sync(f"work-summaries?period=month&from={previous_month}&to={today}")
 
save_watermark(watermark)

let
    BaseUrl = "https://api.kinmu.app/v1",
    ApiKey  = "kinmu_sk_live_…",   // usa Parámetros / almacén de credenciales, no lo escribas en claro
    Source = Json.Document(
        Web.Contents(BaseUrl, [
            RelativePath = "work-summaries",
            Query = [ period = "month", from = "2026-01-01", #"to" = "2026-12-31", limit = "100" ],
            Headers = [ Authorization = "Bearer " & ApiKey, Accept = "application/json" ]
        ])
    ),
    Data = Source[data],
    Table = Table.FromRecords(Data)
in
    Table