Streaming

get_data stream

A vehicle-status record is pushed to the client's Kinesis stream per unit, event-driven, as the unit reports.

Record envelope

Each Kinesis record's Data field is a base64-encoded JSON envelope. For this stream apiName is vehicle_status_updated.

{
  "clientId": "numaris",
  "apiName": "vehicle_status_updated",
  "eventLatency": "int",
  "payload": {
    "unit_key": "1:905003453",
    "unit_type": "1",
    "inner_id": "905003453",
    "unit_id": 98765,
    "date": "2026-06-24T08:14:55Z",
    "server_time": "2026-06-24T08:15:17Z",
    "latitude": 32.0853,
    "longitude": 34.7818,
    "speed": 62,
    "direction": 180,
    "mileage": 152340,
    "fuel_used": 18.4,
    "ignition": 1,
    "satellites": 11,
    "engine_hours": 4210,
    "vehicle_id": "555",
    "group_id": "42",
    "group_name": "RFP",
    "client_id": "13648",
    "client_name": "Traxion Carga",
    "company_number": "20401",
    "license_plate": "AB-123-CD",
    "vin": "3HSDJAPR8JN000000",
    "manufacturer": "International",
    "model": "TRUCK-J1939-SCR-CNT",
    "sub_model": "A79",
    "current_driver": "7788",
    "driver_name": "Juan Pérez",
    "worker_id": "EMP-3391",
    "current_driver_number": "104",
    "current_drive": "660912",
    "last_event_time": "2026-06-24T08:14:40Z",
    "last_event_type": "Ignition on",
    "charge_hours": "0",
    "status": 1
  }
}

Partition key

The Kinesis partition key for every record is "<unitType>:<innerId>", for example 1:905003453. All records for the same physical unit land on the same shard, preserving per-unit ordering.

Payload fields

Name	Type	Required	Description
`unit_key`	string	required	Composite unit key (unitType:innerId).
`unit_type`	string	required	Unit type code (e.g. '1').
`inner_id`	string	required	Unit's inner hardware identifier.
`unit_id`	number	required	Telematics unit identifier.
`date`	string	required	Unit event timestamp (ISO 8601).
`server_time`	string	required	Server ingestion timestamp (ISO 8601).
`latitude`	number	required	GPS latitude.
`longitude`	number	required	GPS longitude.
`speed`	number	required	Speed at record time.
`direction`	number	required	Heading in degrees (0–359).
`mileage`	number	required	Odometer reading.
`fuel_used`	number	required	Fuel consumed (trip accumulator).
`ignition`	number	required	Ignition state: 1=on, 0=off.
`satellites`	number	required	Number of GPS satellites in use.
`engine_hours`	number	required	Cumulative engine hours.
`vehicle_id`	string	required	Internal vehicle identifier.
`group_id`	string	required	Depot/group identifier.
`group_name`	string	required	Depot/group display name.
`client_id`	string	required	Tenant/client identifier.
`client_name`	string	required	Tenant/client display name.
`company_number`	string	required	Client company registration number.
`license_plate`	string	required	Vehicle license plate.
`vin`	string	required	Vehicle VIN / chassis serial.
`manufacturer`	string	required	Vehicle manufacturer name.
`model`	string	required	Vehicle model name.
`sub_model`	string	required	Vehicle sub-model or trim.
`current_driver`	string	required	Active driver identifier.
`driver_name`	string	required	Active driver display name.
`worker_id`	string	required	Active driver's worker/employee identifier.
`current_driver_number`	string	required	Active driver code / badge number.
`current_drive`	string	required	Active trip/drive identifier.
`last_event_time`	string	required	Timestamp of the most recent event.
`last_event_type`	string	required	Description of the most recent event type.
`charge_hours`	string	required	Cumulative charge hours (EVs).
`status`	number	required	Vehicle status code (e.g. 1=moving, 0=idle).