步驟 3:設定應用程式輸出 - 適用於 SQL 應用程式的 Amazon Kinesis Data Analytics 開發人員指南

針對新專案,我們建議您優先選擇新的 Managed Service for Apache Flink Studio,而非 Kinesis Data Analytics for SQL 應用程式。Managed Service for Apache Flink Studio 易於使用且具備進階分析功能,可讓您在幾分鐘內建置複雜的串流處理應用程式。

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

步驟 3:設定應用程式輸出

熱點範例中,可用 Amazon Kinesis Data Analytics 應用程式碼探索串流來源的重要熱點,並為每個熱點指派熱度分數。

您現在可以將應用程式結果從應用程式內串流傳送到外部目的地,即另一個 Kinesis 資料串流 (ExampleOutputStream)。然後,您可以分析熱點分數,並確定熱點熱度的適當閾值。您可以進一步擴充此應用程式以產生提醒。

如要設定應用程式輸出
  1. https://console.aws.amazon.com/kinesis 上開啟 Kinesis Data Analytics 主控台。

  2. 在 SQL 編輯器中,選擇應用程式儀表板中的目的地新增目的地

  3. 新增目的地頁面,選擇從串流中選取。然後,選擇您在上一節建立的 ExampleOutputStream 串流。

    現在您有一個外部目的地,可讓 Amazon Kinesis Data Analytics 將應用程式寫入的任何紀錄保留在應用程式內 DESTINATION_SQL_STREAM 串流中。

  4. 您可以選擇性地設定 AWS Lambda 來監視 ExampleOutputStream 串流,並傳送提醒給您。如需更多詳細資訊,請參閱 使用 Lambda 函數作為輸出。您也可以檢閱 Kinesis Data Analytics 寫入外部目的地 (Kinesis 串流 ExampleOutputStream) 的記錄,如 步驟 4:驗證應用程式輸出 中所述。

後續步驟

步驟 4:驗證應用程式輸出