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

本页介绍了如何在 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 中打开实例，请点击实例，然后点击查看实例。

      转到实例

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

后续步骤