AWS IoT Events

解決する課題

• 複数のセンサーやデバイスから上がる値を組み合わせて判断し、設備の異常や故障の予兆を検知したい
• 「一定時間しきい値を超え続けたら警報」のような状態を持った条件判定を、アプリを自作せずに実現したい
• 異常を検知したら通知やワークフロー起動まで自動でつなげ、現場の対応を迅速にしたい

主要概念と用語

• 検知器モデル（Detector Model）: 監視ロジックを定義する設計図。状態とその間の遷移をまとめた状態機械として表現する
• 状態（State）: デバイスや設備の置かれている局面。正常、警告、異常などを表し、現在どの状態にいるかを保持する
• 遷移（Transition）: ある状態から別の状態へ移る条件。入力値を評価する論理式で定義する
• 入力（Input）: 検知器に流し込むデータの定義。受け取るメッセージの項目（属性）を指定する
• 検知器（Detector）: 検知器モデルを特定の監視対象ごとに実体化したもの。キー（例: 機器ID）ごとに状態を個別に保持する
• イベント / アクション: 状態内や遷移時に評価する条件と、成立時に実行する処理。SNS通知、Lambda起動、タイマー設定、変数更新などがある
• タイマー / 変数: 状態をまたいで値を保持する仕組み。一定時間の経過判定や、回数のカウントに使う

仕様・制限・クォータ

• 提供終了前は、状態と遷移からなる検知器モデルをキーごとに実体化し、タイマーと変数を保持していた
• 2026年5月20日以降はコンソール、API、入力、検知器モデル、検知器へアクセスできない
• 移行後はKinesisのシャード、Lambdaの同時実行と再試行、DynamoDBの容量と条件付き更新を個別に設計する
• 公式の移行例は本番向け完成品ではないため、順序、重複、失敗隔離、監視、暗号化を要件に合わせて補う

内部の仕組み

横にスクロール

提供終了前のAWS IoT Eventsは、入力メッセージを検知器モデルの状態機械に通し、状態遷移として評価していました。入力構造、遷移条件、イベント、アクションを定義し、キーごとに独立した検知器を動かす仕組みでした。

移行では、入力をIoT CoreからKinesisへ渡し、Lambdaで条件を評価し、DynamoDBへ機器ごとの状態と期限を保存し、SNS等へ通知する形に分解します。元のキー、状態、変数、タイマー、遷移条件、アクションを対応表へ残し、並列処理でも状態が競合しない条件付き更新と、再試行時の冪等性を実装します。

設計パターン / ベストプラクティス

• 検知器モデルを機器キー、入力、状態、遷移、変数、タイマー、アクションへ分解して移行台帳を作る
• Kinesisのパーティションキーを機器IDにそろえ、同一機器の順序を保ちやすくする
• DynamoDBの条件付き更新で、古い状態を読んだ並列Lambdaが新しい状態を上書きしないようにする
• イベント識別子を保存し、再試行されたLambdaや通知が同じ副作用を二重実行しないようにする
• 失敗レコードを隔離し、再処理後も状態とタイマーが整合する手順を用意する

運用・監視

• Kinesisの滞留時間、Lambdaのエラーとスロットリング、DynamoDBの競合・容量、隔離レコード数をCloudWatchで監視する
• 代表値、境界値、遅延、重複、順序逆転を含む入力を再生し、旧モデルと移行先の状態・タイマー・通知を照合する
• 想定外の遷移は、機器キー、イベント時刻、到着順、条件付き更新の成否を一つの追跡IDでたどる
• 再処理は冪等にし、隔離レコードを戻しても通知や外部処理を二重実行しないことを確認する

コスト

• 提供終了後は、移行先のKinesis取り込み・保持、Lambdaの実行時間、DynamoDBの読み書き・保存、SNS等を合算して見積もる
• IoT Coreのルールで必要なメッセージだけを転送し、Lambdaでは機器キー単位の処理量と同時実行数を抑える
• 再生用の保持期間、隔離レコード、複数リージョン化を含め、平常時だけでなく障害時の再処理量も試算する
• 単価は各移行先サービスの最新料金ページで確認する

セキュリティ

• IoT CoreからKinesisまでの入口はIoTポリシーとIAMで絞り、別テナント・別機器のキーを受理しない
• Lambdaの実行ロールは、対象ストリーム、状態テーブル、通知先だけへ最小権限を付与する
• 通信はTLS、Kinesis・DynamoDB等の保存データは必要に応じてKMS管理鍵で暗号化する
• CloudTrailとアプリケーションログに、移行ロジックの版、状態遷移、条件付き更新の失敗を記録する
• AWSの移行例は構成例であり、本番の冪等性、競合制御、隔離、権限、監視は利用組織が実装・検証する

関連サービス・比較

移行後の確認例

# 移行先ストリームと状態表が作成済みか確認
aws kinesis describe-stream-summary \
  --stream-name <event-stream>

aws dynamodb describe-table \
  --table-name <detector-state-table>

# 状態評価関数の失敗設定を確認
aws lambda get-function-event-invoke-config \
  --function-name <state-evaluator>