Day11 NiFi & NiFi Registry

在Day3 Pipeline 如何做版本控制 - NiFi Registry就有提到 NiFi Registry 的概念，而今天我们来进一步地讲一下如何在 NiFi Registry 操作，来让 NiFi 的 Data Pipeline 做到版本控制。

对接 NiFi Registry

在开始要使用 NiFi Registry 之前，首先要先来设定好 NiFi Registry 的位置，这样 NiFi 才知道该将版控放到哪一个地方去，首先一样先来看一下主画面，在 Global Menu 点选 Controller Setting：

接着点选 REGISTRY CLIENT:

然而因为我们是采用 Docker 来建置环境，并且将这 NiFi 和 NiFi Registry 的服务设定在同一个网路下，所以采用 172.17.0.1 来指定 NiFi Registry 的位置，参考如下:

设定好按下 UPDATE 就没有问题了！

如果各位读者们还记得我在Day3 Pipeline 如何做版本控制 - NiFi Registry所画的架构图，在 NiFi Registry 操作时，如果要开始做版本控制，首先必须要先 Create Bucket，再让 NiFi 将版控存到对应的 Bucket 底下

所以我们先来建立 Bucket，读者们若启动玩服务之後可以点选 http://localhost:18080/nifi-registry/#/administration/workflow 就可以看到如下画面:

然而当我们点选红框的 New Bucket 时，会跳出以下画面，接着输入 Bucket Name，这边我输入 titanic 为例:

接着刚刚原本的画面，就可以看到我们刚刚所建立的新 Bucket：

如此一来，在 NiFi Registry 的建立 Bucket 步骤就完成了。

一旦我们在 NiFi Registry 的建立完 Bucket，接着带大家再回来到 NiFi 教如何开始做版控，还记得最小单位是 Processor Group(PG) 这件事吗？所以我们仍以 PG 作为单位来做范例。

一样我们在要做版控的 PG 点击右键，可以看到 Version -> Start Version Control:

按下 Start Version Control 之後，我们会看到如下画面：

此时，NiFi 已经帮我们刚刚在 NiFi Registry 建立的 Bucket synch 过来了，然而底下有一些要再额外设定的config，这里说明一下：

所以以我的例子，这边填完之後长得下图呈现:

再来当我们按下 Save，会看到 PG 会多一个 绿色打勾的符号，就代表 Commit 成功且开始进入到版控模式：

我们再回过头来到 NiFi Registry，就可以看到我们刚刚 commit 的结果:

透过上面的操作，我们就可以知道对 Data Pipeline 做版本控制，简单步骤整理如下:

接下来再继续介绍一个场景，如果我们後续又在对这个 PG 做了一些修正，像是参数、Processor 或是 Controller Service 的调整等，NiFi 会自动侦测到目前『已不是』最新的版本了，此时会发现到 PG 的符号变成了 黑色米字号:

此时就代表我们若修改完成时，要再提交一个版本上去，这时候再点击右键时会看到 Version 底下的状态不一样了：

多出了 3 个功能，介绍说明如下：

Commit local changes
这就是 commit 你刚刚修正完的东西到 NiFi Registry，接着你会发现这次就只要输入 comment 即可:
Show local changes
会呈现出这次的修正包含哪一些，大概会像如下的画面:
Revert local changes
直接取消这次的修正，回到最新版的状况