Überwachen Sie mit Amazon CloudWatch Events

AWS IoT Analytics veröffentlicht automatisch ein Ereignis in Amazon CloudWatch Events, wenn während einer AWS Lambda Aktivität ein Laufzeitfehler auftritt. Dieses Ereignis enthält eine detaillierte Fehlermeldung und die Schlüssel der Amazon Simple Storage Service (Amazon S3) -Objekte, die die unverarbeiteten Kanalnachrichten speichern. Sie können die Amazon S3 S3-Schlüssel verwenden, um die unverarbeiteten Kanalnachrichten erneut zu verarbeiten. Weitere Informationen finden Sie unter Kanalnachrichten erneut verarbeiten Die StartPipelineReprocessingAPI in der AWS IoT Analytics API-Referenz und Was ist Amazon CloudWatch Events im Amazon CloudWatch Events-Benutzerhandbuch.

Sie können auch Ziele konfigurieren, die es Amazon CloudWatch Events ermöglichen, Benachrichtigungen zu senden oder weitere Aktionen zu ergreifen. Sie können die Benachrichtigung beispielsweise an eine Amazon Simple Queue Service (Amazon SQS) -Warteschlange senden und dann die StartReprocessingMessage API aufrufen, um die in den Amazon S3 S3-Objekten gespeicherten Kanalnachrichten zu verarbeiten. Amazon CloudWatch Events unterstützt viele Arten von Zielen, wie z. B. die folgenden:

• Amazon Kinesis Streams

• AWS Lambda Funktionen

• Amazon Simple Notification Service (Amazon SNS)-Themen

• Amazon Simple Queue Service (Amazon SQS)-Warteschlangen

Eine Liste der unterstützten Ziele finden Sie unter Amazon EventBridge Targets im EventBridge Amazon-Benutzerhandbuch.

Ihre CloudWatch Event-Ressourcen und die zugehörigen Ziele müssen sich in der AWS Region befinden, in der Sie Ihre AWS IoT Analytics Ressourcen erstellt haben. Weitere Informationen finden Sie unter Dienstendpunkte und Kontingente in der Allgemeine AWS-Referenz.

Die an Amazon CloudWatch Events gesendete Benachrichtigung für Laufzeitfehler in der AWS Lambda Aktivität verwendet das folgende Format.

{
    "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"
    }
}

Beispiel für eine Benachrichtigung:

{
    "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"
    }
}