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

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

准备工作

将 Debezium 参数传递给复制作业

如需将 Debezium 参数传递给 Cloud Data Fusion 中的 MySQL 或 SQL Server 复制作业，请指定以 source.connector 为前缀的运行时参数。

控制台

  1. 转到您的实例：

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

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

      转到实例

  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

转到“Preferences”并设置主键参数。

在 SQL Server 复制中为快照配置隔离模式

如需详细了解隔离模式的运行时参数，请参阅 SQL Server 复制中的隔离级别。

后续步骤