ANALYTICS PLAYBOOK_

import pandas as pd
import requests
import time
 
# Project Icebreaker · Paginated Analytics Engine Ingest
# ⬇ Replace these two values with your Supabase project URL and anon key
SUPABASE_URL = "https://your-project.supabase.co"
SUPABASE_KEY = "your-anon-key"
 
url = f"{SUPABASE_URL}/rest/v1/telemetry_logs"
 
headers = {
    "apikey": SUPABASE_KEY,
    "Authorization": f"Bearer {SUPABASE_KEY}",
}
 
all_data = []
offset = 0
chunk_size = 1000
 
print("📥 Initializing paginated extraction from cloud layer...")
 
while True:
    params = {
        "asset_id": "eq.MBS-KIT-CHILLER-01",
        "timestamp": "gte.2026-08-22T18:16:59.789Z",
        "timestamp": "lte.2026-08-23T18:16:59.789Z",
        "select": "timestamp,active_power,voltage,current,operational_state",
        "order": "timestamp.asc",
        "limit": str(chunk_size),
        "offset": str(offset),
    }
 
    res = requests.get(url, headers=headers, params=params)
    data = res.json()
 
    # Break out if empty list or invalid format returned
    if not isinstance(data, list) or len(data) == 0:
        break
 
    all_data.extend(data)
    print(f"   Aggregated records {offset} to {offset + len(data)}...")
 
    # If the database returns less than our requested chunk, we have hit the end
    if len(data) < chunk_size:
        break
 
    offset += chunk_size
    time.sleep(0.05)  # Lightweight safety buffer to guard against API rate throttling
 
df = pd.DataFrame(all_data)
print(f"✅ Extraction complete. Imported {len(df)} fully labeled telemetry rows into DataFrame 'df'.")