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)   # Beginn der Historie, die dich interessiert
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)
 
# Wasserzeichen VOR dem Aufruf, damit während der Sync geschriebene Datensätze nicht verloren gehen
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)
 
# Das Fenster `from`/`to` grenzt ein, WELCHE Ereignisse dich interessieren (der `timestamp` der Stempelung).
# `updated_since` grenzt ein, WELCHE ÄNDERUNGEN geholt werden (`updated_at`): Abschnitte ohne Änderung kommen leer zurück.
# Zwei verschiedene Achsen — deshalb startet der Zeitraum immer bei SYNC_START: Eine heutige Korrektur
# an einer Januar-Stempelung kommt nur an, wenn der Januar-Abschnitt noch im Fenster liegt.
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)
 
# Aggregate: ohne `updated_since` wird der ganze Zeitraum neu geladen. Start am ersten Tag
# des VORMONATS (im Januar also im Vorjahr), um späte Konsolidierungen des vorherigen
# Abschlusses noch mitzunehmen.
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