# 创建CDL数据库连接 #### 操作场景 通过CDLService WebUI创建数据库连接时，可参考该章节进行CDL作业编排。 #### 前提条件 - 已获取待连接数据对应的驱动Jar包并上传。 - 开启Kerberos认证的集群需已参考[CDL用户权限管理](https://support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_24234.html)创建具有CDL管理操作权限的用户。 #### 操作步骤 1. 使用具有CDL管理操作权限的用户或**admin** 用户（未开启Kerberos认证的集群）登录CDLService WebUI界面，请参考[登录CDLService WebUI界面](https://support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_24236.html)。 2. 选择"连接管理 \> 新增连接"，在弹出窗口中输入数据连接的名称（Name，不能与已存在的名称相同）并选择连接类型（Link Type）。 3. 根据不同的连接类型，界面信息输入数据相关链接参数。 表1MySQL数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | mysql | | Name | 连接配置名称。 | mysqllink | | DB driver | 选择已上传的MySQL驱动文件"mysql-connector-java-8.0.24.jar"。 | mysql-connector-java-8.0.24.jar | | Host | MySQL数据库IP地址。 | 10.10.10.10 | | Port | MySQL数据库端口。 | 3306 | | User | MySQL数据库访问用户。 | user | | Password | MySQL数据库访问密码。 | *user* *用户密码* | | Description | 描述信息。 | xxx | 表2PgSQL数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | pgsql | | Name | 连接配置名称。 | pgsqllink | | Host | PgSQL数据库IP地址。 | 10.10.10.10 | | Port | PgSQL数据库端口。 | 5432 | | DB Name | PgSQL数据库名称。 | testDB | | User | PgSQL数据库访问用户。 | user | | Password | PgSQL数据库访问密码。 | *user* *用户密码* | | Description | 描述信息。 | xxx | 表3Kafka数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | kafka | | Name | 连接配置名称。 | kafkalink | | Description | 描述信息。 | - | 表4Hudi数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | hudi | | Name | 连接配置名称。 | hudilink | | Storage Type | 存储类型。 hdfs：数据存储到HDFS中。 | hdfs | | Auth KeytabFile | 访问用户的keytab文件。可单击"上传文件"进行上传。 安全模式集群填写该参数，普通模式集群不显示该参数。 说明： 该文件可在Manager界面选择"系统 \> 权限 \> 用户"，在待操作用户后选择"更多 \> 下载用户凭证"获取。 | ${BIGDATA_HOME}/FusionInsight_CDL_*X.X.X* /install/FusionInsight-CDL-*X.X.X*/cdl/keytabs/cdl.keytab | | Principal | 访问用户的域名用户。 安全模式集群填写该参数，普通模式集群不显示该参数。 | cdl/test.com@HADOOP.COM | | Description | 描述信息。 | xxx | 表5thirdparty-kafka数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | thirdparty-kafka | | Name | 连接配置名称。 | thirdparty-kafkalink | | Bootstrap Servers | Kafka代理实例，即是*Kafka的Broker实例业务IP* :*Kafka端口号*。 说明： 如果以MRS Kafka作为thirdparty-kafka源端，端口号可登录Manager界面，选择"集群 \> 服务 \> Kafka \> 配置"，在搜索框中搜索端口，根据相应的加密协议获取对应的端口号。 | 10.10.10.10:21005 | | Security Protocol | 加密协议，包括： - SASL_PLAINTEXT - PLAINTEXT - SASL_SSL - SSL | SASL_SSL | | Username | 在实例创建期间启用"SASL_SSL"时指定的用户名。 说明： 仅加密协议为"SASL_PLAINTEXT"和"SASL_SSL"支持该参数。 | test | | Password | 在实例创建期间启用"SASL_SSL"时指定的密码。 说明： 仅加密协议为"SASL_PLAINTEXT"和"SASL_SSL"支持该参数。 | xxx | | SSL Truststore Location | 上传"client.truststore.jks"认证文件。 说明： 仅加密协议为"SASL_SSL"和"SSL"支持该参数。 | - | | SSL Truststore Password | "client.truststore.jks"证书文件对应的密码。 说明： 仅加密协议为"SASL_SSL"和"SSL"支持该参数。 | xxx | | Datastore Type | 上层源的类型，包括： - MRS 3.2.0版本： - opengauss - ogg - oracle - drs-avro-oracle - MRS 3.3.0及之后版本： - drs-opengauss-json - ogg-oracle-avro - drs-oracle-json - drs-oracle-avro | - opengauss - drs-opengauss-json | | DB driver | 选择已上传的thirdparty-kafka驱动文件。 说明： "Datastore Type"为"ogg"（MRS 3.3.0及之后版本为"ogg-oracle-avro"）显示该参数。 | - | | Host | thirdparty-kafka数据库的IP地址。 说明： "Datastore Type"为"oracle"（MRS 3.3.0及之后版本为"drs-oracle-json"）时不支持该参数。 | 11.11.xxx.xxx,12.12.xxx.xxx | | Port | thirdparty-kafka数据库的端口。 说明： "Datastore Type"为"oracle"（MRS 3.3.0及之后版本为"drs-oracle-json"）时不支持该参数。 | 8000 | | DB Name | thirdparty-kafka数据库名称。 说明： "Datastore Type"为"opengauss"（MRS 3.3.0及之后版本为"drs-opengauss-json"）显示该参数。 | opengaussdb | | User | thirdparty-kafka数据库访问用户。 说明： "Datastore Type"为"oracle"（MRS 3.3.0及之后版本为"drs-oracle-json"）时不支持该参数。 | opengaussuser | | DB Password | thirdparty-kafka数据库访问密码。 说明： "Datastore Type"为"oracle"（MRS 3.3.0及之后版本为"drs-oracle-json"）时不支持该参数。 | *opengaussuser用户密码* | | Sid | Oracle的服务ID。 说明： "Datastore Type"为"ogg"MRS 3.3.0及之后版本为"ogg-oracle-avro"）显示该参数。 | - | | Description | 描述信息。 | - | 表6DWS数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | dws | | Name | 连接配置名称。 | dwslink | | Host | 待连接的DWS数据库IP地址。 | 10.10.10.10 | | Port | 数据库端口。 | 8000 | | DB Name | 待连接的数据库名称。 | default | | User | 数据库访问用户。 | test | | Password | 数据库访问密码。 | xxx | | Description | 描述信息。 | - | 表7opengauss数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | opengauss | | Name | 连接配置名称。 | opengausslink | | Host | 待连接的opengauss数据库IP地址。 | 10.10.10.10 | | Port | 数据库端口。 | 8000 | | DB Name | 待连接的数据库名称。 | default | | User | 数据库访问用户。 | test | | Password | 数据库访问密码。 | xxx | | Description | 描述信息。 | - | 表8ClickHouse数据连接配置参数 | 参数名称 | 描述 | 示例 | |:---|:---|:---| | Link Type | 连接类型。 | dws | | Name | 连接配置名称。 | clickhouselink | | Host | *ClickHouse的ClickHouseBalancer实例业务IP地址:HTTP Balancer端口号* 。支持连接多个ClickHouse实例，使用**,** 分隔*。* 说明： *HTTP Balancer端口号*可登录Manager界面，选择"集群 \> 服务 \> ClickHouse \> 逻辑集群"，在集群列表的"HTTP Balancer端口号"列获取。 | 10.10.10.10:21428 | | User | 数据库访问用户。 | test | | Password | 数据库访问密码。 | xxx | | Description | 描述信息。 | - | 4. 参数配置完成后，单击"测试连接"，检查数据连通是否正常。 连接校验通过后，单击"确定"完成数据连接创建。