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)   # inizio dello storico che ti interessa
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 temporale PRIMA di chiamare, per non perdere i record scritti 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 finestra `from`/`to` delimita QUALI eventi ti interessano (il `timestamp` della timbratura).
# `updated_since` delimita QUALI MODIFICHE portare (`updated_at`): le tranche senza modifiche tornano vuote.
# Sono due assi diversi: per questo l'intervallo parte sempre da SYNC_START, dato che una correzione
# fatta oggi su una timbratura di gennaio arriva solo se la tranche di gennaio è ancora nella finestra.
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)
 
# Aggregati: senza `updated_since` si ricarica l'intero intervallo. Si parte dal primo
# giorno del MESE PRECEDENTE (a gennaio si passa all'anno scorso) per raccogliere le
# consolidazioni tardive della chiusura precedente.
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