Amazon CloudWatch Events によるモニタリング

AWS IoT Analytics アクティビティ中にランタイムエラーが発生すると、 は Amazon CloudWatch Events にイベントを自動的に発行します AWS Lambda 。このイベントには、詳細なエラーメッセージと、未処理チャネルメッセージを格納する Amazon Simple Storage Service Amazon S3オブジェクトのキーが含まれます。Amazon S3 キーを使用して、未処理のチャネルメッセージを再処理できます。詳細については、チャネルメッセージの再処理、AWS IoT Analytics API リファレンスのStartPipelineReprocessing API、Amazon CloudWatch Events ユーザーガイドの「Amazon CloudWatch Events とは」を参照してください。

また、Amazon CloudWatch Events による通知の送信や高度なアクションの実行が可能になるようにターゲットを設定することもできます。たとえば、Amazon Simple Queue Service Amazon SQSキューに通知を送信し、StartReprocessingMessage API を呼び出して Amazon S3 オブジェクトに保存されているチャネルメッセージを処理することができます。Amazon CloudWatch Events では、次のような数多くのタイプのターゲットがサポートされています。

詳細については、Amazon EventBridge ユーザーガイドの「Amazon EventBridge ターゲット」を参照してください。

CloudWatch Events リソースと関連するターゲットは、 AWS IoT Analytics リソースを作成した AWS リージョンにある必要があります。詳細については、「AWS 全般のリファレンス」の「サービスエンドポイントとクォータ」を参照してください。

AWS Lambda アクティビティのランタイムエラーについて Amazon CloudWatch Events に送信される通知は、次の形式を使用します。

{
    "version": "version-id",
    "id": "event-id",
    "detail-type": "IoT Analytics Pipeline Failure Notification",
    "source": "aws.iotanalytics",
    "account": "aws-account",
    "time": "timestamp",
    "region": "aws-region",
    "resources": [
        "pipeline-arn"
    ],
    "detail": {
        "event-detail-version": "1.0",
        "pipeline-name": "pipeline-name",
        "error-code": "LAMBDA_FAILURE",
        "message": "error-message",
        "channel-messages": {
            "s3paths": [
                "s3-keys"
            ]
        },
        "activity-name": "lambda-activity-name",
        "lambda-function-arn": "lambda-function-arn"
    }
}

通知の例

{
    "version": "0",
    "id": "204e672e-ef12-09af-4cfd-de3b53673ec6",
    "detail-type": "IoT Analytics Pipeline Failure Notification",
    "source": "aws.iotanalytics",
    "account": "123456789012",
    "time": "2020-10-15T23:47:02Z",
    "region": "ap-southeast-2",
    "resources": [
        "arn:aws:iotanalytics:ap-southeast-2:123456789012:pipeline/test_pipeline_failure"
    ],
    "detail": {
        "event-detail-version": "1.0",
        "pipeline-name": "test_pipeline_failure",
        "error-code": "LAMBDA_FAILURE",
        "message": "Temp unavaliable",
        "channel-messages": {
        "s3paths": [
            "test_pipeline_failure/channel/cmr_channel/__dt=2020-10-15 00:00:00/1602805530000_1602805560000_123456789012_cmr_channel_0_257.0.json.gz"
        ]
    },
    "activity-name": "LambdaActivity_33",
    "lambda-function-arn": "arn:aws:lambda:ap-southeast-2:123456789012:function:lambda_activity"
    }
}