---
title: "通过 Apache NiFi 集成 OB Cloud - OB Cloud 云数据库 master | OceanBase 文档中心"
description: 通过 Apache NiFi 集成 OB Cloud Apache NiFi 是一个自动化数据流处理平台，支持在系统间实现高效可靠的数据传输。通过读取 OB Cloud 的 Binlog 数据，可将数据分发至文件系统、消息队列（如 Kafka）或 HTTP 端点等目标。 前提条件 您已注册 OB Cloud 云数据库…
image: https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*OSPzQ6GUQF4AAAAAQHAAAAgAeiGDAQ/original
---
切换语言

- 中文站 - 简体中文
- International - English
- 日本站 - 日本語

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*qbZXRo_94ZEAAAAAAAAAAAAADiGDAQ/original) OB Cloud 云数据库

# 通过 Apache NiFi 集成 OB Cloud

更新时间：2026-05-14 14:28:04

Apache NiFi 是一个自动化数据流处理平台，支持在系统间实现高效可靠的数据传输。通过读取 OB Cloud 的 Binlog 数据，可将数据分发至文件系统、消息队列（如 Kafka）或 HTTP 端点等目标。

## 前提条件

1. 您已注册 OB Cloud 云数据库账号，并创建如下资源：

      - 创建集群实例和 MySQL 兼容模式租户。详情请参见 [创建集群实例](https://www.oceanbase.com/docs/common-oceanbase-cloud-10000000001780086)、[创建租户](https://www.oceanbase.com/docs/common-oceanbase-cloud-10000000001780107)。
      - 创建数据库和账号（数据库用户）。详情请参见 [创建数据库](https://www.oceanbase.com/docs/common-oceanbase-cloud-1000000001018092)、[创建账号](https://www.oceanbase.com/docs/common-oceanbase-cloud-1000000001018091)。
      - 在创建的 MySQL 兼容模式租户下购买 Binlog 服务。详情请参见 [购买 Binlog 服务](https://www.oceanbase.com/docs/common-oceanbase-cloud-1000000004154488)。
 2. NiFi 服务器 IP 已加入 OB Cloud 集群实例白名单。详情请参见 [设置租户白名单分组](https://www.oceanbase.com/docs/common-oceanbase-cloud-10000000001780091)。
 3. 您的运行环境需满足 Java Development Kit (JDK) 1.8 或更高版本。
 4. 您已下载 [Apache NiFi 安装包](https://archive.apache.org/dist/nifi/)。

## 步骤一：配置 NiFi 运行环境

1. 解压 NiFi 安装包至目标目录。
 2. 按照如下方式修改 `conf/nifi.properties` 配置文件（本文以 HTTP 连接为例）：

   ```properties
   # 禁用 HTTPS 并配置 HTTP 访问
   nifi.web.https.host=
   nifi.web.https.port=
   nifi.web.http.host=0.0.0.0
   nifi.web.http.port=<自定义端口号>

   # 允许非安全远程连接
   nifi.remote.input.secure=false

   ```
 3. 上传 MySQL 驱动至 NiFi 服务器。
 4. 在 NiFi 安装目录下执行如下命令启动服务。如需停止服务，则执行 `bin/nifi.sh stop`。

   ```bash
   # 启动服务
   bin/nifi.sh start

   ```

## 步骤二：配置数据流处理管道

1. 通过浏览器访问 `http://<nifi_server_ip>:<port>/nifi/` 进入 NiFi 控制台。
 2. 配置 CaptureChangeMySQL Processor。

      1. 拖拽页面顶部的 Processor 图标至画布，搜索并选择 `CaptureChangeMySQL`，然后单击 **ADD**。

        ![1](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/25V1/800.integration/nifi/1.png)
      2. 在 CaptureChangeMySQL Processor 上单击右键选择 **Configure**，然后在 **PROPERTIES** 页签下配置相关参数，完成后单击 **APPLY**。

        | 属性名称 | 说明 |
        | --- | --- |
        | MySQL Nodes | OB Cloud 实例地址及端口。 |
        | MySQL Driver Class Name | JDBC 驱动类名，为 `com.mysql.cj.jdbc.Driver`。 |
        | MySQL Driver Location | 您所上传的驱动 JAR 文件所在目录。 |
        | Username | 您所创建的数据库用户的用户名。 |
        | Password | 数据库用户的密码。 |
        | Database/Schema Name Pattern | 需要读取 Binlog 的数据库（支持正则表达式）。 |
        | Table Name Pattern | 需要读取 Binlog 的表（支持正则表达式）。 |
        | Include DDL Events | 捕获 DDL 变更事件，需设置为 `true`。 |

        ![2](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/25V1/800.integration/nifi/2.png)
 3. 配置 PutFile Processor。

      1. 再次拖拽页面顶部的 Processor 图标至画布，搜索并选择 `PutFile`，然后单击 **ADD**。
      2. 在 PutFile Processor 上单击右键选择 **Configure**，然后在 **PROPERTIES** 页签下填写 `Directory` 属性，Binlog 文件将会输出到此目录下。完成后单击 **APPLY**。

        ![3](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/25V1/800.integration/nifi/3.png)
 4. 建立数据流连接。

      1. 回到画布，单击 `CaptureChangeMySQL` 上的箭头指向 `PutFile`，将两者进行连接。
      2. 在弹出的 **Create Connection** 弹窗中，单击 **ADD**。
      3. 在画布中，再次在 PutFile Processor 上单击右键选择 **Configure**，在 **RELATIONSHIPS** 页签下配置 `failure` 和 `success` 的行为策略，均选择 **terminate**。 完成后单击 **APPLY**。

        ![4](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/25V1/800.integration/nifi/4.png)
 5. 启动数据处理流程。

      1. 回到画布，在 CaptureChangeMySQL Processor 上单击右键选择 **Start**。
      2. 在 PutFile Processor 上同样单击右键选择 **Start**。

## 步骤三：验证数据同步

1. 在 OB Cloud 数据库中插入数据。
 2. 检查 PutFile 目录下有文件生成。

   ![5](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/25V1/800.integration/nifi/5.png)
 3. 查看文件内容，可以查看执行的 SQL 语句的相关信息。

   ![6](https://obbusiness-private.oss-cn-shanghai.aliyuncs.com/doc/img/cloud/25V1/800.integration/nifi/6.png)

 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线