canbus
CAN bus and operational telemetry ingestion into Amazon Timestream.
| Field | Value |
|---|
| Serverless service | drive-api-canbus |
| Runtime | nodejs22.x, arm64 |
| Region | ap-southeast-2 |
| Deployed HTTP operations | 2 |
| Local worker harnesses | 0 |
| OpenAPI | /openapi/canbus.yaml · interactive |
Deployed routes
| Method | Path | Auth | Summary |
|---|
| POST | /canbus/event/queue | Public | Queue telemetry records for async Timestream write |
| POST | /canbus/event/write | API key | Write telemetry records directly to Timestream |
Behaviour notes
queueTimestreamEvent validates Timestream-native records and queues them in SQS batches of 10.writeTimestreamEvent is both HTTP-mounted and SQS-triggered; on the SQS path it rethrows so the batch retries.- Record types map to Timestream tables and required dimensions in
services/canbus/types/RecordTypes.ts.
- The queue route can return
200 even when individual SQS entries failed; check the per-record succeeded and failed lists.
Source map
- services/canbus/serverless.yml
- services/canbus/functions/queueTimestreamEvent.ts
- services/canbus/functions/writeTimestreamEvent.ts
- services/canbus/types/RecordTypes.ts
- services/canbus/types/WriteTimestreamEventRequest.ts