DolphinScheduler 是一个分布式、可扩展的工作流调度程序平台，以其强大的容错性和易用性而闻名。本文为您介绍如何使用 DolphinScheduler 连接 ByteHouse 进行数据查询分析。

数据源

使用 DolphinScheduler 连接 ByteHouse 时，当前支持以下三种方式连接：

• 通过 ByteHouse 数据源（推荐）：使用 ByteHouse 提供的连接插件进行连接，更推荐此种方式，使用此种方式时，您需要参考下文下载 ByteHouse 的连接插件。
• 通过 MySQL 数据源：使用标准的连接协议/连接器进行连接。
  由于 DolphinScheduler 没有自带 MySQL 的驱动程序，使用此种方式时，您需要参考下文手动下载驱动并移动到 DolphinScheduler 的指定目录。
• 通过 ClickHouse 数据源：使用标准的连接协议/连接器进行连接。

细分项	已验证版本/注意事项
DolphinScheduler-含 ByteHouse 驱动 说明 使用 ByteHouse 数据源方式连接 ByteHouse 时需要。	v3.1.9 apache-dolphinscheduler-3.1.9-bin.tar.gz 未知大小
DolphinScheduler-常规版本，不含 ByteHouse 驱动 说明 使用 MySQL、ClickHouse 数据源方式连接 ByteHouse 时需要。	v3.1.2 或以上版本，DolphinScheduler-常规版本下载链接
MySQL 驱动 说明 使用 MySQL 数据源方式连接 ByteHous e时需要。	8.0.16，MySQL驱动下载链接
已获取 ByteHouse 帐户 API Token	API Token 的获取方式请参阅文档 获取 API Token。

step1 配置网络域名

登录并进入 ByteHouse 控制台后，在顶部租户管理的基本信息页面，查看网络组配置，确认已绑定 VPC，并绑定了公网域名。

• 如果未绑定 VPC 和公网域名，需参考设置网络信息文档完成绑定配置。
• 完成绑定后，可单击复制公网域名，用于后续对接参数配置。

step2 设置默认计算组

进入顶部租户管理的参数设置页面，查看已设置了默认计算组，并确保此计算组是正在运行的状态，未被停止。后续对接 ByteHouse 后的数据查询等操作，即会使用此处配置的默认计算组。

step 3 获取连接串的用户及密码信息

IAM 用户使用 API Key 作为连接密码，您可进入顶部租户管理的连接信息页面，在 API Key 模块新建一个 API key，并将 API Key 保存至本地，用于后续的配置使用。

step1 准备工作

1. 在使用之前，请提前准备好 Dolphin scheduler v3.1.2 或以上版本环境。以下为简单的安装步骤示例。

   说明

   出于演示目的，以下将使用独立部署环境作为操作示例。

   • Docker 安装：

     docker run --name dolphinscheduler-standalone-server -p 12345:12345 -p 25333:25333 -d apache/dolphinscheduler-standalone-server:3.1.2
     

   • 二进制安装：

     1. 获取安装包，您可根据实际需要选择下载常规版本或含 ByteHouse 驱动版本的 DolphinScheduler 安装包，下载方式可参考上文的注意事项章节。
     2. 解压后启动独立部署的服务器。

        tar -xvzf apache-dolphinscheduler-*-bin.tar.gz
        cd apache-dolphinscheduler-*-bin
        bash ./bin/dolphinscheduler-daemon.sh start standalone-server
        

2. 登录 DolphinScheduler 主页，如 http://localhost:12345/dolphinscheduler/ui/login，并填写账号与用户名。安装后的默认用户名/密码是：admin/dolphinscheduler123。
   

3. 单击顶部 Security 页签进入 Security 页面后，单击 Create Tenant，创建一个新的租户。
   

step2 创建数据源

单击顶部 DataSource 页签，进入数据源页面，单击 Create DataSource，创建数据源。

您可根据业务需要选择创建以下三种数据源中的一种，后续均可使用对应数据源连接 ByteHouse。

方式 1：ByteHouse 数据源

方式 2：MySQL 数据源

1. 下载 MySQL 驱动，并移动到 DolphinScheduler 指定目录。

   1. 单击 MySQL驱动下载链接 下载驱动，已验证 8.0.16 版本，建议您使用此版本。
   2. 将下载的驱动 jar 包移动到指定目录。本示例的独立部署场景下，需移动到：standalone-server/libs/standalone-server/。

      // For Docker Installation
      docker cp ~/Downloads/mysql-connector-j-8.0.31.jar {DOCKER_CONTAINER_ID}:/opt/dolphinscheduler/libs/standalone-server/
      
      // For Binary Installation
      cp ~/Downloads/mysql-connector-java-8.0.16/mysql-connector-java-8.0.16.jar standalone-server/libs/standalone-server
      

2. 重启 DolphinScheduler。

   // For Docker Installation
   // Stop Container
   docker stop {DOCKER_CONTAINER_ID}
   // Start Container
   docker start {DOCKER_CONTAINER_ID}
   
   // For Binary Installation
   // Stop Server
   bash ./bin/dolphinscheduler-daemon.sh stop standalone-server
   // Start Server
   bash ./bin/dolphinscheduler-daemon.sh start standalone-server
   

3. 新建 MySQL 数据源。
   

   参数	使用 IAM 用户连接
   Datasource	选择 MySQL。
   Datasource Name	自定义数据源名称。
   IP	配置为 ByteHouse 的网络域名，格式为：tenant-{TENANT_ID}-{REGION}-public.bytehouse.volces.com，您可以在 ByteHouse 控制台的租户管理>基本信息>网络信息中获取。详情请参见 步骤二：配置网络信息。
   Port	数据库端口号，配置为固定取值：3306。
   User Name & Password	登录 ByteHouse 数据库的用户名和密码。 User Name 默认为 bytehouse。 密码为 <API_Key>，可以在 ByteHouse 控制台>租户管理>连接信息中获取的 API Key。详情请参见获取 API Key。
   Database Name	配置为 ByteHouse 已创建的数据库名称。
   jdbc connect parameters	在连接参数中配置 SSL 开关参数，打开 SSL 开关。 "enabledTLSProtocols": "TLSv1.2" 注意 ByteHouse 需要加密认证，从而保护数据安全，因此您需打开 SSL，否则后续连接时会报错： Caused by: javax.net.ssl.SSLHandshakeException: No appropriate protocol (protocol is disabled or cipher suites are inappropriate)

方式 3：ClickHouse 数据源

{
 "ssl": "true",
 "sslmode": "NONE"
}

java.net.SocketException: Unexpected end of file from server

step3 结果验证

完成数据源创建后，后续您即可使用数据源连接 ByteHouse 进行数据查询分析。以下以一个简单操作作为示例。

1. 创建一个新的项目。
   
2. 创建一个新的工作流。单击该项目，然后转到 Workflow > Workflow Definition > Create Workflow，来创建一个工作流。
   
3. 创建一个 SQL 节点。
   选择一个 SQL 类型的工作流节点，并将节点拖拽到工作流画布中，自定义配置工作流节点的名称，例如：ByteHouseSQLSELECT。
   
4. 在节点的 Datasource types 中选择希望使用的数据源类型，在 Datasource instances 中选择已创建的数据源，在 SQL Statement 中写入查询语句，完成配置后单击 Confirm。
   
5. 回到工作流页面后单击 Save，配置工作流名称等参数后，保存工作流。
   
6. 运行 SQL 工作流。
   
   如果有弹窗提示您需要设置运行参数，可保持默认参数，单击 Confirm。
   
7. 查看工作流运行状态与运行日志。
   • 您可以在 Task Instance 页面中查看工作流运行状态。
     
   • 在 Operation 列也查看详细运行日志。