使用亞馬遜 CloudWatch 活動監控 - AWS IoT Analytics

AWS IoT Analytics 不再提供給新客戶。的現有客戶 AWS IoT Analytics 可以繼續正常使用服務。進一步了解

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

使用亞馬遜 CloudWatch 活動監控

AWS IoT Analytics活動期間發生執行階段錯誤時,會自AWS Lambda動將事件發佈至 Amazon CloudWatch 事件。此事件包含詳細的錯誤訊息,以及存放未處理通道訊息的 Amazon Simple Storage Service (Amazon S3) 物件。您可以使用 Amazon S3 金鑰重新處理未處理的通道訊息。如需詳細資訊重新處理頻道消息,請參閱 StartPipelineReprocessingAPI 參考中的AWS IoT Analytics API 以及 Amazon CloudWatch 事件使用者指南中的「什麼是亞馬遜 CloudWatch 事件」。

您也可以設定讓 Amazon CloudWatch 事件傳送通知或採取進一步動作的目標。例如,您可以將通知傳送至 Amazon Simple Queue Service (Amazon SQS) 佇列,然後呼叫StartReprocessingMessage API 處理 Amazon S3 物件中儲存的通道訊息,以處理儲存在 Amazon S3 物件中的通道訊息。Amazon CloudWatch 活動支援多種類型的目標,例如:

  • Amazon Kinesis Streams

  • AWS Lambda 函式

  • Amazon Simple Notification Service (Amazon SNS) 主題

  • Amazon Simple Queue Service (Amazon SQS) 佇列

如需支援的目標清單,請參閱 Amazon EventBridge 使用者指南中的 Amazon EventBridge 目標

您的 CloudWatch 事件資源和關聯的目標必須位於您建立AWS IoT Analytics資源的AWS區域中。如需詳細資訊,請參閱《AWS 一般參考》中的服務端點和配額

針對AWS Lambda活動中的執行階段錯誤,傳送給 Amazon E CloudWatch vents 的通知會使用下列格式。

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