Sensor Ingestion API

import requests

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://www.rahaff.com"

def push_reading(sensor_id, value):
    resp = requests.post(
        f"{BASE_URL}/api/v1/ingest/simple",
        headers={"X-API-Key": API_KEY},
        json={"sensor_id": sensor_id, "value": value}
    )
    resp.raise_for_status()
    return resp.json()

# Example: push a temperature reading
result = push_reading(sensor_id=1, value=182.4)
print(result)  # {"accepted": 1, "sensor_id": 1, ...}

from datetime import datetime, timedelta

def push_batch(sensor_id, readings):
    """readings: list of (datetime, float) tuples"""
    resp = requests.post(
        f"{BASE_URL}/api/v1/ingest",
        headers={"X-API-Key": API_KEY},
        json={
            "sensor_id": sensor_id,
            "readings": [
                {"value": v, "timestamp": ts.isoformat() + "Z"}
                for ts, v in readings
            ]
        }
    )
    resp.raise_for_status()
    return resp.json()

# Push last hour of readings from your historian
now = datetime.utcnow()
readings = [(now - timedelta(minutes=i), 180.0 + i * 0.1) for i in range(60)]
push_batch(sensor_id=1, readings=readings)

const API_KEY = 'YOUR_API_KEY';
const BASE_URL = 'https://www.rahaff.com';

async function pushReading(sensorId, value) {
  const res = await fetch(`${BASE_URL}/api/v1/ingest/simple`, {
    method: 'POST',
    headers: {
      'X-API-Key': API_KEY,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({ sensor_id: sensorId, value }),
  });
  if (!res.ok) throw new Error(`HTTP ${res.status}`);
  return res.json();
}

// Example
pushReading(1, 182.4).then(console.log);