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)   # where the history you care about starts
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)
 
# Watermark BEFORE calling, so you don't miss records written during the 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)
 
# The `from`/`to` window bounds WHICH events you care about (the check-in `timestamp`).
# `updated_since` bounds WHICH CHANGES to fetch (`updated_at`): unchanged chunks come back empty.
# They are different axes, which is why the range always starts at SYNC_START: a correction
# made today to a January check-in only arrives if January's chunk is still in the window.
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)
 
# Aggregates: with no `updated_since`, the whole range is reloaded. Start on the first
# day of the PREVIOUS MONTH (in January that crosses into last year) to pick up late
# consolidations of the previous close.
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_…",   // use Parameters / credential store, don't write it in plaintext
    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