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

本頁說明如何在 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. 找出複製作業的「應用程式」，然後按一下「偏好設定」。「偏好設定」視窗隨即開啟。

  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.customers 和 purchase.orders 設定鍵：

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

前往「偏好設定」，然後設定主鍵參數。

在 SQL Server 複製中設定快照的隔離模式

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

後續步驟