在即時中樞中將 Postgre SQL 資料庫 CDC 新增為來源 （預覽）

本文說明如何在 Fabric 即時中樞中將 Postgre SQL 資料庫 異動數據擷取 （CDC） 新增為事件來源。

Microsoft Fabric 事件資料流的 Postgre SQL 資料庫 異動數據擷取 （CDC） 來源連接器可讓您擷取 PostgreSQL 資料庫中目前數據的快照集。 接著，連接器會監視並記錄此數據的任何未來數據列層級變更。

注意

實時中樞目前為預覽狀態。

必要條件

• 取得具有投稿人或更高許可權的網狀架構進階工作區的存取權。

• PostgreSQL 資料庫中已註冊的使用者存取權。

• 在 PostgreSQL 資料庫中啟用 CDC。

  如果您有 適用於 PostgreSQL 的 Azure 資料庫，請遵循下一節中的步驟來啟用 CDC。 如需詳細資訊，請參閱邏輯複寫和邏輯解碼 - 適用於 PostgreSQL 的 Azure 資料庫 - 彈性伺服器。

  如需其他 PostgreSQL 資料庫，請參閱 PostgreSQL 的 Debezium 連接器：:D ebezium 檔。

注意

不支援多個資料表 CDC。

在適用於 PostgreSQL 的 Azure 資料庫中啟用自動成長。

若要在 適用於 PostgreSQL 的 Azure 資料庫 中啟用 CDC，請根據您的部署類型遵循這些步驟。

適用於 PostgreSQL 的 Azure 資料庫單一伺服器

1. 移至 Azure 入口網站 上的 [複寫] 頁面。

2. 將復寫規則變更為 [邏輯]。

   

適用於 PostgreSQL 的 Azure 資料庫彈性伺服器

1. 從適用於 PostgreSQL 的 Azure 資料庫彈性伺服器 Microsoft Azure 入口網站頁面，[資源] 功能表的 [設定] 區段中，選取 [伺服器參數]。

2. 在 [ 伺服器參數] 頁面上：

   • 將 wal_level 設定為 logical。

   • 將 max_worker_processes 更新為至少 16。

     

3. 儲存變更並重新啟動伺服器。

4. 確認適用於 PostgreSQL 的 Azure 資料庫彈性伺服器執行個體允許來自連線資源的網路流量。

5. 執行下列 SQL 語句， 以授與系統管理員用戶 復寫權限。

   ALTER ROLE <admin user> WITH REPLICATION;
   

啟動 [新增來源體驗]

1. 登入 Microsoft Fabric。

2. 選取 左側導覽列上的 [實時中樞 ]。

3. 在 [ 即時中樞 ] 頁面上，選取 頁面右上角的 [+ 新增來源 ]。

   

使用新增 Postgre SQL 資料庫 CDC 作為來源區段的指示。

Microsoft來源頁面

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

2. 在 [ 來源 ] 下拉式清單中，選取 [PostgreSQL （CDC）]。

3. 針對 [訂用帳戶]，選取具有 Azure My SQL 資料庫 帳戶資源群組的 Azure 訂用帳戶。

4. 針對 [資源群組]，選取具有資料庫的資源群組。

5. 針對 [ 區域]，選取資料庫所在的位置。

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

   

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

以適用於 PostgreSQL 的 Azure 資料庫作為來源

1. 在 [選取數據源] 畫面上，選取 [適用於 PostgreSQL 的 Azure DB] [CDC]。

   

2. 在 [ 連線] 頁面上，選取 [移至資源 ] 以流覽至 Azure PostgreSQL 資料庫。 在 [概觀] 頁面上，記下 [伺服器名稱] 的值。 它的格式如下：myazurepostgresqlserver.postgres.database.azure.com。

   

3. 在 [連線] 頁面上，選取 [新的連線]。

   

4. 在連線設定區段中，輸入下列資訊。

   • 伺服器：PostgreSQL 資料庫的伺服器位址，例如 my-pgsql-server.postgres.database.azure.com。

   • 資料庫：資料庫名稱，例如 my_database。

     

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

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

   2. 針對 [ 驗證種類]，選取 [ 基本]。

      注意

      目前，Fabric 事件串流僅支援基本身份驗證。

   3. 輸入資料庫的使用者名稱和密碼。

   4. 選取 Connect。

      

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

   1. 對於資料表，請輸入資料表名稱。

   2. 針對 [ 埠]，輸入埠號碼或保留預設值：5432。

   3. 針對 eventstream 名稱，輸入 eventstream 的名稱。 精靈會使用選取的Postgre SQL 資料庫 CDC作為來源，建立事件串流。

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

   5. 請選取頁面底部的下一步。

      

7. 在 [ 檢閱和建立] 畫面上檢閱摘要，然後選取 [ 建立來源]。

   

檢視資料流詳細數據

1. 在 [檢閱並建立] 頁面上，如果您選取 [開啟事件串流]，精靈會開啟它為您建立的事件串流，並以選取的 Postgre SQL 資料庫 CDC 作為來源。 若要關閉精靈，請選取 頁面底部的 [關閉 ]。

   

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

   

相關內容

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

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