データ・プレーン — 物理世界インターフェース

目的

データプレーンはプラットフォームと物理世界のインターフェースです。デバイスの登録とライフサイクル管理、テレメトリの取り込みと分析、OTA ソフトウェア配布、およびすべての上流サービスへのデータ可用性を処理します。プラットフォームに参加するすべてのロボット、PDA、センサー、または IoT デバイスがここで登録および監視されます。

サービス

サービス	担当領域	詳細
DeviceAdmin	デバイス登録、アラート、OTA ステータス	IoT デバイスを登録し、ThingsBoard アラートを提示し、OTA 更新の可視性を提供する
ThingIO	データ処理、分析、ダッシュボード	Wraps StreamPipes for pipeline execution; provides Data API for telemetry queries, scope management, and pipeline lifecycle. Consumer apps call APIs and render their own dashboards.
OTAForge	OTA アーティファクト管理とポリシー駆動のロールアウト	アーティファクト公開、ディストリビューションセット、ポリシー駆動のロールアウト自動化、プロキシされた DDI、アーティファクト公開用 CI/CD アクセスキーのために hawkBit をラップ

インタラクションモデル

                                ┌───────────────┐
  CI/CD (Jenkins) ──AK/SK─────►│   OTAForge    │──► hawkBit
  (artifact publishing only)    │               │
                                │ Artifact mgmt │     DDI proxy
  Policy Service ──policies───►│ Policy engine  │◄──────────── Devices
                                │ DDI proxy     │   (Hara polls OTAForge,
                                └───────┬───────┘    not hawkBit directly)
                                        │ OTA status
                                        ▼
  Devices ──MQTT──► ThingsBoard ──► ┌──────────────┐
                         │          │  DeviceAdmin  │ ◄── Identity Plane
                         │ alerts   │ (enrollment,  │     (DotID auth)
                         └─────────►│  alerts, OTA  │
                                    │  status)      │
  Provisioning ◄── delegates ──────│               │
  Service                           └──────────────┘
                         │
              Kafka      │
           (Cluster A)   │ cross-cluster replication
                         ▼
                    ┌──────────────┐
  Applications ───►│   ThingIO    │ ◄── Equator (spatial overlay)
  (WES, CJ)        │ (Data API,  │
  call API,         │  Pipelines) │ Kafka
  own dashboards    └──────────────┘

• DeviceAdmin は統合デバイス管理インターフェースです——登録、アラート、OTA ステータス。プロビジョニングを Provisioning Service に委任します。開発者は ThingsBoard や hawkBit と直接やり取りすることはありません。

• ThingIO is the data processing and telemetry API layer — provides REST APIs for scopes, telemetry queries, and pipeline management, backed by StreamPipes. Consumer apps call ThingIO APIs and build their own dashboards. Three pipeline tiers: managed (auto-provisioned), app (self-service from templates), and platform (operator-built in StreamPipes UI).

• OTAForge は OTA アーティファクトレイヤーです——CI/CD アクセスキーによるアーティファクト公開、ポリシー駆動のロールアウト自動化、プロキシされた DDI エンドポイント。ロールアウトは手動ではなく、ポリシー評価によって自動作成されます。

• Kafka runs as a single Strimzi cluster on EKS (KRaft mode, 3 brokers). ThingsBoard publishes to thingsboard.* topics, StreamPipes publishes to sp.analytics.* topics. ThingIO consumes both.

• すべてのサービスは DotID を通じて認証されます。リソースはアカウントにスコープされます。

データ所有権

データ	所有者	利用者
デバイスレジストリ（ID、タイプ、ファームウェア、リース）	DeviceAdmin	全プレーン
デバイスアラート（バッテリー、接続性、閾値）	DeviceAdmin	アプリケーション、オペレーター
OTA 更新ステータス（バージョン、保留中、履歴）	OTAForge（DeviceAdmin ビュー経由）	アプリケーション、オペレーター
生テレメトリ（位置、バッテリー、センサー読み取り値）	ThingsBoard（内部）	ThingIO、DeviceAdmin アラート
処理済み分析（パターン、異常、カバレッジ）	ThingIO	アプリケーション、インテリジェンスプレーン
ダッシュボード、ウィジェット、パイプライン	ThingIO	アプリケーション
アーティファクト、ディストリビューションセット、ロールアウト	OTAForge	DeviceAdmin（ステータスビュー）、デバイス

IoT テクノロジーレイヤー

データプレーンサービスは3つのオープンソース IoT プラットフォームをラップします。技術的な詳細は IoT レイヤー を参照してください。

サービス	ラップ対象	関係
DeviceAdmin	ThingsBoard CE	デバイス CRUD、アラートサブスクリプション、クレデンシャル管理
ThingIO	Apache StreamPipes	Data pipelines, telemetry API, pipeline lifecycle management
OTAForge	Eclipse hawkBit	アーティファクトストレージ、ロールアウトエンジン、プロキシされた DDI エンドポイント