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)   # début de l'historique qui vous intéresse
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)
 
# Filigrane AVANT l'appel, pour ne pas perdre les enregistrements écrits pendant 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 fenêtre `from`/`to` borne QUELS événements vous intéressent (le `timestamp` du pointage).
# `updated_since` borne QUELS CHANGEMENTS récupérer (`updated_at`) : les tranches sans changement reviennent vides.
# Ce sont deux axes distincts : la plage part donc toujours de SYNC_START, car une correction faite
# aujourd'hui sur un pointage de janvier n'arrive que si la tranche de janvier est encore dans la fenêtre.
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)
 
# Agrégats : sans `updated_since`, on recharge toute la plage. On démarre au premier jour
# du MOIS PRÉCÉDENT (en janvier, cela bascule sur l'année passée) pour récupérer les
# consolidations tardives de la clôture précédente.
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