使用 Amazon 进行监控 CloudWatch 事件 - Amazon IoT Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用 Amazon 进行监控 CloudWatch 事件

Amazon IoT Analytics自动向亚马逊发布活动 CloudWatch 在Amazon Lambda活动。此事件包含详细的错误消息以及存储未处理的通道消息的 Amazon Simple Storage Service (Amazon S3) 对象的密钥。您可以使用 Amazon S3 密钥重新处理未处理的频道消息。有关更多信息,请参阅 。重新处理通道消息StartPipelineReprocessing中的 APIAmazon IoT AnalyticsAPI 参考, 和什么是 Amazon CloudWatch 事件中的亚马逊 CloudWatch 事件用户指南.

您也可以配置启用 Amazon 的目标。 CloudWatch 发送通知或采取进一步行动的事件。例如,您可以将通知发送到 Amazon Simple Queue Service (Amazon SQS) 队列,然后调用StartReprocessingMessage用于处理保存在 Amazon S3 对象中的频道消息的 API。亚马逊 CloudWatch 事件支持许多类型的目标,如下所示:

  • Amazon Kinesis Streams

  • Amazon Lambda 函数

  • Amazon Simple Notification Service (Amazon SNS) 主题

  • Amazon Simple Queue Service (Amazon SQS) 队列

有关支持的目标列表,请参阅亚马逊 EventBridge 目标中的亚马逊 EventBridge 用户指南.

您的 CloudWatch 事件资源和相关目标必须位于Amazon创建您的区域Amazon IoT Analytics资源的费用。有关更多信息,请参阅 。服务终端节点和配额中的Amazon一般参考.

发送给亚马逊的通知 CloudWatch 中的运行时错误的事件Amazon LambdaActivity 采用以下格式。

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