Durable telemetry
Writes persisted before acknowledgement.
Fleet telemetry, live vehicle state that survives late and re-sent updates, and live reads on the dispatch path.
The problem
A logistics or mobility platform tracks a fleet in motion: a stream of telemetry, current vehicle state that dispatch reads constantly, and updates that arrive late or twice when a vehicle reconnects. The usual stack is a telemetry pipeline, a cache for live state and a separate service per question.
The split adds delay to exactly the reads that need to be prompt, opens a gap between what a vehicle reported and what the dispatcher sees, and lets a late update overwrite a newer one.
You want durable telemetry ingest, vehicle state ordered by the vehicle’s own sequence rather than by arrival, and live reads in the same SQL.
Where NYXDB fits
Architecture
Telemetry lands in one table; vehicle state lives in a versioned table ordered by the vehicle’s own sequence, so a late update never wins over a newer one; STREAM SELECT pushes each state change to dispatch.
Every telemetry row is durable before it is acknowledged.
The winner per vehicle is picked by sequence, in a VERSIONED table with VALID BY and REVISION BY.
Every accepted version is kept beside the current winner.
Vehicle-state changes reach dispatch live, with STREAM SELECT.
In practice
The examples use the same two tables on every page. See the SQL reference for full syntax.
CREATE TABLE balances ( chain_id UINT16 NOT NULL, address STRING NOT NULL, token STRING NOT NULL, amount UINT256 NULL, updated_at DATETIME64(3, 'UTC') NULL, balance_index UINT128 NULL, balance_version UINT64 NULL, transfer_count UINT64 NULL, last_transfer_at DATETIME64(3, 'UTC') NULL, activity_index UINT128 NULL, PRIMARY KEY (chain_id, address, token), ATTRIBUTE GROUP holding (amount, updated_at, balance_index, balance_version) VALID BY (balance_index) REVISION BY (balance_version), ATTRIBUTE GROUP activity (transfer_count, last_transfer_at, activity_index) VALID BY (activity_index))MODE VERSIONEDSHARD BY (address) SHARDS AUTOORDER BY (chain_id, address, token);Capabilities
Writes persisted before acknowledgement.
A late update never overrides a newer one, with VALID BY and REVISION BY.
Current row per vehicle, history retained.
A container image or a Kubernetes manifest.
Learn more