Skip to content

feat(example-iot-telemetry): implement polyglot ObjectUri pipeline and Gemini AI anomaly synthesis聽#44

Description

@crapougnax

Part of parent story #41.

馃幆 Goal

Implement polyglot ObjectUri routing across storage engines and cognitive incident diagnosis via Google Gemini AI.

馃搵 Specification

  1. Polyglot ObjectUri resolution:
    • Device model: postgres:devices/dev-sensor-42.
    • Message in transit: amqp:sensor-frames/msg-881.
    • Cold storage raw payload: s3:telemetry-cold/2026-09/dev-sensor-42.json.
  2. Cold Storage Archiving:
    • Export raw batches to S3 / MinIO via @quatrain/storage-s3.
  3. AI Cognitive Anomaly Synthesis:
    • Integrate @quatrain/ai-gemini to detect critical threshold anomalies (e.g. abrupt soil moisture drop, battery sag).
    • Use generateStructured() with strict JSON schema to produce actionable diagnostic cards (anomaly kind, probable root cause, severity, recommended maintenance action).

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions