PostgreSQL Adapter 用於接受 PostgreSQL 的資料,會利用 CDC 監聽 PostgreSQL 資料庫的變更事件,進行即時的資料收集。
若要安裝 PostgreSQL Adapter,可以準備一個部署容器的 YAML 檔案(adapter.yaml)包括所有的相關設定,如下:
然後執行以下命令:
若要設定 PostgreSQL 資料源適配器(Adapter),可以藉由代入環境變數(Environment Variable)來達成,以下將對適配器所支援的組態參數進行詳細說明。
GRAVITY_ADAPTER_POSTGRESQL_ + ❮參數名稱❯
這裡是所有關於 GRAVITY 的相關參數,用於讓資料源適配器連接上資料節點,並註冊成為合法的資料輸入源。
參數 | 資料型態 | 預設值 | 說明 |
---|---|---|---|
GRAVITY.HOST | 字串 | 目標 GRAVITY 之主機位置 | |
GRAVITY.PORT | 整數 | 目標 GRAVITY 主機之埠號 | |
GRAVITY.DOMAIN | 字串 | gravity | 指定資料節點服務的 Domain |
ADAPTER.ADAPTER_ID | 字串 | postgres_adapter | 指定資料源適配器在資料節點上的唯一識別 ID |
ADAPTER.ADAPTER_NAME | 字串 | Postgres Adapter | 指定資料源適配器的顯示名稱 |
資料源適配器可以指定多個資料庫的來源,透過設定 GRAVITY_ADAPTER_POSTGRESQL_SOURCE_SETTINGS 環境變數,可以指定要訂閱的來源資料庫和資料表。資料源適配器會依據設定,從指定的來源獲取資料,然後輸入到 GRAVITY 資料節點。
以下設定格式用於設定多個資料源連線和訂閱資訊:
每個 PostgreSQL 來源可以設定的屬性(Property)說明如下:
來源屬性 | 資料型態 | 預設值 | 說明 |
---|---|---|---|
disabled | 布林值 | 是否停用此設定 | |
host | 字串 | 來源之主機位置 | |
port | 整數 | 來源主機之埠號 | |
username | 字串 | 來源資料庫連線帳號 | |
password | 字串 | 來源資料庫連線密碼 | |
dbname | 字串 | 來源資料庫名稱 | |
param | 字串 | 其他連線參數 | |
initialLoad | 布林值 | 是否執行初始化載入 | |
interval | 字串 | 獲取事件資料的時間間隔(單位:秒) | |
slotName | 字串 | 指定 PostgreSQL Slot 名稱 | |
tables | 物件 | 指定要接收的資料表清單 |
來源資料表的設定屬性如下:
屬性 | 資料型態 | 預設值 | 說明 |
---|---|---|---|
events.snapshot | 字串 | 自定義初始化載入事件的名稱 | |
events.create | 字串 | 自定義建立事件的名稱 | |
events.update | 字串 | 自定義變更事件的名稱 | |
events.delete | 字串 | 自定義刪除事件的名稱 |
使用PostgreSQL Adapter 接受 PostgreSQL 的資料,必須開啟 CDC 監聽 PostgreSQL 資料庫的變更事件,進行即時的資料收集,開啟 CDC 的方式如下:
設定PostgreSQL :
重新啟動PostgreSQL
建立PostgreSQL Slot ( Slot Name: regression_slot )
檢查是否建立成功