將 Postgre SQL 資料庫 CDC 來源新增至事件串流（預覽）

發行項
06/18/2024

本文說明如何將 Postgre SQL 資料庫異動數據擷取（CDC）來源新增至事件數據流。

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

重要

Fabric 事件數據流的增強功能目前為預覽狀態。

注意

工作區容量的下列區域不支援此來源： 美國西部 3、 瑞士西部。

必要條件

具有參與者或更高許可權的網狀架構進階工作區存取權。
PostgreSQL 資料庫中已註冊的使用者存取權。
您的 PostgreSQL 資料庫必須可公開存取，且不得位於防火牆後方或虛擬網路中受到保護。
在 PostgreSQL 資料庫和資料表中啟用 CDC。

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

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

注意

一個事件數據流的來源和目的地數目上限為 11。

在您的適用於 PostgreSQL 的 Azure 資料庫中啟用 CDC

若要在適用於 PostgreSQL 的 Azure 資料庫彈性伺服器中啟用 CDC，請遵循下列步驟：

在 Azure 入口網站的 [適用於 PostgreSQL 的 Azure 資料庫彈性伺服器] 頁面上，選取導覽功能表中的 [伺服器參數]。
在 [ 伺服器參數] 頁面上：
- 將wal_level設定為邏輯。
- 將 max_worker_processes 更新為至少 16。
儲存變更並重新啟動伺服器。
確認您的適用於 PostgreSQL 的 Azure 資料庫彈性伺服器實例允許公用網路流量。
執行下列 SQL 語句， 以授與系統管理員用戶 復寫許可權。如果您想要使用其他使用者帳戶來連線 PostgreSQL DB 來擷取 CDC，請確定使用者是 數據表擁有者。
```
ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
```

將適用於 PostgreSQL 的 Azure 資料庫 CDC 新增為來源

選取 [Eventstream ] 以建立新的 Eventstream。請確定 [增強功能][預覽] 選項已啟用。
在下一個畫面上，選取 [ 新增外部來源]。

設定並連線到適用於 PostgreSQL 的 Azure 資料庫 CDC

在 [選取數據源] 畫面上，選取 [適用於 PostgreSQL 的 Azure DB] [CDC]。
在 [ 連線] 頁面上，選取 [ 新增連線]。
在 [ 連線設定] 區段中，輸入下列資訊。
- 伺服器:P ostgreSQL 資料庫的伺服器位址，例如 my-pgsql-server.postgres.database.azure.com。
- 資料庫：資料庫名稱，例如 my_database。
向下卷動，然後在 [ 連線認證 ] 區段中，遵循下列步驟。
1. 針對 [ 連線名稱]，輸入連接的名稱。
2. 針對 [ 驗證種類]，選取 [ 基本]。
  
  注意
  
  目前，Fabric 事件數據流僅 支援基本 身份驗證。
3. 輸入資料庫的使用者名稱和密碼。
4. 選取 Connect。
現在，在 [ 連線] 頁面上，執行下列步驟：
1. 針對 table，輸入數據表名稱。
2. 針對 [ 埠]，輸入埠號碼或保留預設值：5432。
3. 請選取頁面底部的下一步。
在 [ 檢閱和建立] 畫面上檢閱摘要，然後選取 [ 新增]。