要获得与亚马逊 Timestream 类似的功能 LiveAnalytics，可以考虑适用于 InfluxDB 的亚马逊 Timestream。适用于 InfluxDB 的 Amazon Timestream 提供简化的数据摄取和个位数毫秒级的查询响应时间，以实现实时分析。点击[此处](https://docs.aws.amazon.com//timestream/latest/developerguide/timestream-for-influxdb.html)了解更多信息。本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。 # 计划查询通知消息本节介绍创建、删除、运行或更新计划查询状态 LiveAnalytics 时由 Timestream 发送的消息。 | 通知消息名称 | 结构 | 说明 | | --- | --- | --- | | CreatingNotificationMessage |

CreatingNotificationMessage {
    String arn;
    NotificationType type;
}

| 此通知消息在发送 `CreateScheduledQuery` 的响应之前发送。发送此通知后，会启用计划查询。
*arn*：正在创建的计划查询 ARN。
*type*：SCHEDULED\_QUERY\_CREATING | | UpdateNotificationMessage |

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

| 此通知消息在计划查询更新时发送。Timestream for LiveAnalytics 可以自动禁用定时查询，以防遇到不可恢复的错误，例如：[See the AWS documentation website for more details](http://docs.aws.amazon.com/zh_cn/timestream/latest/developerguide/scheduledqueries-notification.html)
*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*-自动触发成功或 MANUAL\_TRIGGER\_SUCCESS。
*nextInvocationEpoch第二*-下次 Timestream LiveAnalytics 将运行计划查询。
*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*：有关计划查询运行的信息。 |