计划查询通知消息 - Amazon Timestream

要获得与亚马逊 Timestream 类似的功能 LiveAnalytics，可以考虑适用于 InfluxDB 的亚马逊 Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间，以实现实时分析。点击此处了解更多信息。

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

计划查询通知消息

本部分介绍适用于 LiveAnalytics 的 Timestream 在创建、删除、运行或更新计划查询状态时发送的消息。

通知消息名称 结构 描述

CreatingNotificationMessage

 
CreatingNotificationMessage {
    String arn;
    NotificationType type;
}

此通知消息在发送 CreateScheduledQuery 的响应之前发送。发送此通知后，会启用计划查询。

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

type：SCHEDULED_QUERY_CREATING

UpdateNotificationMessage

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

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

  • AssumeRole 失败

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

  • 计划查询运行过程中遇到的任何 4xx 错误。

  • 摄取查询结果过程中遇到的任何 4xx 错误

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

type：SCHEDULED_QUERY_UPDATE

state：启用或禁用

DeleteNotificationMessage

 
DeletionNotificationMessage {
    String arn;
    NotificationType type;
}

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

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

type：SCHEDULED_QUERY_DELETED

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：AUTO_TRIGGER_SUCCESS 或 MANUAL_TRIGGER_SUCCESS。

nextInvocationEpochSecond：适用于 LiveAnalytics 的 Timestream 下次运行计划查询的时间。

runSummary：有关计划查询运行的信息。

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：AUTO_TRIGGER_FAILURE 或 MANUAL_TRIGGER_FAILURE。

runSummary：有关计划查询运行的信息。