將執行階段引數傳遞至複製工作

本頁面說明如何在 Cloud Data Fusion 複製工作中傳遞執行階段引數。

將 Debezium 引數傳遞至複製工作

如要將引數從 Debezium 應用程式傳遞至 Cloud Data Fusion 中的 MySQL 或 SQL Server 複製工作,請使用前置字串 source.connector 指定執行階段引數。

控制台

  1. 前往您的執行個體:

    1. 在 Google Cloud 控制台中,前往 Cloud Data Fusion 頁面。

    2. 如要在 Cloud Data Fusion Studio 中開啟執行個體,請依序按一下「Instances」和「View instance」

      前往「Instances」(執行個體)

  2. 依序按一下 「選單」圖示 >「控制中心」

  3. 找出複寫工作的「應用程式」,然後按一下 「偏好設定」。「Preferences」視窗隨即開啟。

  4. 在「Key」欄位中,請在複本工作執行階段引數前方加上前置字串 source.connector

    前往「偏好設定」,並在「金鑰」前方輸入「source.connector」。

  5. 按一下「Save & Close」

REST API

如要使用 REST API 設定執行階段引數,請參閱 CDAP 偏好設定微服務參考資料。

設定 JDBC 參數

如要將 JDBC 參數傳遞至 MySQL 或 SQL Server 複製工作,請指定前面加上 source.connector.database 的執行階段引數。

舉例來說,如要將 JDBC 參數 sessionVariables 設為 MAX_EXECUTION_TIME=43200000,請使用鍵 source.connector.database.sessionVariables 和值 MAX_EXECUTION_TIME=43200000設定執行階段引數

如要設定多個 JDBC 參數,請為每個參數設定執行階段引數。舉例來說,如要設定 JDBC 參數 encrypt=true&trustServerCertificate=true,請傳遞下列引數:

source.connector.database.encrypt true
source.connector.database.trustServerCertificate true

設定主鍵參數

要複製的來源資料表必須具備主鍵。只有在 Oracle 是來源資料庫時,才需要嚴格遵守這項規定。針對 SQL Server 和 MySQL 來源,您可以指定自訂主鍵,即使來源資料表沒有主鍵也一樣。

使用以下執行階段引數設定 key 參數:

source.connector.message.key.columns = SCHEMA.TABLE:KEY_COLUMN

更改下列內容:

  • SCHEMA:來源結構定義的名稱。
  • TABLE:來源資料表名稱。
  • KEY_COLUMN:包含安全金鑰的資料欄。

您可以使用 key 屬性為多個資料表設定主鍵。以下範例說明如何為資料表 inventory.customerspurchase.orders 設定索引鍵:

source.connector.message.key.columns = inventory.customers:pk1,pk2;purchase.orders:pk3,pk4

前往「偏好設定」並設定主鍵參數。

在 SQL Server 複製作業中,為快照設定隔離模式

如要進一步瞭解隔離模式的執行階段引數,請參閱「SQL Server 複製作業中的隔離等級」。

後續步驟