Sharded ingest
One owner per shard serializes its commits.
Durable, ordered device history, the current state of every machine and live follows, in one engine for the plant’s telemetry.
The problem
Industrial telemetry is unforgiving: sensor and control streams are high-volume and bursty, ordering matters, and a dropped reading can mean a missed fault.
Cloud-only pipelines add delay and a failure mode when connectivity drops; warehouse-only pipelines answer current-state questions with full-history scans.
You want an engine that keeps ordered history durably, keeps one current row per machine, and lets operators follow a machine’s readings as they commit.
Where NYXDB fits
Architecture
Readings land in tables sharded by machine, each shard with one owner that serializes its commits; keyed tables keep the latest state per machine; STREAM SELECT follows a single machine live.
Every reading is in the write-ahead log before it is acknowledged.
Versions are ordered by the coordinates you declare, not by arrival, with VALID BY and REVISION BY.
The latest row per (machine, metric), in an UPSERT table.
A container image and a Kubernetes manifest ship with the engine.
In practice
The examples use the same two tables on every page. See the SQL reference for full syntax.
STREAM SELECT chain_id, token, SUM(amount) AS volume, COUNT(*) AS transfersFROM transfersGROUP BY chain_id, token;Capabilities
One owner per shard serializes its commits.
Write-ahead log persistence precedes acknowledgement.
Latest row per machine.
A container image or a Kubernetes manifest.
Learn more