1.概述

本文使用 NIFI 实现如何监控某一个数据库表的变化，并将数据库变化写入到文件中。
这中间使用到了

• CaptureChangeMySQL
  关注数据库变化，及数据库表所有的变化都会被捕获，这个是实时处理的
• EvaluateJsonPath
  从数据中抽取部分数据，放到 flowfile 的属性中
• UpdateAttribute
  更新 flowfile 的 filename 属性
• PutFile
  负责将flowfile 以指定filename 属性写入到文件系统中

2. 配置过程

2.1 配置 CaptureChangeMySQL

这里配置我需要监控的 数据库，数据库表，并填写 数据库节点用户名密码

2.2 配置EvaluateJsonPath

这个步骤的作用是将 一条记录的属性抽取到 flowfile 的属性中

这里增加两个属性，这里使用的是 json path 获取 table_name 和 timestamp 时间戳。

至于我怎么知道需要这样获取。我们可以使用 nifi 的 特性，即

我们可以启动第一个CDC ,停掉 之后的任务，这样数据存在于

队列中。

比如我们在数据库表中增加一条记录，在 右键在画布中 选择 refresh 刷新。

我们看到队列中有一条数据。

可以看到队列中的数据内容。

点击查看内容

数据是一个JSON,我们可以根据 JSON path 获取 数据中的内容。

2.3 配置 UpdateAttribute

这里我们修改 filename 属性，为表名_时间戳.json

2.4 配置

这里只需要配置一下写入的目录。

配置完成后，我们点击启动，我们模拟对数据进行增改删,就会看到 putfile 配置的目录下增加了JSON文件。

这里只是 演示了一下 NIFI的基础功能及配置过程。