在即時中樞中將 Azure Cosmos DB CDC 新增為來源

本文說明如何將適用於 NoSQL 的 Azure Cosmos DB 異動數據擷取 （CDC） 新增為 Fabric 實時中樞的事件來源。

Azure Cosmos DB 異動數據擷取 （CDC） 來源連接器可讓您擷取 Azure Cosmos DB 資料庫中目前數據的快照集。 接著，連接器會監視並記錄此數據的任何未來數據列層級變更。 在資料流中擷取變更之後，您可以即時處理此 CDC 數據，並將其傳送至 Fabric 內的不同目的地，以進行進一步處理或分析。

必要條件

• 在 Fabric 容量授權模式中存取工作區，或具有參與者或更高許可權的試用版授權模式。
• 存取適用於 NoSQL 的 Azure Cosmos DB 帳戶和資料庫。
• Azure Cosmos DB for NoSQL 資料庫必須可公開存取，且不可位於防火牆後方或在 Azure 虛擬網路中受保護。
• 如果您沒有 eventstream， 請建立 eventstream。

從 Azure 入口網站取得連接字串詳細資料

下列步驟會顯示您需要從 Azure 入口網站 收集之項目的標籤。 您一律需要端點 URI，格式如下 https://<account>.<api>.azure.com:<port>/：、主鍵，以及您想要收集數據的資料庫名稱和專案識別碼。

注意

適用於 NoSQL CDC 的 Azure Cosmos DB 使用 Azure Cosmos DB 變更摘要的最新版本模式。 它會擷取最新版本中記錄的變更。 請注意，此模式不會擷取刪除。

1. 在 Azure Cosmos DB 帳戶頁面上，選取左側導覽中 [設定] 下的 [金鑰]。

2. 在 [ 金鑰 ] 頁面上，複製 URI 和 主要金鑰 值，以用於設定事件資料流連線。

   

3. 在 Azure Cosmos DB 帳戶的 [Azure 入口網站 概觀] 頁面上，記下您要收集數據的資料庫和專案識別碼。

   

從 Azure Cosmos DB CDC 取得事件

您可以透過下列其中一種方式，從 Azure Cosmos DB CDC 取得事件到即時中樞：

• 使用新增 來源 體驗
• 使用 [Microsoft來源] 頁面

資料來源頁面

1. 登入 Microsoft Fabric。

2. 如果您在頁面左下角看到 Power BI，請選取 [Power BI]，然後選取 [Fabric]，以切換至 Fabric 工作負載。

   

3. 選取 左側導覽列上的 [即時 ]。

   

4. 在 [即時中樞] 頁面上，選取左側導覽功能表上 [聯機到] 底下的 [+ 數據源]。

   

   您也可以選取右上角的 [+ 連接資料源] 按鈕，從 [所有數據流] 或 [我的數據流] 頁面取得 [數據源] 頁面。

   

使用新增 Azure Cosmos DB CDC 作為來源 區段的指示。

Microsoft來源頁面

1. 在 [實時中樞] 中，選取 [Microsoft來源]。

2. 在 [繫結類型] 下拉式清單中，選取 [Azure Cosmos DB]。

3. 針對 [ 訂用帳戶]，選取 具有 Cosmos DB 帳戶資源群組的 Azure 訂用帳戶。

4. 針對 [ 資源群組]，選取 具有 Cosmos DB 帳戶的資源群組 。

5. 針對 [ 區域]，選取 Cosmos DB 所在的位置。

6. 現在，將滑鼠移至您想要連線到資料庫清單中的 Cosmos DB CDC 來源名稱，然後選取 [連線] 按鈕，或選取 ...。（省略號），然後選取 [連線] 按鈕。

   

   若要設定連線資訊，請使用新增 Azure Cosmos DB CDC 作為來源 區段的步驟。 在 [新增來源精靈] 中，略過選取 Azure Cosmos DB CDC 作為來源類型的第一個步驟。

將 Azure Cosmos DB CDC 新增為來源

1. 在連線頁面上，選取新增連線。

   

2. 在 [ 連線設定 ] 區段中，指定 Cosmos DB 端點。 輸入您從 Azure 入口網站 複製的 Cosmos DB 帳戶 URI 或端點。

   

3. 展開 [ 進階選項]，然後遵循下列步驟：

   1. 針對 重試次數，指定當要求從可復原錯誤失敗時，連接器應該將要求重新傳送至 Cosmos DB 資料庫的最大次數。

   2. 針對 [啟用 AVERAGE 函式關閉]，指定連接器是否應該將 AVG 聚合函數向下傳遞至 Cosmos DB 資料庫。

   3. 針對 [ 啟用多個數據行的 SORT 傳遞]，指定連接器是否應在 SQL 查詢的 ORDER BY 子句中指定時，允許將多個數據行傳遞至 Cosmos DB 資料庫。

      

4. 向下卷動，然後在 [ 連線認證 ] 區段中，遵循下列步驟。

   1. 選取現有的連線，並保留預設 的 [建立新連線 ] 選項。
   2. 使用下列值建立連線：

      1. 對於連線名稱 - 輸入連線的名稱。

      2. 針對 [ 驗證種類]，選取 [ 帳戶密鑰]。

      3. 針對 [ 帳戶金鑰]，輸入您稍早儲存的金鑰值。

      4. 選取 Connect。

         

5. 現在，在 [ 連線] 頁面上，執行下列步驟：

   1. 在 Azure Cosmos DB 帳戶中指定容器的容器標識碼 。

   2. 在右側的 [ 串流詳細數據 ] 區段中，選取您要在其中儲存精靈要建立之 Eventstream 的 Fabric 工作區 。

   3. 針對 eventstream 名稱，輸入 eventstream 的名稱。 精靈會建立具有所選 Azure Cosmos DB CDC 作為來源的事件串流。

   4. 串 流名稱 會自動為您產生，方法是將 -stream 附加至事件資料流的名稱。 當精靈完成時，您可以在即時中樞 [所有數據流] 頁面上看到此數據流 。

   5. 選取 [下一步]。

      

6. 在 [ 檢閱 + 連線 ] 畫面上，檢閱摘要，然後選取 [ 建立來源]。

   

檢視資料流詳細數據

1. 在 [ 檢閱 + 連線 ] 頁面上，如果您選取 [開啟事件串流]，精靈會開啟它為您建立的事件串流，並將選取的 Azure Cosmos DB CDC 作為來源。 若要關閉精靈，請選取 頁面右上角的 [關閉 ] 或 [X*]。

   

2. 在 [實時中樞] 中，選取 [ 所有數據流]。 若要查看新的數據流，請重新整理 [ 所有數據流] 頁面。

   

   如需詳細步驟，請參閱 在網狀架構即時中樞中檢視資料流的詳細數據。

相關內容

若要瞭解如何取用資料流，請參閱下列文章：

• 處理資料流
• 分析資料流
• 設定資料流的警示