预设查询通知消息 - Amazon Timestream
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

从2025年6月20日起，亚马逊Timestream版 LiveAnalytics 将不再向新客户开放。如果您想使用亚马逊 Timestream LiveAnalytics，请在该日期之前注册。现有客户可以继续照常使用该服务。有关更多信息，请参阅 Amazon Timestream 以了解 LiveAnalytics 可用性变更。

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

预设查询通知消息

本节介绍创建、删除、运行或更新计划查询状态 LiveAnalytics 时由 Timestream 发送的消息。

通知消息名称 结构 描述

CreatingNotificationMessage

 
CreatingNotificationMessage {
    String arn;
    NotificationType type;
}

此通知消息是在发送回复之前发送的CreateScheduledQuery。发送此通知后，将启用计划查询。

arn-正在创建的计划查询的 ARN。

type-计划查询_创建

UpdateNotificationMessage

 
 UpdateNotificationMessage {
    String arn;
    NotificationType type;
    QueryState state;
}

此通知消息是在计划查询更新时发送的。Timestream for LiveAnalytics 可以自动禁用定时查询，以防遇到不可恢复的错误，例如：

  • AssumeRole 失败

  • 指定客户托管的 KMS 密钥后，与 KMS 通信时遇到的任何 4xx 错误。

  • 运行计划查询期间遇到的任何 4xx 错误。

  • 在提取查询结果期间遇到的任何 4xx 错误

arn-正在更新的计划查询的 ARN。

类型-预定查询更新

状态-启用或禁用

DeleteNotificationMessage

 
DeletionNotificationMessage {
    String arn;
    NotificationType type;
}

此通知消息是在计划查询被删除后发送的。

arn-正在创建的计划查询的 ARN。

类型-已调度查询已删除

SuccessNotificationMessage

 
SuccessNotificationMessage {
    NotificationType type;
    String arn;
    Date nextInvocationEpochSecond;
    ScheduledQueryRunSummary runSummary;
}

ScheduledQueryRunSummary {
    Date invocationTime;
    Date triggerTime;
    String runStatus;
    ExecutionStats executionstats;
    ErrorReportLocation errorReportLocation;
    String failureReason;
}


ExecutionStats {
    Long bytesMetered;
    Long dataWrites;
    Long queryResultRows;
    Long recordsIngested;
    Long executionTimeInMillis;
}


ErrorReportLocation {
    S3ReportLocation s3ReportLocation;
}


S3ReportLocation {
    String bucketName;
    String objectKey;
}

此通知消息是在运行计划查询并成功提取结果之后发送的。

ARN-正在删除的计划查询的 ARN。

NotificationType-自动触发成功或 MANUAL_TRIGGER_SUCCESS。

nextInvocationEpoch第二-下次 Timestream LiveAnalytics 将运行计划查询。

runS ummary-有关计划查询运行的信息。

FailureNotificationMessage

 
FailureNotificationMessage {
    NotificationType type;
    String arn;
    ScheduledQueryRunSummary runSummary;
}

ScheduledQueryRunSummary {
    Date invocationTime;
    Date triggerTime;
    String runStatus;
    ExecutionStats executionstats;
    ErrorReportLocation errorReportLocation;
    String failureReason;
}


ExecutionStats {
    Long bytesMetered;
    Long dataWrites;
    Long queryResultRows;
    Long recordsIngested;
    Long executionTimeInMillis;
}


ErrorReportLocation {
    S3ReportLocation s3ReportLocation;
}


S3ReportLocation {
    String bucketName;
    String objectKey;
}

在计划查询运行期间或获取查询结果时遇到故障时，会发送此通知消息。

arn-正在运行的计划查询的 ARN。

type-自动触发失败或手动触发失败。

runS ummary-有关计划查询运行的信息。