排程查詢通知訊息 - Amazon Timestream

自 2025 年 6 月 20 日起，Amazon Timestream for LiveAnalytics 將不再向新客戶開放。如果您想要使用 Amazon Timestream for LiveAnalytics，請在該日期之前註冊。現有客戶可以繼續正常使用服務。如需詳細資訊，請參閱 Amazon Timestream for LiveAnalytics 可用性變更。

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

排程查詢通知訊息

本節說明 Timestream for LiveAnalytics 在建立、刪除、執行或更新排程查詢狀態時傳送的訊息。

通知訊息名稱 結構 描述

CreatingNotificationMessage

 
CreatingNotificationMessage {
    String arn;
    NotificationType type;
}

此通知訊息會在傳送 的回應之前傳送CreateScheduledQuery。傳送此通知後，就會啟用排程查詢。

arn - 正在建立之排程查詢的 ARN。

類型 - SCHEDULED_QUERY_CREATING

UpdateNotificationMessage

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

更新排程查詢時，會傳送此通知訊息。LiveAnalytics 的 Timestream 可以自動停用排程查詢，以防發生無法復原的錯誤，例如：

  • AssumeRole 失敗

  • 指定客戶受管 KMS 金鑰時，與 KMS 通訊時遇到的任何 4xx 錯誤。

  • 在執行排程查詢期間遇到的任何 4xx 錯誤。

  • 擷取查詢結果期間遇到的任何 4xx 錯誤

arn - 正在更新之排程查詢的 ARN。

類型 - SCHEDULED_QUERY_UPDATE

狀態 - 啟用或停用

DeleteNotificationMessage

 
DeletionNotificationMessage {
    String arn;
    NotificationType type;
}

刪除排程查詢時，會傳送此通知訊息。

arn - 正在建立之排程查詢的 ARN。

類型 - 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 - 下次 Timestream for 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 - 排程查詢執行的相關資訊。