LAYER 01
Ingestion pipeline
Continuous 4-second SCADA variables are parsed on site by industrial gateways and streamed
over low-latency WebSockets into a managed Kubernetes cluster. Snapshots buffer in an in-memory
cache before landing in daily-partitioned time-series hypertables.
LAYER 02
Algorithmic core
Every 15 minutes, scheduled serverless compute nodes process weather grid arrays and
cross-border transfer capacity, then build an opportunity cost matrix: trade the spot market,
or collect the standby fee.
LAYER 03
Transaction layer
Once a trade clears the fractional cycle wallet that protects the manufacturer warranty,
encrypted payloads route to the Transelectrica and OPCOM trading engines over mutual TLS.
- Compute
- Containerised cluster on
Amazon EKS, with serverless AWS Fargate nodes for scheduled model training runs.
- Storage
TimescaleDB hypertables for telemetry and settlement history; Redis for the hot in-memory buffer.
- Models
- Gradient-boosted trees (
XGBoost, LightGBM) with sequential time-series cross-validation.
- Edge
- Industrial
Teltonika RUT956 gateways speaking Modbus to the inverters, with a local watchdog script.
- Transport
- WebSocket streams inbound, mutual TLS outbound to market APIs. No public IP on the data plane.
- Region
- EU-only hosting inside private VPC subnets in
eu-central-1 (Frankfurt).