将运行时参数传递给复制作业

本页面介绍了如何在 Cloud Data Fusion 中传递运行时参数 复制作业。

将 Debezium 参数传递给复制作业

将参数从 Debezium 应用传递到 MySQL 或 SQL Server Cloud Data Fusion 中的复制作业，请使用 前缀 source.connector。

控制台

  1. 前往您的实例：

    1. 在 Google Cloud 控制台中，转到 Cloud Data Fusion 页面。

    2. 如需在 Cloud Data Fusion Studio 中打开实例，请点击实例，然后点击查看实例。

      转到实例

  2. 点击 菜单 > 控制中心。

  3. 找到复制作业的应用，然后点击 偏好设置。系统随即会打开偏好设置窗口。

  4. 在键字段中，为 为复制作业添加 source.connector 前缀。

    转到“偏好设置”并输入 source.connector 作为键的前缀。

  5. 点击保存并关闭。

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 复制功能中的隔离级别。

后续步骤