LAMINARDB: STREAMING DATA PLATFORM.

# pip install laminardb

import laminardb

conn = laminardb.open(":memory:")

conn.execute("""
    CREATE SOURCE events (key VARCHAR, value DOUBLE, ts TIMESTAMP)
""")

conn.execute("""
    CREATE STREAM summary AS
    SELECT key, COUNT(*) AS total, AVG(value) AS avg
    FROM events
    GROUP BY key, TUMBLE(ts, INTERVAL '1' MINUTE)
    EMIT ON WINDOW CLOSE
""")

# Push events in, then query results back
conn.insert("events", [
    {"key": "sensor-1", "value": 42.0, "ts": 1700000000000},
    {"key": "sensor-1", "value": 44.0, "ts": 1700000001000},
])

conn.sql("SELECT * FROM summary").show()
conn.close()

# Pull the latest standalone LaminarDB server image
docker pull laminardb/laminardb-server:latest

# Run standalone server with REST/WebSocket API on port 8080
docker run -d \
  --name laminardb \
  -p 8080:8080 \
  -v $(pwd)/laminardb.toml:/etc/laminardb/laminardb.toml \
  laminardb/laminardb-server:latest

# Verify that the server is responding to health checks
curl http://localhost:8080/health

# 1. Add the LaminarDB Helm repository and install the standalone release
helm repo add laminardb https://laminardb.io/charts
helm repo update
helm install laminar-dev laminardb/laminardb

# 2. For high-availability clustering, install with clustered parameters:
helm install laminar-prod laminardb/laminardb \
  --set replicaCount=3 \
  --set cluster.enabled=true \
  --set persistence.size=10Gi

# 1. Fetch the latest release version dynamically
VERSION=$(curl -s https://api.github.com/repos/laminardb/laminardb/releases/latest | grep tag_name | cut -d '"' -f4)

# 2. Download and extract the matching package for your platform
# For Linux x86_64:
curl -LO "https://github.com/laminardb/laminardb/releases/download/${VERSION}/laminardb-server-x86_64-unknown-linux-gnu-${VERSION}.tar.gz"
tar xzf laminardb-server-*-linux-gnu-${VERSION}.tar.gz

# For macOS (Apple Silicon):
curl -LO "https://github.com/laminardb/laminardb/releases/download/${VERSION}/laminardb-server-aarch64-apple-darwin-${VERSION}.tar.gz"
tar xzf laminardb-server-*-apple-darwin-${VERSION}.tar.gz

# 3. Start standalone server using configuration file
./laminardb --config laminardb.toml

-- Tumbling window: 1-minute OHLC bars
CREATE STREAM ohlc_1m AS
SELECT symbol,
       first_value(price) AS open,
       MAX(price) AS high, MIN(price) AS low,
       last_value(price) AS close,
       SUM(volume) AS volume
FROM trades
GROUP BY symbol, tumble(ts, INTERVAL '1' MINUTE)
EMIT ON WINDOW CLOSE;

-- Session window: detect activity bursts
CREATE STREAM sessions AS
SELECT user_id, COUNT(*) AS clicks,
       MAX(ts) - MIN(ts) AS duration_ms
FROM clickstream
GROUP BY user_id, session(ts, INTERVAL '30' SECOND)
EMIT ON WINDOW CLOSE;

-- ASOF join: enrich trades with closest preceding quote
SELECT t.symbol, t.price, q.bid, q.ask,
       t.price - q.bid AS spread
FROM trades t
ASOF JOIN quotes q
    MATCH_CONDITION(t.ts >= q.ts)
    ON t.symbol = q.symbol;

-- Interval join: match orders to payments within 1 hour
CREATE STREAM matched AS
SELECT o.order_id, o.amount, p.status
FROM orders o
INNER JOIN payments p ON o.order_id = p.order_id
    AND p.ts BETWEEN o.ts AND o.ts + 3600000;