Apache NiFi用户指南

偏执的太偏执、 2022-03-02 04:46 307阅读 0赞

介绍

Apache NiFi是基于流程编程概念的数据流系统。它支持强大且可扩展的数据路由，转换和系统中介逻辑的有向图。NiFi具有基于Web的用户界面，用于设计，控制，反馈和监控数据流。它在服务质量的几个方面具有高度可配置性，例如容错与保证交付，低延迟与高吞吐量以及基于优先级的排队。NiFi为所有接收，分叉，加入克隆，修改，发送和最终在达到其配置的最终状态时丢弃的数据提供细粒度数据来源。

有关系统要求，安装和配置的信息，请参阅“ [系统管理员指南”][Link 1]。安装NiFi后，使用支持的Web浏览器查看UI。

## 浏览器支持 ##

<table> 
 <thead> 
  <tr> 
   <th>Browser</th> 
   <th>Version</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>Chrome</p> </td> 
   <td> <p>Current and Current - 1</p> </td> 
  </tr> 
  <tr> 
   <td> <p>FireFox</p> </td> 
   <td> <p>Current and Current - 1</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Edge</p> </td> 
   <td> <p>Current and Current - 1</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Safari</p> </td> 
   <td> <p>Current and Current - 1</p> </td> 
  </tr> 
 </tbody> 
</table>

Current和Current - 1表示该浏览器的当前稳定版本和前一个版本支持UI。例如，如果当前的稳定版本是45.X，那么官方支持的版本将是45.X和44.X.

对于不太频繁发布主要版本的Safari，Current和Current - 1只代表两个最新版本。

支持的浏览器版本由UI使用的功能及其使用的依赖项驱动。将针对支持的浏览器开发和测试UI功能。使用支持的浏览器的任何问题都应报告给Apache NiFi。

### 不支持的浏览器 ###

虽然UI可能在不受支持的浏览器中成功运行，但它没有针对它们进行主动测试。此外，UI被设计为桌面体验，目前在移动浏览器中不受支持。

### 在可变大小的浏览器中查看UI ###

在大多数环境中，所有UI都在浏览器中可见。但是，UI具有响应式设计，允许您根据需要在较小尺寸的浏览器或平板电脑环境中滚动屏幕。

在浏览器宽度小于800像素且高度小于600像素的环境中，UI的某些部分可能会变得不可用。

## 术语 ##

**DataFlow Manager**：DataFlow Manager（DFM）是NiFi用户，具有添加，删除和修改NiFi数据流组件的权限。

**FlowFile**：FlowFile代表NiFi中的单个数据。FlowFile由两个组件组成：FlowFile Attributes和FlowFile Content 。

Content是FlowFile表示的数据。

Attributes是提供有关数据的信息或上下文的特征; 它们由键值对组成。

所有FlowFiles都具有以下标准属性：

*  **uuid**：一个通用唯一标识符，用于区分FlowFile与系统中的其他FlowFiles。
 *  **filename**：在将数据存储到磁盘或外部服务时可以使用的可读文件名
 *  **path**：在将数据存储到磁盘或外部服务时可以使用的分层结构值，以便数据不存储在单个目录中

**Processor**：处理器是NiFi组件，用于监听传入数据; 从外部来源提取数据; 将数据发布到外部来源; 并从FlowFiles中路由，转换或提取信息。

**Relationship**：每个处理器都为其定义了零个或多个关系。命名这些关系以指示处理FlowFile的结果。处理器处理完FlowFile后，它会将FlowFile路由（或“传输”）到其中一个关系。然后，DFM能够将这些关系中的每一个连接到其他组件，以指定每个潜在处理结果下FlowFile应该在哪里进行下一步。

**Connection**：DFM通过将组件从NiFi工具栏的“组件”部分拖动到画布，然后通过Connections将组件连接在一起来创建自动数据流。每个连接由一个或多个关系组成。对于绘制的每个Connection，DFM可以确定应该为Connection使用哪些关系。这允许基于其处理结果以不同方式路由数据。每个连接都包含一个FlowFile队列。将FlowFile传输到特定关系时，会将其添加到属于关联Connection的队列中。

**Controller Service**：控制器服务是扩展点，在用户界面中由DFM添加和配置后，将在NiFi启动时启动，并提供供其他组件（如处理器或其他控制器服务）使用的信息。多个组件使用的常见Controller服务是StandardSSLContextService。它提供了一次配置密钥库和/或信任库属性的能力，并在整个应用程序中重用该配置。我们的想法是，控制器服务不是在每个可能需要它的处理器中配置这些信息，而是根据需要为任何处理器提供。

**Reporting Task**：报告任务在后台运行，以提供有关NiFi实例中发生情况的统计报告。DFM根据需要在用户界面中添加和配置报告任务。常见的报告任务包括ControllerStatusReportingTask，MonitorDiskUsage报告任务，MonitorMemory报告任务和StandardGangliaReporter。

**Funnel**：**Funnel**是一个NiFi组件，用于将来自多个Connections的数据合并到一个Connection中。

**Process Group**：当数据流变得复杂时，在更高，更抽象的层面上推断数据流通常是有益的。NiFi允许将多个组件（如处理器）组合到一个过程组中。然后，NiFi用户界面使DFM可以轻松地将多个流程组连接到逻辑数据流中，并允许DFM进入流程组以查看和操作流程组中的组件。

**Port**：使用一个或多个进程组构建的数据流需要一种方法将进程组连接到其他数据流组件。这是通过使用Ports实现的。DFM可以向进程组添加任意数量的输入端口和输出端口，并相应地命名这些端口。

**Remote Process Group**：正如数据传输进出进程组一样，有时需要将数据从一个NiFi实例传输到另一个实例。虽然NiFi提供了许多不同的机制来将数据从一个系统传输到另一个系统，但是如果将数据传输到另一个NiFi实例，远程进程组通常是实现此目的的最简单方法。

**Bulletin**：NiFi用户界面提供了大量有关应用程序当前状态的监视和反馈。除了滚动统计信息和为每个组件提供的当前状态之外，组件还能够报告公告。每当组件报告公告时，该组件上都会显示公告图标。系统级公告显示在页面顶部附近的状态栏上。使用鼠标悬停在该图标上将提供一个工具提示，显示公告的时间和严重性（调试，信息，警告，错误）以及公告的消息。也可以在全局菜单中的公告板页面中查看和过滤所有组件的公告。

**Template**：通常，数据流由许多可以重用的子流组成。NiFi允许DFM选择数据流的一部分（或整个数据流）并创建模板。此模板具有名称，然后可以像其他组件一样拖动到画布上。结果，可以将若干组件组合在一起以形成更大的构建块，从该构建块创建数据流。这些模板也可以导出为XML并导入到另一个NiFi实例中，从而可以共享这些构建块。

**flow.xml.gz**：DFM放入NiFi用户界面画布的所有内容都实时写入一个名为*flow.xml.gz的*文件。该文件`nifi/conf`默认位于目录中。在画布上进行的任何更改都会自动保存到此文件中，而无需用户单击“保存”按钮。此外，NiFi在更新时会自动在归档目录中创建此文件的备份副本。您可以使用这些归档文件来回滚流配置。为此，请停止NiFi，将*flow.xml.gz*替换为所需的备份副本，然后重新启动NiFi。在集群环境中，停止整个NiFi集群，替换其中一个节点的*flow.xml.gz*，然后重新启动该节点。删除*flow.xml.gz*来自其他节点。确认节点启动为单节点群集后，启动其他节点。替换的流配置将在群集中同步。*flow.xml.gz*的名称和位置以及自动存档行为是可配置的。有关更多详细信息，请参阅“ [系统管理员指南”][Link 2]。

## NiFi用户界面 ##

NiFi UI提供了创建自动数据流以及可视化，编辑，监视和管理这些数据流的机制。UI可以分为几个部分，每个部分负责应用程序的不同功能。本节提供应用程序的屏幕截图，并突出显示UI的不同部分。每个部分将在本文档后面进一步详细讨论。

启动应用程序后，用户可以通过转到`http://<hostname>:8080/nifi`Web浏览器中的默认地址导航到UI 。默认情况下没有配置权限，因此任何人都可以查看和修改数据流。有关保护系统的信息，请参阅“ [系统管理员指南”][Link 1]。

当DFM首次导航到UI时，会提供一个空白画布，可在其上构建数据流：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70][]

组件工具栏跨越屏幕的左上角。它包含可以拖动到画布上以构建数据流的组件。在[构建DataFlow][DataFlow]中更详细地描述了每个组件。

状态栏位于组件工具栏下。状态栏提供有关当前在流中处于活动状态的线程数，流中当前存在的数据量，每个状态中画布上存在的远程进程组数（传输，未传输），有多少的信息画布上的处理器存在于每个状态（已停止，正在运行，无效，已禁用），每个状态下画布上存在多少个版本化的进程组（最新，本地修改，过时，本地修改和失效，同步失败）和上次刷新所有此类信息的时间戳。此外，如果NiFi实例是群集的，则状态栏会显示群集中有多少节点以及当前连接的节点数。

操作面板位于屏幕的左侧。它由DFM用于管理流的按钮以及管理用户访问和配置系统属性的管理员组成，例如应向应用程序提供多少系统资源。

在画布的右侧是搜索和全局菜单。您可以使用“搜索”轻松查找画布上的组件，并可以按组件名称，类型，标识符，配置属性及其值进行搜索。全局菜单包含允许您操作画布上现有组件的选项：

此外，UI还具有一些功能，可让您轻松浏览画布。您可以使用“导航选项板”在画布上平移，以及放大和缩小。数据流的“鸟眼视图”提供了数据流的高级视图，并允许您平移大部分数据流。您还可以在屏幕底部找到面包屑。当您导航进出流程组时，面包屑会显示流程中的深度，以及您输入的每个流程组以达到此深度。面包屑中列出的每个进程组都是一个链接，可以将您带回流中的该级别。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 1][]

## 使用多租户授权访问UI ##

多租户授权允许多组用户（租户）命令，控制和观察数据流的不同部分，具有不同级别的授权。当经过身份验证的用户尝试查看或修改NiFi资源时，系统会检查用户是否具有执行该操作的权限。这些权限由可以应用于系统范围或单个组件的策略定义。从数据流管理器的角度来看，这意味着一旦您可以访问NiFi画布，您就可以看到一系列功能，具体取决于分配给您的权限。

可用的全球访问策略是：

<table> 
 <thead> 
  <tr> 
   <th style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">策略</th> 
   <th style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;">特权</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;"> <p style="margin-left:0px;">view the UI</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户查看UI</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;"> <p style="margin-left:0px;">access the controller</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户查看和修改控制器，包括报告任务，控制器服务和群集中的节点</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">query provenance</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户提交出处搜索并请求甚至沿袭</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">access restricted components</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">假设其他权限足够，允许用户创建/修改受限制的组件。受限组件可以指示需要哪些特定权限。可以为特定限制授予权限，也可以在不受限制的情况下授予权限。如果授予权限而不受限制，则用户可以创建/修改所有受限制的组件。</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">access all policies</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户查看和修改所有组件的策略</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">access users/groups</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户查看和修改用户和用户组</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">retrieve site-to-site details</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许其他NiFi实例检索站点到站点的详细信息</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">view system diagnostics</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户查看系统诊断</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;">proxy user requests</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许代理计算机代表其他人发送请求</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:182px;"> <p style="margin-left:0px;">access counters</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;width:667px;"> <p style="margin-left:0px;">允许用户查看和修改计数器</p> </td> 
  </tr> 
 </tbody> 
</table>

可用的组件级访问策略包括：

<table> 
 <thead> 
  <tr> 
   <th style="border-color:#dedede;text-align:left;vertical-align:top;">政策</th> 
   <th style="border-color:#dedede;text-align:left;vertical-align:top;">特权</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">view the component</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许用户查看组件配置详细信息</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">modify the component</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许用户修改组件配置详细信息</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">view provenance</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">允许用户提交出处搜索并请求甚至追溯</td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">view the data</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许用户在出站连接中的流文件队列中以及通过出处事件查看此组件的元数据和内容</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">modify the data</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许用户在出站连接中清空流文件队列，并通过出处事件提交重播</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">view the policies</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许用户查看可以查看和修改组件的用户列表</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">modify the policies</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许用户修改可以查看和修改组件的用户列表</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">retrieve data via site-to-site</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许端口从NiFi实例接收数据</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">send data via site-to-site</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">允许端口从NiFi实例发送数据</p> </td> 
  </tr> 
 </tbody> 
</table>

如果您无法查看或修改NiFi资源，请与系统管理员联系，或参阅[系统管理员指南][Link 1]中的配置用户和访问策略以 获取更多信息。

## 登录 ##

如果NiFi配置为安全运行，则用户将能够请求访问DataFlow。有关配置NiFi以安全运行的信息，请参阅“ [系统管理员指南”][Link 1]。如果NiFi支持匿名访问，则会为用户提供相应的访问权限，并提供登录选项。

单击“登录”链接将打开登录页面。如果用户使用他们的用户名/密码登录，他们将会看到一个表单。如果NiFi未配置为支持匿名访问且用户使用其用户名/密码登录，则会立即将其发送到绕过画布的登录表单。

![登录][205aaf7cc64d1f0034dbd8aba04b6fd1.png]

## 构建DataFlow ##

DFM能够使用NiFi UI构建自动数据流。只需将组件从工具栏拖到画布，配置组件以满足特定需求，并将组件连接在一起。

### 向画布添加组件 ###

上面的“用户界面”部分概述了UI的不同部分，并指出了“组件工具栏”。本节将查看该工具栏中的每个组件：

![20190319135217968.png][]

![2019031913523742.png][] **处理器**：处理器是最常用的组件，因为它负责数据的入口，出口，路由和操作。有许多不同类型的处理器。实际上，这是NiFi中非常常见的扩展点，这意味着许多供应商可能会实施自己的处理器来执行其用例所需的任何功能。将处理器拖动到画布上时，会向用户显示一个对话框，以选择要使用的处理器类型：

在右上角，用户可以根据处理器类型或与处理器关联的标签过滤列表。处理器开发人员能够将标签添加到其处理器中。这些标签在此对话框中用于过滤，并显示在标签云的左侧。使用特定标记存在的处理器越多，标记在标记云中显示的越大。单击云中的标记会将可用的处理器过滤为仅包含该标记的处理器。如果选择了多个标记，则仅显示包含所有这些标记的处理器。例如，如果我们只想显示那些允许我们提取文件的处理器，我们可以同时选择`files`Tag和`ingest`Tag：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 2][]

受限制的组件将在![受限][bbc311f3af857b30c96ebf6d13262cc0.png] 其名称旁边标有 图标。这些组件可用于执行操作员通过NiFi REST API / UI提供的任意未经过抽样的代码，或者可用于使用NiFi OS凭证获取或更改NiFi主机系统上的数据。这些组件可由其他授权的NiFi用户使用，超出应用程序的预期用途，升级特权，或者可能暴露有关NiFi进程或主机系统内部的数据。所有这些功能都应被视为特权，管理员应了解这些功能，并为可信用户的子集明确启用它们。在允许用户创建和修改受限制的组件之前，必须授予他们访问权限。徘徊在![受限][bbc311f3af857b30c96ebf6d13262cc0.png] 图标将显示受限制的组件所需的特定权限。无论限制如何，都可以分配权限。在这种情况下，用户可以访问所有受限制的组件。或者，可以为用户分配对特定限制的访问权限。如果用户已被授予访问组件所需的所有限制的权限，则他们将具有对该组件的访问权限，否则将获得足够的权限。有关更多信息，请参阅 [在版本化流程中][Link 3][访问具有多租户授权][Link 4]和[受限组件][Link 3][的UI][Link 4]。

单击`Add`按钮或双击处理器类型将选定的处理器添加到画布中删除它的位置。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>对于添加到画布的任何组件，可以使用鼠标选择它并将其移动到画布上的任何位置。此外，可以通过按住Shift键并选择每个项目或按住Shift键并在所需组件周围拖动选择框，一次选择多个项目。</td> 
  </tr> 
 </tbody> 
</table>

将处理器拖到画布上后，可以通过右键单击处理器并从上下文菜单中选择一个选项来与其进行交互。根据分配给您的权限，上下文菜单中可用的选项会有所不同。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 3][]

虽然上下文菜单中提供的选项有所不同，但是当您具有使用处理器的完全权限时，通常可以使用以下选项：

*  **Configure**：此选项允许用户建立或更改处理器的配置（请参阅[配置处理器][Link 5]）。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>对于处理器，端口，远程进程组，连接和标签，可以通过双击所需组件来打开配置对话框。</td> 
  </tr> 
 </tbody> 
</table>

*  **Start**或**Stop**：此选项允许用户启动或停止处理器; 该选项可以是Start或Stop，具体取决于处理器的当前状态。
 *  **Enable**或**Disable**：此选项允许用户启用或启用处理器; 该选项将为“启用”或“禁用”，具体取决于处理器的当前状态。
 *  **View data provenance**：此选项显示NiFi数据来源表，其中包含有关通过该处理器路由的FlowFiles的数据来源事件的信息（请参阅[数据来源][Link 6]）。
 *  **View status history**：此选项打开处理器统计信息随时间的图形表示。
 *  **View usage**：此选项将用户带到处理器的使用文档。
 *  **View connections→Upstream**：此选项允许用户查看和“跳转”到进入处理器的上游连接。当处理器连接进出其他进程组时，这尤其有用。
 *  **View connections→Downstream**：此选项允许用户查看和“跳转”到处理器外的下游连接。当处理器连接进出其他进程组时，这尤其有用。
 *  **Center in view**：此选项将画布的视图置于给定的处理器上。
 *  **Change color**：此选项允许用户更改处理器的颜色，这可以使大流量的可视化管理更容易。
 *  **Create template**：此选项允许用户从所选处理器创建模板。
 *  **Copy**：此选项将所选处理器的副本放在剪贴板上，以便可以通过右键单击画布并选择“粘贴”将其粘贴到画布上的其他位置。复制/粘贴操作也可以使用按键Ctrl-C（Command-C）和Ctrl-V（Command-V）完成。
 *  **Delete**：此选项允许DFM从画布中删除处理器。

![输入端口][e498d187f54c56dcbbc162dbdfbec5bf.png] **Input Port**：输入端口提供将数据传输到进程组的机制。将输入端口拖动到画布上时，将提示DFM命名端口。进程组中的所有端口必须具有唯一的名称。

All components exist only within a Process Group. When a user initially navigates to the NiFi page, the user is placed in the Root Process Group. If the Input Port is dragged onto the Root Process Group, the Input Port provides a mechanism to receive data from remote instances of NiFi via [Site-to-Site][]. In this case, the Input Port can be configured to restrict access to appropriate users, if NiFi is configured to run securely. For information on configuring NiFi to run securely, see the[System Administrator’s Guide][Link 1].

![输出端口][958df746ae1e91ba723308f363b7c9cd.png] **Output Port**: Output Ports provide a mechanism for transferring data from a Process Group to destinations outside of the Process Group. When an Output Port is dragged onto the canvas, the DFM is prompted to name the Port. All Ports within a Process Group must have unique names.

如果将输出端口拖动到根进程组，则输出端口提供了一种通过[站点到站点][Site-to-Site]将数据发送到远程NiFi实例的机制。在这种情况下，端口充当队列。当NiFi的远程实例从端口提取数据时，该数据将从传入连接的队列中删除。如果NiFi配置为安全运行，则可以将输出端口配置为限制对适当用户的访问。有关配置NiFi以安全运行的信息，请参阅“ [系统管理员指南”][Link 1]。

![流程组][7ff757372e856635053415ddf6dcb4a1.png] **Process Group**：进程组可用于对一组组件进行逻辑分组，以便更容易理解和维护数据流。将进程组拖动到画布上时，将提示DFM命名进程组。同一父组中的所有进程组必须具有唯一的名称。然后，进程组将嵌套在该父组中。

将进程组拖到画布上后，可以通过右键单击进程组并从上下文菜单中选择一个选项来与其进行交互。从上下文菜单中可用的选项会有所不同，具体取决于分配给您的权限。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 4][]

虽然上下文菜单中提供的选项各不相同，但如果您具有使用进程组的完全权限，则通常可以使用以下选项：

*  **Configure**：此选项允许用户建立或更改进程组的配置。
 *  **Variables**：此选项允许用户在NiFi UI中创建或配置变量。
 *  **Enter group**：此选项允许用户进入进程组。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>也可以双击进程组输入它。</td> 
  </tr> 
 </tbody> 
</table>

*  **Start**：此选项允许用户启动进程组。
 *  **Stop**：此选项允许用户停止进程组。
 *  **View status history**：此选项打开过程组随时间变化的统计信息的图形表示。
 *  **View connections→Upstream**：此选项允许用户查看和“跳转”进入进程组的上游连接。
 *  **View connections→Downstream**：此选项允许用户查看和“跳转”到流程组外的下游连接。
 *  **Center in view**：此选项将画布视图置于给定进程组的中心。
 *  **Group**：此选项允许用户创建一个新的流程组，其中包含选定的流程组和在画布上选择的任何其他组件。
 *  **Create template**：此选项允许用户从选定的进程组创建模板。
 *  **Copy**：此选项将所选进程组的副本放在剪贴板上，以便可以通过右键单击画布并选择“粘贴”将其粘贴到画布上的其他位置。复制/粘贴操作也可以使用按键Ctrl-C（Command-C）和Ctrl-V（Command-V）完成。
 *  **Delete**：此选项允许DFM删除进程组。

![远程进程组][646a9ba71d2cd3ae2f07f3469c8b4394.png] **Remote Process Group**：远程进程组显示并且行为类似于进程组。但是，远程进程组（RPG）引用了NiFi的远程实例。将RPG拖动到画布上时，不会提示输入名称，而是提示DFM输入远程NiFi实例的URL。如果远程NiFi是群集实例，则应使用的URL是该群集中任何NiFi实例的URL。当数据通过RPG传输到NiFi的群集实例时，RPG将首先连接到远程实例，其URL配置为确定群集中的节点以及每个节点的繁忙程度。然后，此信息用于对推送到每个节点的数据进行负载平衡。然后定期询问远程实例，以确定有关从群集中删除或添加到群集的任何节点的信息，并根据每个节点的负载重新计算负载平衡。有关更多信息，请参阅有关的部分[站点到站点][Site-to-Site]。

将远程进程组拖到画布上后，可以通过右键单击远程进程组并从上下文菜单中选择一个选项来与其进行交互。根据分配给您的权限，上下文菜单中可用的选项会有所不同。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 5][]

虽然上下文菜单中的选项有所不同，但是当您具有使用远程进程组的完全权限时，通常可以使用以下选项：

*  **Configure**：此选项允许用户建立或更改远程进程组的配置。
 *  **Enable transmission**：激活NiFi实例之间的数据传输（请参阅[远程进程组传输][Link 7]）。
 *  **Disable transmission**：禁用NiFi实例之间的数据传输。
 *  **View status history**：此选项打开远程过程组随时间变化的统计信息的图形表示。
 *  **View connections→Upstream**：此选项允许用户查看和“跳转”进入远程进程组的上游连接。
 *  **View connections→Downstream**：此选项允许用户查看和“跳转”到远程进程组外的下游连接。
 *  **Refresh remote**：此选项刷新远程NiFi实例的状态视图。
 *  **Group**：此选项允许用户创建包含所选远程进程组和在画布上选择的任何其他组件的新进程组。
 *  **Manage remote ports**：此选项允许用户查看远程进程组连接到的远程NiFi实例上存在的输入端口和/或输出端口。请注意，如果站点到站点配置是安全的，则仅可以看到已访问连接的NiFi的端口。
 *  **Center in view**：此选项将画布的视图置于给定的远程进程组的中心。
 *  **Go to**：此选项在浏览器的新选项卡中打开远程NiFi实例的视图。请注意，如果站点到站点配置是安全的，则用户必须能够访问远程NiFi实例才能查看它。
 *  **Group**：此选项允许用户创建包含所选远程进程组的进程组。
 *  **Create template**：此选项允许用户从选定的远程进程组创建模板。
 *  **Copy**：此选项将所选进程组的副本放在剪贴板上，以便可以通过右键单击画布并选择“粘贴”将其粘贴到画布上的其他位置。复制/粘贴操作也可以使用按键Ctrl-C（Command-C）和Ctrl-V（Command-V）完成。
 *  **Delete**：此选项允许DFM从画布中删除远程进程组。

![漏斗][c55d4cf8640f81947a4a2f5b176eebff.png] **Funnel**：**Funnel**用于将来自多个Connections的数据合并到一个Connection中。这有两个好处。首先，如果使用相同的目标创建了许多连接，则如果这些连接必须跨越大空间，则画布可能会变得混乱。通过将这些Connections汇集到一个Connection中，可以绘制该单个Connection以跨越该大空间。其次，可以使用FlowFile优先级配置器配置Connections。来自多个Connections的数据可以汇集到一个Connection中，从而能够对该一个Connection上的所有数据进行优先级排序，而不是单独确定每个Connection上的数据的优先级。

![模板][87869024dd9b572bac408cf10037d576.png] **Template**：模板可以由流的各个部分的DFM创建，也可以从其他数据流导入。这些模板提供了更大的构建块，可以快速创建复杂的流程。将模板拖动到画布上时，DFM会提供一个对话框，用于选择要添加到画布的模板：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 6][]

单击下拉框可显示所有可用模板。使用描述创建的任何模板都将显示一个问号图标，表示有更多信息。使用鼠标将鼠标悬停在图标上将显示以下说明：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 7][]

![标签][80fcd8683eb661dac506c7a3e2d15594.png] **Label**：标签用于为数据流的各个部分提供文档。将Label放到画布上时，会使用默认大小创建它。然后可以通过拖动右下角的手柄来调整Label的大小。标签在最初创建时没有文本。可以通过右键单击Label并选择来添加Label的文本`Configure`。

### 组件版本 ( Component Versions ) ###

您可以访问有关处理器，控制器服务和报告任务的版本的信息。当您在具有运行不同版本组件的多个NiFi实例的集群环境中工作或者已升级到较新版本的处理器时，此功能尤其有用。“添加处理器”，“添加控制器服务”和“添加报告任务”对话框包括一个标识组件版本的列，以及组件的名称，创建组件的组织或组以及包含该组件的NAR捆绑包。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 8][]

画布上显示的每个组件也包含此信息。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 9][]

排序和过滤组件 (Sorting and Filtering Components)

添加组件时，可以根据原始源对版本号或过滤器进行排序。

要基于版本进行排序，请单击版本列以按升序或降序版本顺序显示。

要基于源组进行过滤，请单击“添加组件”对话框左上角的源下拉列表，然后选择要查看的组。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 10][]

更改组件版本

要更改组件版本，请执行以下步骤。

1.  右键单击画布上的组件以显示配置选项。
2.  选择更改版本。
    
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 11][]
3.  在“组件版本”对话框中，从“版本”下拉菜单中选择要运行的版本。
    
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 12][]

了解版本依赖关系

配置组件时，还可以查看有关版本依赖性的信息。

1.  右键单击组件，然后选择“配置”以显示组件的“配置”对话框。
2.  单击“属性”选项卡。
3.  单击信息图标以查看任何版本依赖关系信息。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 13][]

在以下示例中，使用控制器服务StandardMyService 1.0版正确配置了MyProcessor 1.0版：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 14][]

如果MyProcessor的版本更改为不兼容的版本（MyProcessor 2.0），则验证错误将显示在处理器上：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 15][]

并且由于服务不再有效，因此处理器的控制器服务配置中将显示错误消息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 16][]

### 配置处理器 ( Configuring a Processor ) ###

要配置处理器，请右键单击处理器，然后`Configure`从上下文菜单中选择该选项。或者，只需双击处理器即可。打开配置对话框，其中包含四个不同的选项卡，每个选项卡将在下面讨论。完成处理器配置后，可以通过单击`Apply`按钮应用更改，或单击按钮取消所有更改`Cancel`。

请注意，处理器启动后，为处理器显示的上下文菜单不再有`Configure` 选项，而是有一个`View Configuration`选项。处理器运行时无法更改处理器配置。您必须先停止处理器并等待其所有活动任务完成，然后再次配置处理器。

请注意，不支持输入某些控制字符，并在输入时自动过滤掉。任何配置中都不会保留以下字符和任何未配对的Unicode代理点代码点：

>     [#x0], [#x1], [#x2], [#x3], [#x4], [#x5], [#x6], [#x7], [#x8], [#xB], [#xC], [#xE], [#xF], [#x10], [#x11], [#x12], [#x13], [#x14], [#x15], [#x16], [#x17], [#x18], [#x19], [#x1A], [#x1B], [#x1C], [#x1D], [#x1E], [#x1F], [#xFFFE], [#xFFFF]

设置标签

处理器配置对话框中的第一个选项卡是“设置”选项卡：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 17][]

此选项卡包含几个不同的配置项。首先，它允许DFM更改处理器的名称。默认情况下，处理器的名称与处理器类型相同。处理器名称旁边是一个复选框，指示处理器是否已启用。将处理器添加到画布后，将启用它。如果禁用处理器，则无法启动。禁用状态用于指示当启动一组处理器时，例如当DFM启动整个进程组时，应排除此（禁用）处理器。

在Name配置下方，将显示Processor的唯一标识符以及Processor的类型和NAR包。这些值无法修改。

接下来是两个用于配置“惩罚持续时间”和“产量持续时间”的对话框。在处理一条数据（FlowFile）的正常过程期间，可能发生事件，该事件指示此时不能处理数据但是数据可以在稍后的时间处理。发生这种情况时，处理器可以选择Penalize FlowFile。这将阻止FlowFile在一段时间内被处理。例如，如果处理器要将数据推送到远程服务，但远程服务已经有一个与处理器指定的文件名同名的文件，则处理器可能会惩罚FlowFile。“惩罚持续时间”允许DFM指定FlowFile应该受到多长时间的惩罚。默认值为`30 seconds`。

类似地，处理器可以确定存在某种情况，使得处理器不再能够进行任何进展，而不管其正在处理的数据。例如，如果处理器要将数据推送到远程服务并且该服务没有响应，则处理器无法取得任何进展。结果，处理器应该“产生”，这将阻止处理器被安排运行一段时间。通过设置'Yield Duration'来指定该时间段。默认值为`1 second`。

“设置”选项卡左侧的最后一个可配置选项是“公告”级别。每当处理器写入其日志时，处理器也将生成公告。此设置指示应在用户界面中显示的最低级别的公告。默认情况下，公告级别设置为`WARN`，这意味着它将显示所有警告和错误级别公告。

“设置”选项卡的右侧包含“自动终止关系”部分。此处列出了处理器定义的每个关系及其描述。为了使处理器被视为有效且能够运行，处理器定义的每个关系必须连接到下游组件或自动终止。如果关系是自动终止的，则将从流中删除任何路由到该关系的FlowFile，并将其处理视为完成。已连接到下游组件的任何关系都无法自动终止。必须首先从使用它的任何Connection中删除关系。此外，对于选择自动终止的任何关系，

调度选项卡

“处理器配置”对话框中的第二个选项卡是“计划”选项卡：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 18][]

调度策略

第一个配置选项是调度策略。调度组件有三种可能的选项：

**Timer driven **：这是默认模式。处理器将安排定期运行。运行处理器的时间间隔由“运行时间表”选项定义（见下文）。

**Event driven**：选择此模式时，将触发处理器以由事件运行，并且当FlowFiles进入连接此处理器的Connections时，将发生该事件。此模式目前被认为是实验性的，并非所有处理器都支持。选择此模式时，“运行计划”选项不可配置，因为处理器未被触发定期运行，而是作为事件的结果。此外，这是“并发任务”选项可以设置为0的唯一模式。在这种情况下，线程数仅受管理员配置的事件驱动线程池的大小限制。

**CRON驱动**：当使用CRON驱动的调度模式时，处理器被安排定期运行，类似于定时器驱动的调度模式。然而，CRON驱动模式以增加配置的复杂性为代价提供了显着更大的灵活性。CRON驱动的调度值是由六个必需字段和一个可选字段组成的字符串，每个字段由空格分隔。这些字段是：

<table> 
 <thead> 
  <tr> 
   <th>Field</th> 
   <th>Valid values</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>Seconds</p> </td> 
   <td> <p>0-59</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Minutes</p> </td> 
   <td> <p>0-59</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Hours</p> </td> 
   <td> <p>0-23</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Day of Month</p> </td> 
   <td> <p>1-31</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Month</p> </td> 
   <td> <p>1-12 or JAN-DEC</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Day of Week</p> </td> 
   <td> <p>1-7 or SUN-SAT</p> </td> 
  </tr> 
  <tr> 
   <td> <p>Year (optional)</p> </td> 
   <td> <p>empty, 1970-2099</p> </td> 
  </tr> 
 </tbody> 
</table>

您通常通过以下方式之一指定值：

*  **数字**：指定一个或多个有效值。您可以使用逗号分隔列表输入多个值。
 *  **范围**：使用  <number>-<number> 语法指定范围。
 *  **增量**：使用 <start value>/<increment>语法指定增量。例如，在“分钟”字段中，0/15表示分钟 0,15,30 和 45。

您还应该知道几个有效的特殊字符：

*  \* - 表示所有值对该字段都有效。
 *  ？ - 表示未指定特定值。此特殊字符在“星期几”和“星期几”字段中有效。
 *  L - 您可以将L附加到星期几值中的一个，以指定该月中该日的最后一次出现。例如，1L表示该月的最后一个星期日。

例如：

*  该字符串`0 0 13 * * ?`表示您希望将处理器安排在每天下午1:00运行。
 *  该字符串`0 20 14 ? * MON-FRI`表示您希望将处理器安排在每周一至周五下午2:20运行。
 *  该字符串`0 15 10 ? * 6L 2011-2017`表示您希望将处理器安排在2011年至2017年的每个月的最后一个星期五上午10:15运行。

有关其他信息和示例，请参阅Quartz文档中的[Chron Trigger教程][Chron Trigger]。

并发任务(Concurrent Tasks)

接下来，Scheduling选项卡提供名为'Concurrent Tasks'的配置选项。这可以控制处理器将使用的线程数。换句话说，它控制此处理器应同时处理多少个FlowFiles。增加此值通常会使处理器在相同的时间内处理更多数据。但是，它通过使用其他处理器无法使用的系统资源来实现此目的。这基本上提供了处理器的相对权重 - 它控制应该将多少系统资源分配给此处理器而不是其他处理器。该字段适用于大多数处理器。但是，某些类型的处理器只能使用单个“并发”任务进行调度。

运行计划(Run Schedule)

“运行计划”指示应该安排处理器运行的频率。此字段的有效值取决于所选的调度策略（参见上文）。如果使用事件驱动的调度策略，则此字段不可用。使用定时器驱动的调度策略时，该值是由数字后跟时间单位指定的持续时间。例如，`1 second`或`5 mins`。默认值`0 sec`表示处理器应尽可能频繁地运行，只要它有要处理的数据即可。这适用于0任何持续时间，而不管时间单位（即，`0 sec`，`0 mins`，`0 days`）。有关适用于CRON驱动的调度策略的值的说明，请参阅CRON驱动的调度策略本身的说明。

执行(Execution)

执行设置用于确定处理器将被调度执行的节点。选择“所有节点”将导致在集群中的每个节点上调度此处理器。选择“主节点”将导致此处理器仅在主节点上进行调度。已为“主节点”执行配置的处理器由处理器图标旁边的“P”标识：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 19][]

要快速识别“主节点”处理器，“P”图标也会显示在“摘要”页面的“处理器”选项卡中：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 20][]

运行持续时间

“调度”选项卡的右侧包含一个用于选择“运行持续时间”的滑块。这可以控制处理器每次触发时应安排运行的时间。在滑块的左侧，标记为“较低延迟”，而右侧标记为“较高吞吐量”。处理器完成运行后，必须更新存储库才能将FlowFiles传输到下一个Connection。更新存储库的成本很高，因此在更新存储库之前可以立即完成的工作量越多，处理器可以处理的工作量就越多（吞吐量越高）。但是，这意味着在上一个Process更新此存储库之前，下一个Processor无法开始处理这些FlowFiles。结果是，延迟时间会更长（从开始到结束处理FlowFile所需的时间会更长）。因此，滑块提供了一个频谱，DFM可以从中选择支持较低延迟或较高吞吐量。

属性选项卡

Properties选项卡提供了一种配置特定于Processor的行为的机制。没有默认属性。每种类型的处理器必须定义哪些属性对其用例有意义。下面，我们看到RouteOnAttribute Processor的Properties选项卡：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 21][]

默认情况下，此处理器只有一个属性：“路由策略”。默认值为“路由到属性名称”。此属性的名称旁边是一个小问号符号（ ![问号][4d6d4e00cf23a833cee72db296194a39.png] ）。在整个用户界面的其他位置可以看到此帮助符号，它表示可以获得更多信息。使用鼠标将鼠标悬停在此符号上将提供有关属性和默认值的其他详细信息，以及为该属性设置的历史值。

单击属性的值将允许DFM更改该值。根据属性允许的值，向用户提供从中选择值的下拉列表，或者为用户提供键入值的文本区域：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 22][]

选项卡的右上角是一个用于添加新属性的按钮。单击此按钮将为DFM提供一个对话框，用于输入新属性的名称和值。并非所有处理器都允许用户定义的属性。在不允许它们的处理器中，处理器在应用用户定义属性时变为无效。但是，RouteOnAttribute允许用户定义的属性。实际上，在用户添加属性之前，此处理器无效。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 23][]

请注意，添加了User-Defined属性后，该行的右侧将出现一个图标（ ![删除图标][3ece91f8a007c00c82daa6a4b78cd742.png] ）。单击它将从处理器中删除用户定义的属性。

某些处理器还内置了高级用户界面（UI）。例如，UpdateAttribute处理器具有高级UI。要访问高级用户界面，请单击`Advanced`“配置处理器”窗口底部显示的按钮。只有具有高级UI的处理器才具有此按钮。

某些处理器具有引用其他组件的属性，例如Controller Services，这些组件也需要进行配置。例如，GetHTTP处理器具有SSLContextService属性，该属性引用StandardSSLContextService控制器服务。当DFM想要配置此属性但尚未创建和配置控制器服务时，他们可以选择在现场创建服务，如下图所示。有关配置Controller Services的详细信息，请参阅“ [Controller Services”][Controller Services]部分。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 24][]

评论标签

处理器配置对话框中的最后一个选项卡是“注释”选项卡。此选项卡仅为用户提供一个区域，以包含适用于此组件的任何注释。使用“注释”选项卡是可选的：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 25][]

### 其他帮助 ###

您可以通过右键单击处理器并从上下文菜单中选择“使用”来访问有关每个处理器使用情况的其他文档。或者，从UI右上角的“全局菜单”中选择“帮助”，以显示包含所有文档的“帮助”页面，包括所有可用处理器的使用文档。单击所需的处理器以查看使用文档。

### 使用表达式语言的自定义属性 ###

您可以使用NiFi表达式语言来引用FlowFile属性，将它们与其他值进行比较，并在创建和配置数据流时操纵它们的值。有关表达式语言的更多信息，请参阅“ [表达式语言指南”][Link 8]。

除了在Express Language中使用FlowFile属性，系统属性和环境属性之外，您还可以定义表达式语言使用的自定义属性。定义自定义属性可以更灵活地处理和处理数据流。您还可以为连接，服务器和服务属性创建自定义属性，以便更轻松地配置数据流。

NiFi属性具有在创建自定义属性时应注意的分辨率优先级：

*  特定于处理器的属性
 *  FlowFile属性 
 *  FlowFile属性 
 *  从变量注册表： 
    
     *  用户定义的属性（自定义属性）
     *  系统属性 
     *  操作系统环境变量

在创建自定义属性时，请确保每个自定义属性包含不同的属性值，以便现有环境属性，系统属性或FlowFile属性不会覆盖它。

有两种方法可以使用和管理自定义属性：

*  在NiFi UI中通过Variables窗口
 *  通过*nifi.properties*引用自定义属性

变量窗口

可以在NiFi UI中创建和配置变量。变量可用于支持表达式语言的任何字段。NiFi自动获取在UI中创建的新变量或修改变量。

要访问“变量”窗口，请在未选中任何内容的画布上单击鼠标右键：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 26][]

从上下文菜单中选择“变量”：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 27][]

选择进程组时，右键单击“上下文菜单”中也可以使用“变量”：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 28][]

创建变量

在“变量”窗口中，单击`+`按钮以创建新变量。添加名称：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 29][]

和一个值：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 30][]

选择“应用”：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 31][]

执行更新变量的步骤（识别受影响的组件，停止受影响的处理器等）。例如，Referencing Processors部分现在列出了“PutFile-Root”处理器。在列表中选择处理器的名称将导航到画布上的该处理器。查看处理器的属性，`${putfile_dir}`由Directory属性引用：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 32][]

可变范围

变量的作用域由它们定义的进程组确定，并且可供该级别及以下定义的任何处理器使用（即任何后代处理器）。

后代组中的变量会覆盖父组中的值。更具体地说，如果变量`x`在根组中声明并且也在进程组内声明，则进程组内的组件将使用进程组中`x`定义的值。

例如，除了`putfile_dir`根进程组中存在的变量之外，假设`putfile_dir`在进程组A中创建了另一个变量。如果进程组A中的一个组件引用`putfile_dir`，则将列出这两个变量，但是`putfile_dir`根组中的变量将是有一个删除线表明被覆盖：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 33][]

只能为其创建的进程组修改变量，该变量列在“变量”窗口的顶部。要修改在不同进程组中定义的变量，请选择该变量行中的“箭头”图标：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 34][]

这将导航到该进程组的Variables窗口：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 35][]

变量权限

变量权限仅基于相应进程组上配置的权限。

例如，如果用户无权查看进程组，则无法查看该进程组的“变量”窗口：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 36][]

如果用户有权查看流程组但无权访问“修改流程组”，则可以查看变量但不能修改变量。

有关如何管理组件权限的信息，请参阅 “系统管理员指南”中的“ [访问策略”][Link 9]部分。

引用控制器服务

除了Referencing Processors之外，Variables窗口还显示Referencing Controller Services：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 37][]

选择控制器服务的名称将导航到“配置”窗口中的该控制器服务：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 38][]

未经授权的引用组件

如果未向引用变量的组件提供“查看”或“修改”权限，则组件的UUID将显示在“变量”窗口中：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 39][]

在上面的示例中，变量`property1`由“user1”无法查看的处理器引用：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 40][]

通过nifi.properties引用自定义属性

识别一组或多组键/值对，并将它们提供给系统管理员。

添加新的自定义属性后，请确保使用自定义属性位置更新*nifi.properties*文件中的`nifi.variable.registry.properties` 字段。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>必须重新启动NiFi才能获取这些更新。</td> 
  </tr> 
 </tbody> 
</table>

有关详细信息，请参阅“系统管理员指南”中的“ [自定义属性”][Link 10]部分。

### 控制器服务 ###

Controller Services是共享服务，可供报告任务，处理器和其他服务使用，以用于配置或任务执行。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>控制器级别定义的控制器服务仅限于报告任务和其中定义的其他服务。必须在将要使用它们的根进程组或子进程组的配置中定义供数据流中的处理器使用的控制器服务。</td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>如果您的NiFi实例受到保护，您查看和添加Controller Services的能力取决于分配给您的权限。如果您无权访问一个或多个Controller Services，则无法在UI中查看或访问它。可以在全局或特定于Controller Service的基础上分配访问权限（有关更多信息，请参阅<a href="/images/20220302/360db14537ed44c0886371b68d0b7b42.png" rel="nofollow">访问具有多租户授权的UI</a>）。</td> 
  </tr> 
 </tbody> 
</table>

为报告任务添加控制器服务

要为报告任务添加控制器服务，请从全局菜单中选择控制器设置。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 41][]

这将显示“NiFi设置”窗口。该窗口有四个选项卡：常规，报告任务控制器服务，报告任务和注册表客户端。“常规”选项卡提供实例的总体最大线程数的设置。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 42][]

“常规”选项卡右侧是“报告任务控制器服务”选项卡。在此选项卡中，DFM可以单击右上角的`+`按钮以创建新的Controller Service。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 43][]

“添加控制器服务”窗口打开。此窗口类似于“添加处理器”窗口。它提供了右侧可用的Controller Services列表和标签云，显示了左侧用于Controller Services的最常见类别标签。DFM可以单击标签云中的任何标签，以便将Controller Services列表缩小到适合所需类别的那些。DFM还可以使用窗口右上角的“过滤器”字段来搜索所需的“控制器服务”，或使用左上角的“源”下拉列表按创建它们的组筛选列表。从列表中选择Controller Service后，DFM可以在下面看到该服务的描述。选择所需的控制器服务，然后单击“添加”，或者只需双击要添加的服务名称即可。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 44][]

添加控制器服务后，可以通过单击`Configure`最右侧列中的按钮进行配置。此列中的其他按钮包括`Enable`，`Remove`和`Access Policies`。

![20190319175701638.png][]

您可以通过单击左侧列中的`Usage`和`Alerts`按钮来获取有关Controller Services的信息。

![20190319175830152.png][]

当DFM单击该`Configure`按钮时，将打开“配置控制器服务”窗口。它有三个选项卡：设置，属性和注释。此窗口类似于“配置处理器”窗口。“设置”选项卡为DFM提供了一个位置，以便为Controller Service提供唯一的名称（如果需要）。它还列出了服务的UUID，类型，捆绑和支持信息，并提供了引用该服务的其他组件（报告任务或其他控制器服务）的列表。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 45][]

“属性”选项卡列出了适用于特定控制器服务的各种属性。与配置处理器一样，DFM可以将鼠标悬停在问号图标上以查看有关每个属性的更多信息。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 46][]

“注释”选项卡只是一个开放文本字段，其中DFM可能包含有关服务的注释。配置Controller Service后，单击`Apply`按钮以应用配置并关闭窗口，或单击`Cancel`按钮取消更改并关闭窗口。

为数据流添加控制器服务

要为数据流添加控制器服务，可以右键单击“进程组”并选择“配置”，或单击“操作选项板”中的“配置”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 47][]

在画布上单击“操作选项板”中的“配置”时，如果未在画布上选择任何内容，则为根进程组添加控制器服务。然后，该控制器服务可用于数据流中的所有嵌套进程组。在画布上选择“进程组”，然后从“操作选项板”或“进程组”上下文菜单中单击“配置”时，该服务将可用于该进程组及以下中定义的所有处理器和控制器服务。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 48][]

使用以下步骤添加Controller服务：

1.  单击“配置”，可以从“操作选项板”或“进程组”上下文菜单中单击“配置”。这将显示进程组“配置”窗口。该窗口有两个选项卡：常规和控制器服务。“常规”选项卡用于与有关进程组的常规信息有关的设置。例如，如果配置根进程组，DFM可以为整个数据流提供唯一的名称，以及描述流的注释（注意：此信息对于远程连接到此实例的任何其他NiFi实例是可见的（使用远程进程组，又名，站点到站点））。
    
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 49][]
2.  从Process Group Configuration页面中，选择Controller Services选项卡。
3.  单击`+`按钮以显示“添加控制器服务”对话框。
4.  选择所需的Controller Service，然后单击“添加”。
5.  单击![配置][88cfe8c8eef4812379a3ca3c6e676e2a.png]右侧列中的配置图标（），执行任何必要的Controller Service配置任务。

启用/禁用控制器服务

配置Controller Service后，必须启用它才能运行。使用“ 控制器服务”选项卡的最右侧列中的`Enable`按钮（![启用按钮][4243cd3cdb9af52b17fb8a7e3bce77fb.png]）执行此操作。为了修改现有/正在运行的控制器服务，DFM需要停止/禁用它（以及所有引用报告任务和控制器服务）。使用`Disable`按钮（![禁用按钮][877c9f4dd42805ad926528690381ac9a.png]）执行此操作。DFM可以在禁用相关控制器服务时停止/禁用它们，而不必搜寻该控制器服务引用的每个组件。启用控制器服务时，DFM可以选择启动/启用控制器服务和所有引用组件，也可以仅启动/启用控制器服务本身。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 50][]

### 报告任务 ###

报告任务在后台运行，以提供有关NiFi实例中发生情况的统计报告。DFM添加和配置报告任务，类似于Controller Services的过程。要添加报告任务，请从全局菜单中选择控制器设置。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 51][]

这将显示“NiFi设置”窗口。选择“报告任务”选项卡，然后单击右上角的`+`按钮以创建新的“报告任务”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 52][]

将打开“添加报告任务”窗口。此窗口类似于“添加处理器”窗口。它提供了右侧可用报告任务的列表和标签云，显示了左侧用于报告任务的最常见类别标签。DFM可以单击标签云中的任何标签，以便将报告任务列表缩小到适合所需类别的那些。DFM还可以使用窗口右上角的“过滤器”字段来搜索所需的“报告任务”，或使用左上角的“源”下拉列表按创建它们的组筛选列表。从列表中选择报告任务后，DFM可以在下面看到该任务的描述。选择所需的报告任务，然后单击“添加”，或者只需双击要添加的服务名称即可。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 53][]

添加报告任务后，DFM可以通过单击`Edit`最右侧列中的按钮对其进行配置。在此列中的其他按钮包括`Start`，`Remove`，`State`和`Access Policies`。

![20190319180257107.png][]

您可以获取有关通过点击报告任务信息`View Details`，`Usage`以及`Alerts`在左侧栏中的按钮。

![2019031918025161.png][]

当DFM单击该`Edit`按钮时，将打开“配置报告任务”窗口。它有三个选项卡：设置，属性和注释。此窗口类似于“配置处理器”窗口。“设置”选项卡为DFM提供了一个位置，以便为报告任务提供唯一的名称（如果需要）。它还列出了任务的UUID，Type和Bundle信息，并提供了任务的Scheduling Strategy和Run Schedule的设置（类似于处理器中的相同设置）。DFM可以将鼠标悬停在问号图标上以查看有关每个设置的更多信息。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 54][]

“属性”选项卡列出了可为任务配置的各种属性。DFM可以将鼠标悬停在问号图标上以查看有关每个属性的更多信息。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 55][]

“注释”选项卡只是一个开放文本字段，其中DFM可能包含有关任务的注释。配置报告任务后，单击`Apply`按钮以应用配置并关闭窗口，或单击`Cancel`按钮取消更改并关闭窗口。

如果要运行“报告任务”，请单击`Start`按钮（![开始按钮][569ae3773a0dbef2549ed881c5b4a203.png]）。

### 连接组件 ###

将处理器和其他组件添加到画布并进行配置后，下一步是将它们相互连接，以便NiFi知道在处理完每个FlowFile后如何处理。这是通过在每个组件之间创建连接来实现的。当用户将鼠标悬停在组件的中心上时，会出现一个新的连接图标（ ![连接泡泡][48c6a631161bededaed98e5264a85086.png] ）：

![20190319180407309.png][]

用户将连接气泡从一个组件拖动到另一个组件，直到第二个组件突出显示。当用户释放鼠标时，会出现“创建连接”对话框。该对话框包含两个选项卡：“详细信息”和“设置”。它们将在下面详细讨论。请注意，可以绘制连接，以便它在同一处理器上循环。如果DFM希望处理器在失败关系时尝试重新处理FlowFiles，这将非常有用。要创建这种类型的循环连接，只需将连接气泡拖离，然后再返回到同一处理器，直到它突出显示。然后释放鼠标，出现相同的“创建连接”对话框。

细节标签

“创建连接”对话框的“详细信息”选项卡提供有关源和目标组件的信息，包括组件名称，组件类型和组件所在的进程组：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 56][]

此外，此选项卡还提供了选择此Connection中应包含哪些关系的功能。必须至少选择一个关系。如果只有一个关系可用，则会自动选择它。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>如果使用相同的关系添加多个Connections，则将自动“克隆”路由到该关系的任何FlowFile，并将副本发送到每个Connections。</td> 
  </tr> 
 </tbody> 
</table>

设置

“设置”选项卡提供配置连接名称，FlowFile到期，背压阈值，负载平衡策略和优先级的功能：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 57][]

连接名称是可选的。如果未指定，则为Connection显示的名称将是Connection的活动关系的名称。

FlowFile到期

FlowFile到期是一个概念，通过该概念可以自动从流中删除无法及时处理的数据。例如，当预计数据量超过可以发送到远程站点的卷时，这很有用。在这种情况下，到期可以与优先级排序器一起使用，以确保首先处理最高优先级数据，然后可以丢弃在特定时间段（例如，一小时）内无法处理的任何内容。到期时间基于数据进入NiFi实例的时间。换句话说，如果给定连接上的文件到期时间设置为“1小时”，并且已经在NiFi实例中一小时的文件到达该连接，则该文件将过期。默认值为`0 sec`表示数据永不过期。当设置了“0秒”以外的文件到期时，连接标签上会出现一个小时钟图标，因此在查看画布上的流时，DFM可以一目了然地看到它。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 58][]

后台压力

NiFi为后台压力提供两种配置元素。这些阈值表示在不再计划运行作为Connection源的组件之前，应允许在队列中存在多少数据。这允许系统避免数据溢出。提供的第一个选项是“后台压力对象阈值”。这是在应用后台压力之前可以在队列中的FlowFiles的数量。第二个配置选项是“背压数据大小阈值”。这指定了在应用反压之前应排队的最大数据量（大小）。通过输入数字后跟数据大小（`B`对于字节，`KB`对于千字节，`MB`对于兆字节，`GB`对于千兆字节或`TB`对于太字节）来配置此值。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>默认情况下，添加的每个新连接都将具有默认的后台压力对象阈值<code>10,000 objects</code>和后台压力数据大小阈值<code>1 GB</code>。可以通过修改<em>nifi.properties</em>文件中的相应属性来更改这些默认值。</td> 
  </tr> 
 </tbody> 
</table>

启用背压时，连接标签上会出现小进度条，因此在查看画布上的流时，DFM可以一目了然地看到它。进度条根据队列百分比更改颜色：绿色（0-60％），黄色（61-85％）和红色（86-100％）。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 59][]

将鼠标悬停在条形图上会显示确切的百分比。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 60][]

队列完全填满后，Connection将以红色突出显示。

![20190319180825236.png][]

负载均衡

负载平衡策略

为了在群集中的节点之间分配流中的数据，NiFi提供以下负载平衡策略：

*  **Do not load balance**：不要在群集中的节点之间平衡FlowFile。这是默认值。
 *  **Partition by attribute**：根据用户指定的FlowFile属性的值确定将给定FlowFile发送到哪个节点。具有相同Attribute值的所有FlowFile将发送到集群中的同一节点。如果目标节点与群集断开连接或无法通信，则数据不会故障转移到另一个节点。数据将排队，等待节点再次可用。此外，如果节点加入或离开集群需要重新平衡数据，则应用一致性散列以避免必须重新分发所有数据。
 *  **Round robin**：FlowFiles将以**循环**方式分发到集群中的节点。如果节点与群集断开连接或无法与节点通信，则排队等待该节点的数据将自动重新分发到另一个节点。
 *  **Single node**：所有FlowFiles将发送到集群中的单个节点。它们被发送到哪个节点是不可配置的。如果节点与群集断开连接或无法与节点通信，则排队等待该节点的数据将保持排队，直到该节点再次可用。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>除UI设置外，还有与负载平衡相关的<a href="http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#cluster_node_properties" rel="nofollow">群集节点属性</a>，还必须在<em>nifi.properties中</em>进行配置。</td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>NiFi会在重新启动时持久保存群集中的节点。这可以防止在所有节点都已连接之前重新分配数据。如果群集已关闭且无意重新启动节点，则用户有责任通过UI中的“群集”对话框从群集中删除该节点（有关详细信息，请参阅<a href="http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#managing_nodes" rel="nofollow">管理节点</a>）。</td> 
  </tr> 
 </tbody> 
</table>

负载平衡压缩

选择负载平衡策略后，用户可以配置在群集中的节点之间传输时是否应压缩数据。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 61][]

可以使用以下压缩选项：

*  **Do not compress**：FlowFiles不会被压缩。这是默认值。
 *  **Compress attributes only**：将压缩FlowFile属性，但不会压缩FlowFile内容。
 *  **Compress attributes and content**：将压缩FlowFile属性和内容。

负载平衡指示器

为连接实施负载平衡策略后，连接![负载平衡图标][392e205cd217b7d07e1ec7cd62e23733.png]上将显示负载平衡指示符（）：

![20190319181231617.png][]

将鼠标悬停在该图标上将显示连接的负载平衡策略和压缩配置。此状态下的图标还表示连接中的所有数据都已在群集中分布。

![20190319181239584.png][]

当在群集中的节点之间主动传输数据时，负载平衡指示器将更改方向和颜色：

![20190319181249889.png][]

群集连接摘要

要查看在群集节点之间分配数据的位置，请从“全局菜单”中选择“摘要”。然后选择“连接”选项卡和源的“查看连接详细信息”图标：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 62][]

这将打开“群集连接摘要”对话框，该对话框显示群集中每个节点上的数据：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 63][]

优先级

**选项卡的右侧提供了对队列中数据进行优先级排序的功能，以便首先处理更高优先级的数据**。优先级可以从顶部（'可用的优先级排序器'）拖动到底部（'选择的优先级排序器'）。可以选择多个优先级排序器。**位于“所选优先级”列表顶部的优先级排序是最高优先级**。如果两个FlowFiles根据此优先级排序器具有相同的值，**则第二个优先级排序器将确定首先处理哪个FlowFile**，依此类推。如果不再需要优先级排序器，则可以将其从“选定的优先级排序器”列表拖动到“可用的优先级排序器”列表。

可以使用以下优先顺序：

*  **FirstInFirstOutPrioritizer**：给定两个FlowFiles，首先处理首先到达连接的FlowFiles。
 *  **NewestFlowFileFirstPrioritizer**：给定两个FlowFiles，将首先处理数据流中最新的FlowFiles。
 *  **OldestFlowFileFirstPrioritizer**：给定两个FlowFiles，将首先处理数据流中最旧的FlowFiles。'这是在没有选择优先级的情况下使用的默认方案'。
 *  **PriorityAttributePrioritizer**：给定两个FlowFiles，将提取名为“priority”的属性。将首先处理具有最低优先级值的那个。
    
     *  请注意，应使用UpdateAttribute处理器在FlowFiles到达具有此优先级设置的连接之前将“priority”属性添加到FlowFiles。
     *  如果只有一个具有该属性，它将首先出现。
     *  “priority”属性的值可以是字母数字，其中“a”将出现在“z”之前，“1”出现在“9”之前
     *  如果“priority”属性无法解析为long，则将使用unicode字符串排序。例如：“99”和“100”将被排序，因此带有“99”的流文件首先出现，但“A-99”和“A-100”将排序，因此带有“A-100”的流文件首先出现。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>与<a href="http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#load_balance_strategy" rel="nofollow">负载平衡策略</a>配置，连接有除了本地队列每个节点的队列。优先级排序器将独立地对每个队列中的数据进行排序。</td> 
  </tr> 
 </tbody> 
</table>

更改配置和上下文菜单选项

在两个组件之间建立连接之后，可以更改连接的配置，并且可以将连接移动到新目的地; 但是，必须先停止连接任一侧的处理器，然后才能进行配置或目标更改。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 64][]

要更改连接的配置或以其他方式与连接交互，请右键单击连接以打开连接上下文菜单。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 65][]

可以使用以下选项：

*  **Configure**：此选项允许用户更改连接的配置。
 *  **View status history**：此选项打开连接统计信息随时间的图形表示。
 *  **List queue**：此选项列出可能正在等待处理的FlowFiles队列。
 *  **Go to source**：如果画布上连接的源组件和目标组件之间有很长的距离，则此选项很有用。通过单击此选项，画布视图将跳转到连接源。
 *  **Go to destination**：与“转到源”选项类似，此选项将视图更改为画布上的目标组件，如果两个连接的组件之间存在较长距离，则此选项可能很有用。
 *  **Bring to front**：如果其他东西（例如另一个连接）与其重叠，则此选项将连接带到画布的前面。
 *  **Empty queue**：此选项允许DFM清除可能正在等待处理的FlowFiles队列。当DFM不关心从队列中删除数据时，此选项在测试期间特别有用。选择此选项后，用户必须确认是否要删除队列中的数据。
 *  **Delete**：此选项允许DFM删除两个组件之间的连接。请注意，必须先停止连接两侧的组件，并且连接必须为空才能删除。

弯曲连接

要向现有连接添加弯曲点（或弯头），只需双击要弯曲点所在位置的连接即可。然后，您可以使用鼠标抓住弯曲点并拖动它，以便以所需的方式弯曲连接。您可以根据需要添加任意数量的弯曲点。您还可以使用鼠标将连接上的标签拖动并移动到任何现有折弯点。要删除折弯点，只需再次双击即可。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 66][]

### 处理器验证 ###

在尝试启动处理器之前，确保处理器的配置有效非常重要。状态指示器显示在处理器的左上角。如果处理器无效，指示器将显示黄色警告指示器，并带有感叹号，表示存在问题：

![20190319182024945.png][]

在这种情况下，使用鼠标悬停在指示器图标上将提供工具提示，显示处理器的所有验证错误。一旦解决了所有验证错误，状态指示器将变为Stop图标，表示处理器有效并准备启动但当前未运行：

![20190319182032354.png][]

### 站点到站点 (Site-to-Site) ###

当从一个NiFi实例向另一个实例发送数据时，可以使用许多不同的协议。但是，首选协议是NiFi站点到站点协议。站点到站点可以轻松安全高效地将数据传输到一个NiFi实例中的节点或从一个NiFi实例中的节点或数据生成应用程序传输到另一个NiFi实例或其他消费应用程序中的节点。

使用站点到站点提供以下好处：

*  易于配置 (Easy to configure)
    
     *  输入远程NiFi实例的URL后，将自动发现可用端口（端点）并在下拉列表中提供
 *  安全 (Secure)
    
     *  站点到站点可选地使用证书来加密数据并提供身份验证和授权。可以将每个端口配置为仅允许特定用户，并且只有那些用户才能看到该端口甚至存在。有关配置证书的信息，请参阅 “ [系统管理员指南”的“ ][Link 1][安全配置”][Link 11]部分 。
 *  可扩展 (Scalable)
    
     *  随着远程群集中的节点发生更改，将自动检测这些更改，并在群集中的所有节点上扩展数据。
 *  高效(Efficient)
    
     *  站点到站点允许一次发送批量的FlowFiles，以避免建立连接和在对等点之间进行多次往返请求的开销。
 *  可靠(Reliable)
    
     *  校验和由发送方和接收方自动生成，并在数据传输后进行比较，以确保没有发生损坏。如果校验和不匹配，则只会取消交易并再次尝试。
 *  自动加载平衡(Automatically load balanced)
    
     *  当节点联机或退出远程群集，或节点的负载变得更重或更轻时，将自动调整定向到该节点的数据量。
 *  FlowFiles维护属性  (FlowFiles maintain attributes)
    
     *  当通过此协议传输FlowFile时，所有FlowFile的属性都会随之自动传输。这在许多情况下是非常有利的，因为由一个NiFi实例确定的所有上下文和丰富随数据传播，使得数据易于路由并且允许用户容易地检查数据。
 *  适应性强 (Adaptable)
    
     *  随着新技术和新想法的出现，处理站点到站点通信的协议能够随之改变。当与远程NiFi实例建立连接时，执行握手以协商将使用哪种协议和协议版本。这允许添加新功能，同时仍保持与所有旧实例的向后兼容性。此外，如果在协议中发现漏洞或缺陷，它允许更新版本的NiFi禁止通过受损版本的协议进行通信。

站点到站点是在两个NiFi实例之间传输数据的协议。两端可以是独立的NiFi或NiFi集群。在本节中，NiFi实例启动通信称为*站点到站点客户端NiFi实例*，另一端启动为*站点到站点服务器NiFi实例，*以阐明每个NiFi实例所需的配置。

NiFi实例可以是站点到站点协议的客户端和服务器，但是，它只能是特定站点到站点通信中的客户端或服务器。例如，如果有三个NiFi实例A，B和C.甲将数据推送到B，和B从C.提取数据*A — push → B ← pull — C*。那么B不仅是A和B之间通信的*服务器*，还是B和C中的*客户端*。

了解哪个NiFi实例将是客户端或服务器以设计数据流并相应地配置每个实例非常重要。以下是基于数据流方向在哪一方运行的组件的摘要：

*  Push：客户端*将*数据*发送*到远程进程组，服务器通过输入端口*接收*数据
 *  Pull：客户端从远程进程组*接收*数据，服务器通过输出端口*发送*数据

配置站点到站点客户端NiFi实例

**远程进程组(Remote Process Group)**：为了通过站点到站点与远程NiFi实例进行通信，只需将[远程进程组][Link 12]拖到画布上，然后输入远程NiFi实例的URL（有关远程进程组组件的更多信息） ，请参阅 本指南的“ [远程进程组传输”][Link 7]部分。）URL与用于转到该实例的用户界面的URL相同。此时，您可以使用与将处理器连接到处理器或本地进程组的连接相同的方式将连接拖到远程进程组或从远程进程组拖出连接。拖动连接时，您将有机会选择要连接的端口。请注意，远程进程组最多可能需要一分钟才能确定哪些端口可用。

如果从远程进程组开始拖动连接，则显示的端口将是远程组的输出端口，因为这表示您将从远程实例中提取数据。如果连接在远程进程组上结束，则显示的端口将是远程组的输入端口，因为这意味着您将数据推送到远程实例。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>如果远程实例配置为使用安全数据传输，您将只看到您有权与之通信的端口。有关配置NiFi以安全运行的信息，请参阅“&nbsp;<a href="http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html" rel="nofollow">系统管理员指南”</a>。</td> 
  </tr> 
 </tbody> 
</table>

**传输协议**：在远程进程组创建或配置对话框中，您可以选择用于站点到站点通信的传输协议，如下图所示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 67][]

默认情况下，它设置为*RAW*，它使用专用端口使用原始套接字通信。如果远程NiFi实例位于仅允许通过HTTP（S）协议进行访问或仅可从特定HTTP代理服务器访问的受限网络中，则*HTTP*传输协议特别有用。对于通过HTTP代理服务器进行访问，支持BASIC和DIGEST身份验证。

**本地网络接口 (Local Network Interface)**：在某些情况下，可能需要优先选择一个网络接口而不是另一个网络接口。例如，如果存在有线接口和无线接口，则有线接口可能是优选的。可以通过指定要在此框中使用的网络接口的名称来配置。如果输入的值无效，则远程进程组将无效，并且在解决此问题之前不会与其他NiFi实例通信。

配置站点到站点服务器NiFi实例

**检索站点到站点详细信息**：如果您的NiFi正在安全运行，为了让另一个NiFi实例从您的实例中检索信息，需要将其添加到Global Access“检索站点到站点详细信息”策略。这将允许另一个实例查询您的实例以获取详细信息，例如名称，描述，可用对等体（群集时的节点），统计信息，OS端口信息以及可用的输入和输出端口。在安全实例中使用输入和输出端口需要额外的策略配置，如下所述。

**输入端口**：为了允许另一个NiFi实例将数据推送到本地实例，您只需将[输入端口][Link 13]拖到画布的根进程组即可。输入端口名称后，它将添加到您的流程中。您现在可以右键单击“输入端口”并选择“配置”，以便调整用于端口的名称和并发任务数。

如果将站点到站点配置为安全运行，则需要管理端口的“通过站点到站点接收数据”组件访问策略。只有已添加到策略的用户才能与端口通信。

**输出端口**：与输入端口类似，DataFlow Manager可以选择将[输出端口][Link 14]添加到根进程组。输出端口允许授权的NiFi实例远程连接到您的实例并从输出端口提取数据。配置输出端口和管理端口的访问策略将再次允许DFM控制允许的并发任务数，以及授权哪些用户从正在配置的实例中提取数据。

除了NiFi的其他实例之外，一些其他应用程序可以使用站点到站点客户端来将数据推送到NiFi实例或从NiFi实例接收数据。例如，NiFi提供Apache Storm spout和Apache Spark Receiver，它们能够从NiFi的根组输出端口提取数据。

有关如何在NiFi实例上启用和配置站点到站点的信息，请参阅 “ [系统管理员指南”的“ ][Link 1][站点到站点属性”][Link 15]部分 。

有关如何配置访问策略的信息，请参阅 “ [系统管理员指南”的“ ][Link 1][访问属性”][Link 9]部分 。

### 示例Dataflow  ###

本节介绍了构建数据流所需的步骤。现在，把它们放在一起。以下示例数据流仅包含两个处理器：GenerateFlowFile和LogAttribute。这些处理器通常用于测试，但它们也可用于构建快速流程以用于演示目的，并查看NiFi的运行情况。

将GenerateFlowFile和LogAttribute处理器拖到画布并连接它们（使用上面提供的指南）后，按如下所示进行配置：

*  生成FlowFile
    
     *  在“调度”选项卡上，将“运行计划”设置为：5秒。请注意，GenerateFlowFile处理器可以非常快速地创建许多FlowFiles; 这就是为什么设置运行计划很重要，这样这个流程就不会让NiFi运行的系统不堪重负。
     *  在“属性”选项卡上，将“文件大小”设置为：10 KB
 *  日志属性(Log Attribute)
    
     *  在“设置”选项卡上的“自动终止关系”下，选中“成功”旁边的复选框。这将在此处理器成功处理后终止FlowFiles。
     *  同样在“设置”选项卡上，将“公告”级别设置为“信息”。这样，当数据流运行时，此处理器将显示公告图标（请参阅[处理器剖析][Link 16]），用户可以使用鼠标将鼠标悬停在其上以查看处理器正在记录的属性。

数据流应如下所示：

![20190320100133818.png][]

现在请参阅以下有关如何启动和停止数据流的部分。数据流运行时，请务必记下每个处理器正面显示的统计信息（请参阅处理器[剖析][Link 16]）。

## DataFlow的命令和控制 ##

将组件添加到NiFi画布时，它处于“已停止”状态。为了使组件被触发，必须启动组件。一旦启动，组件可以随时停止。从“已停止”状态，可以配置，启动或禁用该组件。

### 启动组件 ###

要启动组件，必须满足以下条件：

*  组件的配置必须有效。
 *  组件的所有已定义关系必须连接到另一个组件或自动终止。
 *  必须停止该组件。
 *  必须启用该组件。
 *  该组件必须没有活动任务。有关活动任务的详细信息，请参阅“解剖......”段下[的数据流的监控][Link 17]（[处理器的剖析][Link 16]，[进程组的解剖][Link 18]，[远程过程组的解剖][Link 19]）。

可以通过选择要启动的所有组件然后单击 “操作选项板”中的`Start`按钮（ ![开始][c7617e53be601d025d765f6cc1cbf4ef.png]）或右键单击单个组件并从上下文菜单中选择“启动”来启动组件。

如果启动进程组，则将启动该进程组中的所有组件（包括子进程组），但无效或禁用的组件除外。

一旦启动，处理器的状态指示器将变为播放符号（ ![跑][759853b6d148f8c3c6f44aa876134b94.png] ）。

### 停止组件 (Stopping a Component) ###

组件可以在运行时停止。通过右键单击组件并从上下文菜单中单击“停止”，或者通过选择组件并单击 “操作选项板”中的`Stop`按钮（ ![停止][3227d441bb87fb7788efc2f2210e7db1.png]）来停止组件。

如果进程组已停止，则将停止进程组（包括子进程组）中的所有组件。

停止后，组件的状态指示器将更改为停止符号（ ![停止][873ad4c216c3cd398d7686382b746ae3.png] ）。

停止组件不会中断其当前正在运行的任务。相反，它会停止安排要执行的新任务。活动任务的数量显示在处理器的右上角（有关 详细信息，请参阅处理器[剖析][Link 16]）。

### 启用/禁用组件 (Enabling/Disabling a Component) ###

启用组件后，即可启动它。例如，用户可以选择在组件仍然是正在组装的数据流的一部分时禁用组件。通常，如果不打算运行组件，则禁用该组件，而不是将其置于“已停止”状态。这有助于区分有意未运行的组件和可能已暂时停止的组件（例如，更改组件的配置），并且无意中从未重新启动。

当需要重新启用组件时，可以通过选择组件并单击 “操作选项板”中的`Enable`按钮（ ![启用][ed5cfd0e71dcb13dff73bf28e2b4da91.png]）来启用它。仅当禁用所选组件时，此选项才可用。或者，可以通过选中“处理器配置”对话框的“设置”选项卡中的“已启用”选项旁边的复选框或端口的配置对话框来启用组件。

启用后，组件的状态指示器将更改为Invalid（ ![无效][dde38ad3a9b181630fbc494a1a0bd11a.png] ）或Stopped（ ![停止][873ad4c216c3cd398d7686382b746ae3.png] ），具体取决于组件是否有效。

然后，通过选择组件并单击“ 操作选项板”中的`Disable`按钮（ ![禁用][95fa205675e8f3d1c19cd08cd565a8e0.png]），或清除“处理器配置”对话框的“设置”选项卡中的“已启用”选项旁边的复选框或端口的配置对话框，可以禁用组件。

只能启用和禁用端口和处理器。

### 远程进程组传输(Remote Process Group Transmission) ###

远程进程组提供了一种向远程NiFi实例发送数据或从中检索数据的机制。将远程进程组（RPG）添加到画布时，会添加“禁用传输”，如![传输禁用][30ea0fe2c1208e12c8df0a30f99bdb84.png] 左上角的图标（ ）所示。当传输被禁用时，可以通过右键单击RPG并单击“启用传输”菜单项来启用它。这将导致有连接的所有端口开始传输数据。这将导致状态指示灯变为Transmission Enabled图标（ ![传输已启用][5f11f91dbbae6f7e76f1e126b54b3552.png] ）。

如果与远程进程组通信时出现问题，则![警告][dde38ad3a9b181630fbc494a1a0bd11a.png] 可能会在左上角显示警告指示符（ ）。使用鼠标将鼠标悬停在此警告指示器上将提供有关该问题的更多信息。

ndividual Port Transmission

有时，DFM可能希望仅为远程进程组中的特定端口启用或禁用传输。这可以通过右键单击远程进程组并选择“远程端口”菜单项来完成。这提供了一个配置对话框，可以从中配置每个端口：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 68][]

左侧列出了NiFi远程实例允许发送数据的所有输入端口。右侧列出了此实例能够从中提取数据的所有输出端口。如果远程实例正在使用安全通信（NiFi实例的URL以`https://`，而不是`http://`），则不会显示远程实例未对此实例可用的任何端口。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>如果此对话框中未显示预期显示的端口，请确保实例具有适当的权限，并且远程进程组的流是最新的。可以通过关闭“端口配置”对话框并查看“远程进程组”的右下角来检查。显示上次刷新流的日期。如果流程似乎已过时，可以通过右键单击远程进程组并选择“刷新流程”来更新它。（有关更多信息，请参阅<a href="http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#remote_group_anatomy" rel="nofollow">远程过程组剖析</a>）。</td> 
  </tr> 
 </tbody> 
</table>

每个端口都显示端口名称，后跟其描述，当前配置的并发任务数，以及是否将压缩发送到此端口的数据。此信息的左侧是用于打开或关闭端口的开关。那些没有连接到它们的连接的端口显示为灰色：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 69][]

on/off 开关提供了一种机制，可以独立地启用和禁用远程过程组中每个端口的传输。可以通过单击![编辑][66b415776252bbcedaf1ddd7355e107b.png] 开/关开关下方的铅笔图标（）来配置已连接但当前未传输的端口 。单击此图标将允许DFM更改并发任务的数量，以及在向此端口传输数据时是否应使用压缩。

## 在DataFlow中导航 ##

NiFi提供各种机制来绕过数据流。该[NiFi用户界面][NiFi]部分描述了在NiFi画布中导航的各种方法; 但是，一旦画布上存在流，就会有其他方法从一个组件到另一个组件。当流中存在多个流程组时，面包屑会显示在屏幕底部，提供在它们之间导航的方法。此外，要进入当前在画布上可见的进程组，只需双击它，从而“向下钻取”它。Connections还提供了一种在流程中从一个位置跳转到另一个位置的方法。右键单击连接并选择“转到源”或“转到目标”以跳转到连接的一端或另一端。这在大型复杂数据流中非常有用，其中连接线可能很长并且跨越画布的大部分区域。最后，所有组件都提供在流程中向前或向后跳跃的能力。右键单击任何组件（例如，处理器，进程组，端口等），然后选择“上游连接”或“下游连接”。将打开一个对话框窗口，显示用户可以跳转到的可用上游或下游连接。当尝试沿向后方向跟踪数据流时，这尤其有用。通常很容易从头到尾跟踪数据流的路径，向下钻取到嵌套的流程组; 但是，在另一个方向上跟踪数据流可能更加困难。将打开一个对话框窗口，显示用户可以跳转到的可用上游或下游连接。当尝试沿向后方向跟踪数据流时，这尤其有用。通常很容易从头到尾跟踪数据流的路径，向下钻取到嵌套的流程组; 但是，在另一个方向上跟踪数据流可能更加困难。将打开一个对话框窗口，显示用户可以跳转到的可用上游或下游连接。当尝试沿向后方向跟踪数据流时，这尤其有用。通常很容易从头到尾跟踪数据流的路径，向下钻取到嵌套的流程组; 但是，在另一个方向上跟踪数据流可能更加困难。

### 组件链接 ###

超链接可用于直接导航到NiFi画布上的组件。在配置[多租户授权][Link 20]时，这尤其有用。例如，可以将URL提供给用户以将其定向到他们具有特权的特定进程组。

NiFI实例的默认URL是`http://<hostname>:8080/nifi`指向根进程组。在画布上选择组件后，将使用表单中组件的进程组ID和组件ID更新URL `http://<hostname>:8080/nifi/?processGroupId=<UUID>&componentIds=<UUIDs>;`。在以下屏幕截图中，进程组PG1中的GenerateFlowFile处理器是所选组件：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 70][]

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>支持链接到画布上的多个组件，但限制URL的长度不能超过2000个字符。</td> 
  </tr> 
 </tbody> 
</table>

### 组件对齐 ###

NiFi画布上的组件可以对齐，以更精确地排列数据流。为此，首先选择要对齐的所有组件。然后右键单击以查看上下文菜单，并根据所需结果选择“垂直对齐”或“水平对齐”。

垂直对齐

以下是在画布上垂直对齐组件的示例。选中/突出显示所有组件后，右键单击：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 71][]

并选择“垂直对齐”以获得以下结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 72][]

水平对齐

以下是在画布上水平对齐组件的示例。选中/突出显示所有组件后，右键单击：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 73][]

并选择“水平对齐”以获得以下结果：

![20190320100727280.png][]

## 监控DataFlow ##

NiFi提供有关DataFlow的大量信息，以便监控其健康状况。状态栏提供有关整体系统运行状况的信息（请参阅[NiFi用户界面][NiFi]）。处理器，进程组和远程进程组提供有关其操作的细粒度详细信息。连接和进程组提供有关其队列中数据量的信息。摘要页面以表格格式提供有关画布上所有组件的信息，还提供包括磁盘使用情况，CPU利用率以及Java堆和垃圾收集信息的系统诊断。在群集环境中，此信息可以按节点使用，也可以作为整个群集中的聚合使用。我们将在下面探讨每个监控工件。

### 处理器的剖析 ###

NiFi提供有关画布上每个处理器的大量信息。下图显示了处理器的解剖结构：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 74][]

该图像概述了以下元素：

*  **处理器类型(Processor Type)**：NiFi提供多种不同类型的处理器，以便执行各种任务。每种类型的处理器都旨在执行一项特定任务。处理器类型（在此示例中为PutFile）描述了此处理器执行的任务。在这种情况下，处理器将FlowFile写入磁盘 - 或者将FlowFile“放入”文件。
 *  **公告指示器(Bulletin Indicator)**：当处理器记录某个事件已发生时，它会生成一个公告，以通过用户界面通知正在监控NiFi的人员。DFM能够通过更新“处理器配置”对话框的“设置”选项卡中的“公告级别”字段来配置应在用户界面中显示的公告。默认值为`WARN`，这意味着UI中仅显示警告和错误。除非此处理器存在公告，否则此图标不存在。当它出现时，用鼠标悬停在图标上将提供一个工具提示，说明处理器和公告级别提供的消息。如果NiFi的实例是群集的，它还将显示发布公告的节点。
 *  **状态指示灯(Status Indicator)**：显示处理器的当前状态。以下指标是可能的：
    
     *  ![运行][759853b6d148f8c3c6f44aa876134b94.png] **正在运行(Running)**：处理器当前正在运行。
     *  ![停止][873ad4c216c3cd398d7686382b746ae3.png] **已停止(Stopped)**：处理器有效并已启用但未运行。
     *  ![无效][dde38ad3a9b181630fbc494a1a0bd11a.png] **无效(Invalid)**：处理器已启用但当前无效且无法启动。将鼠标悬停在此图标上将提供工具提示，指示处理器无效的原因。
     *  ![残][877c9f4dd42805ad926528690381ac9a.png] **已禁用(Disabled)**：处理器未运行，在启用之前无法启动。此状态不表示处理器是否有效。
 *  **处理器名称(Processor Name)**：这是**处理器**的用户定义名称。默认情况下，Processor的名称与Processor Type相同。在示例中，此值为“Copy to /review”。
 *  **活动任务( Active Tasks )**：此处理器当前正在执行的任务数。此数字受“处理器配置”对话框的“计划”选项卡中的“并发任务”设置的约束。在这里，我们可以看到处理器当前正在执行一项任务。如果NiFi实例是群集的，则此值表示当前正在群集中的所有节点上执行的任务数。
 *  **5分钟统计(5-Minute Statistics)**：处理器以表格形式显示几种不同的统计数据。这些统计数据中的每一个都代表过去五分钟内完成的工作量。如果NiFi实例是群集的，则这些值表示在过去五分钟内所有节点组合完成了多少工作。这些指标是：
    
     *  **In**：处理器从其传入Connections的队列中提取的数据量。此值表示为<count>（<size>），其中<count>是从队列中提取的FlowFiles的数量，<size>是这些FlowFiles内容的总大小。在此示例中，处理器已从输入队列中提取了29个FlowFiles，总计14.16兆字节（MB）。
     *  **读/写(Read/Write)**：处理器从磁盘读取并写入磁盘的FlowFile内容的总大小。这提供了有关此处理器所需的I / O性能的有用信息。某些处理器可能只读取数据而不写入任何内容，而某些处理器不会读取数据但只会写入数据。其他人既不会读取也不会写入数据，而某些处理器会读取和写入数据。在这个例子中，我们看到在过去的五分钟内，这个处理器读取了4.88 MB的FlowFile内容，并且写了4.88 MB。这是我们所期望的，因为这个处理器只是将FlowFile的内容复制到磁盘。但请注意，这与从输入队列中提取的数据量不同。这是因为它从输入队列中提取的某些文件已经存在于输出目录中，并且处理器配置为在发生这种情况时将FlowFiles路由到失败。因此，对于那些已经存在于输出目录中的文件，数据既不会被读取也不会被写入磁盘。
     *  **Out**：处理器已传输到其出站连接的数据量。这不包括处理器自行删除的FlowFiles，也不包括路由到自动终止的连接的FlowFiles。与上面的“In”指标一样，此值表示为<count>（<size>），其中<count>是已传输到出站Connections的FlowFiles的数量，<size>是这些FlowFiles内容的总大小。在此示例中，所有关系都配置为自动终止，因此不会报告任何FlowFiles已被转出。
     *  **任务/时间(Tasks/Time)**：此处理器在过去5分钟内被触发运行的次数，以及执行这些任务所花费的时间。时间格式为<hour>：<minute>：<second>。请注意，所花费的时间可能超过五分钟，因为许多任务可以并行执行。例如，如果处理器计划运行60个并发任务，并且每个任务都需要一秒钟才能完成，则所有60个任务可能会在一秒钟内完成。但是，在这种情况下，我们会看到时间指标显示它需要60秒，而不是1秒。这个时间可以被认为是“系统时间”，或换句话说，

### 过程组的剖析 ###

进程组提供了一种机制，用于将组件组合到一个逻辑构造中，以便以更高级别更容易理解的方式组织DataFlow。下图突出显示了构成Process Group解剖结构的不同元素：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 75][]

过程组由以下元素组成：

*  **名称**：这是进程组的用户定义名称。将进程组添加到画布时，将设置此名称。稍后可以通过右键单击“进程组”并单击“配置”菜单选项来更改名称。在此示例中，进程组的名称是“Process Group ABC”。
 *  **公告指示器(Bulletin Indicator)**：当进程组的子组件发布公告时，该公告也会传播到组件的父进程组。当任何组件具有活动公告时，将显示此指示符，允许用户使用鼠标将鼠标悬停在图标上以查看公告。
 *  **活动任务**：此进程组中组件当前正在执行的任务数。在这里，我们可以看到Process Group当前正在执行两项任务。如果NiFi实例是群集的，则此值表示当前正在群集中的所有节点上执行的任务数。
 *  **统计信息**：流程组提供有关过程组在过去5分钟内处理的数据量以及当前在流程组中排队的数据量的统计信息。以下元素包含流程组的“统计”部分：
    
     *  **排队**：当前在进程组中排队的FlowFiles数。此字段表示为<count>（<size>），其中<count>是当前在Process Group中排队的FlowFiles的数量，<size>是这些FlowFiles内容的总大小。在此示例中，Process Group当前有26个FlowFiles排队，总大小为12.7兆字节（MB）。
     *  **In**：在过去5分钟内通过其所有输入端口传输到Process Group的FlowFiles数。此字段表示为<count> / <size>→<ports>，其中<count>是过去5分钟内进入Process Group的FlowFiles的数量，<size>是这些FlowFiles内容的总大小， <ports>是输入端口的数量。在此示例中，8个FlowFiles已进入进程组，总大小为800 KB，并且存在两个输入端口。
     *  **读/写**：进程组中的组件已从磁盘读取并写入磁盘的FlowFile内容的总大小。这提供了有关此Process Group所需的I / O性能的有用信息。在此示例中，我们看到在过去五分钟内，此Process Group中的组件读取了14.72 MB的FlowFile内容，并写入了14.8 MB。
     *  **Out**：在过去5分钟内通过其输出端口传输出Process Group的FlowFiles数。此字段表示为<ports>→<count>（<size>），其中<ports>是输出端口的数量，<count>是过去5分钟内退出Process Group的FlowFiles的数量和<size >是FlowFiles内容的总大小。在此示例中，有三个输出端口，16个FlowFiles已退出进程组，其总大小为78.57 KB。
 *  **组件计数**：组件计数元素提供有关进程组中每种类型的组件数量的信息。以下提供了有关这些图标及其含义的信息：
    
     *  ![传输有效][5f11f91dbbae6f7e76f1e126b54b3552.png] **传输端口**：当前配置为将数据传输到远程NiFi实例或从远程NiFi实例提取数据的远程进程组端口的数量。
     *  ![传输无效][30ea0fe2c1208e12c8df0a30f99bdb84.png] **非传输端口**：当前连接到此进程组中的组件但当前已禁用其传输的远程进程组端口的数量。
     *  ![运行][759853b6d148f8c3c6f44aa876134b94.png] **运行组件**：当前在此进程组中运行的处理器，输入端口和输出端口的数量。
     *  ![停止组件][873ad4c216c3cd398d7686382b746ae3.png] **已停止的组件**：当前未运行但有效且已启用的处理器，输入端口和输出端口的数量。这些组件已准备好启动。
     *  ![无效的组件][dde38ad3a9b181630fbc494a1a0bd11a.png] **无效组件**：已启用但当前未处于有效状态的处理器，输入端口和输出端口的数量。这可能是由于配置错误或缺少关系造成的。
     *  ![残疾人组件][877c9f4dd42805ad926528690381ac9a.png] **已禁用组件**：当前已禁用的处理器，输入端口和输出端口的数量。这些组件可能有效，也可能无效。如果启动了进程组，则这些组件不会导致任何错误，但不会启动。
 *  **版本状态计数**：版本状态计数元素提供有关进程组中有多少版本化进程组的信息。有关更多信息，请参阅[版本状态][Link 21]
 *  **注释**：将流程组添加到画布时，将为用户提供指定注释的选项，以便提供有关流程组的信息。稍后可以通过右键单击“进程组”并单击“配置”菜单选项来更改注释。

### 远程过程组的剖析 ###

创建DataFlow时，通常需要将数据从一个NiFi实例传输到另一个实例。在这种情况下，NiFi的远程实例可以被视为进程组。因此，NiFi提供了远程过程组的概念。从用户界面，远程进程组看起来类似于进程组。但是，不是显示有关远程进程组的内部工作和状态的信息（例如队列大小），而是呈现有关远程进程组的信息与此NiFi实例与远程实例之间发生的交互有关。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 76][]

上图显示了组成远程进程组的不同元素。在这里，我们提供有关所提供信息的图标和详细信息的说明。

*  **传输状态**：传输状态指示当前是否启用此NiFi实例与远程实例之间的数据传输。![传输有效][5f11f91dbbae6f7e76f1e126b54b3552.png] 如果任何输入端口或输出端口当前配置为传输，则显示的图标将是Transmission Enabled图标（ ）如果![传输无效][30ea0fe2c1208e12c8df0a30f99bdb84.png] 当前连接的所有输入端口和输出端口都已停止，则传输已禁用图标（ ）。
 *  **远程实例名称**：这是远程实例报告的NiFi实例的名称。首次创建远程进程组时，在获取此信息之前，此处将显示远程实例的URL。
 *  **远程实例URL**：这是远程进程组指向的远程实例的URL。将远程进程组添加到画布并且无法更改时，将输入此URL。
 *  **安全指示器**：此图标指示与远程NiFi实例的通信是否安全。如果与远程实例的通信是安全的，则将通过“锁定”图标（![安全][2887109c77395c8da193b29143b8913b.png] ）指示 。如果通信不安全，将通过“未锁定”图标指示（ ![不安全][72a36a311e91e905e90ca57f4622c662.png] ）。如果通信是安全的，则在远程实例的管理员授予访问权限之前，此NiFi实例将无法与远程实例通信。每当将远程进程组添加到画布时，这将自动发起请求，以便在远程实例上创建此NiFi实例的用户。在远程实例上的管理员将用户添加到系统并向用户添加“NiFi”角色之前，此实例将无法与远程实例通信。如果通信不安全，远程进程组可以从任何人接收数据，并且在NiFi实例之间传输数据时不会对数据进行加密。
 *  **5分钟统计信息**：显示远程进程组的两个统计信息：已**发送**和已**接收**。这两种格式都是<count>（<size>）格式，其中<count>是在前五分钟内发送或接收的FlowFiles的数量，<size>是这些FlowFiles内容的总大小。
 *  **注释**：为远程进程组提供的注释不是由此NiFi的用户添加的注释，而是由远程实例的管理员添加的注释。这些评论表明了NiFi实例的整体目的。
 *  **上次刷新时间**：从远程实例中提取并在用户界面中的远程进程组上呈现的信息会在后台定期刷新。此元素指示最后一次刷新的时间，或者如果信息在相当长的时间内未刷新，则该值将更改为指示*远程流不是最新的*。通过右键单击远程进程组并选择“刷新流程”菜单项，可以触发NiFi以启动刷新此信息。

### 队列交互 ###

必要时，可以查看连接中排队的FlowFiles。队列列表通过`List queue`Connection的上下文菜单打开。该列表将根据配置的优先级返回活动队列中的前100个FlowFiles。即使源和目标正在运行，也可以执行列表。

此外，单击最左侧列中的`Details`按钮（![细节][f17792a92439081c2f9017ae6f96470f.png]）可以查看列表中Flowfile的详细信息。从这里，可以使用FlowFile详细信息和属性以及用于下载或查看内容的按钮。仅在`nifi.content.viewer.url`已配置内容时才能查看内容。如果Connection的源或目标正在运行，则所需的FlowFile可能不再位于活动队列中。

必要时，还可以删除连接中排队的FlowFiles。通过`Empty queue`Connection的上下文菜单启动FlowFiles的删除。如果源和目标正在运行，也可以执行此操作。

### 摘要页面 ###

虽然NiFi画布对于了解如何布置配置的DataFlow非常有用，但在尝试辨别系统状态时，此视图并不总是最佳的。为了帮助用户了解DataFlow在更高级别的运行方式，NiFi提供了“摘要”页面。此页面位于用户界面右上角的“全局菜单”中。有关此工具栏位置的详细信息，请参阅[NiFi用户界面][NiFi]部分。

通过从全局菜单中选择摘要来打开摘要页面。这将打开“摘要”表对话框：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 77][]

此对话框提供有关画布上每个组件的大量信息。下面，我们在对话框中注释了不同的元素，以便更容易地讨论对话框。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 78][]

“摘要”页面主要由一个表组成，该表提供有关画布上每个组件的信息。此表上方是一组五个选项卡，可用于查看不同类型的组件。表中提供的信息与为画布上的每个组件提供的信息相同。可以通过单击列的标题对表中的每个列进行排序。有关详细上显示的类型的信息，请参见部分 [的处理器的解剖学][Link 16]，[一个过程组的解剖学][Link 18]，和[一个远程过程组的解剖学][Link 19]的上方。

“摘要”页面还包含以下元素：

*  **公告指示器(Bulletin Indicator)**：与整个用户界面中的其他位置一样，当此图标存在时，将鼠标悬停在图标上将提供有关生成的公告的信息，包括消息，严重性级别，公告生成的时间以及（在集群环境中）生成公告的节点。与“摘要”表中的所有列一样，可以通过单击标题对显示公告的列进行排序，以便所有当前存在的公告显示在列表顶部。
 *  **详细信息 (Details)**：单击“详细信息”图标将为用户提供组件的详细信息。此对话框与用户右键单击组件并选择“查看配置”菜单项时提供的对话框相同。
 *  **转到(Go To)**：单击此按钮将关闭“摘要”页面，并将用户直接带到NiFi画布上的组件。这可能会更改用户当前所在的进程组。如果已在新的浏览器选项卡或窗口中打开“摘要”页面（通过单击“弹出”按钮，如下所述），则此图标不可用。
 *  **状态历史记录(Status History)**：单击“状态历史记录”图标将打开一个新对话框，其中显示为此组件呈现的统计信息的历史视图。有关更多信息，请参阅[组件的历史统计][Link 22]信息部分。
 *  **刷新(Refresh)**：该`Refresh`按钮允许用户刷新显示的信息，而无需关闭对话框并再次打开它。上次刷新信息的时间显示在`Refresh`按钮右侧。页面上的信息不会自动刷新。
 *  **过滤器(Filter)**：Filter元素允许用户通过键入全部或部分条件（例如“处理器类型”或“处理器名称”）来过滤“摘要”表的内容。可用的过滤器类型根据所选选项卡而不同。例如，如果查看“处理器”选项卡，则用户可以按名称或类型进行过滤。查看“连接”选项卡时，用户可以按源，名称或目标名称进行筛选。更改文本框的内容时，将自动应用过滤器。文本框下方是表中表中有多少条目与过滤器匹配以及表中存在多少条目的指示符。
 *  **弹出(Pop-Out)**：监视流时，能够在单独的浏览器选项卡或窗口中打开摘要表是有帮助的。按钮旁边的“弹出”按钮`Close`将导致在新的浏览器选项卡或窗口中打开整个“摘要”对话框（具体取决于浏览器的配置）。页面“弹出”后，对话框将在原始浏览器选项卡/窗口中关闭。在新选项卡/窗口中，“弹出”按钮和“转到”按钮将不再可用。
 *  **系统诊断(System Diagnostics)**：“系统诊断”窗口提供有关系统在系统资源利用率方面的执行情况的信息。虽然这主要适用于管理员，但在此视图中提供了它，因为它确实提供了系统摘要。此对话框显示CPU利用率，磁盘空闲程度以及特定于Java的度量标准（如内存大小和利用率）以及垃圾收集信息等信息。

### 组件的历史统计 (Historical Statistics of a Component) ###

虽然“摘要”表和画布显示了与过去五分钟内组件性能相关的数字统计信息，但查看历史统计信息通常也很有用。通过右键单击组件并选择“状态历史记录”菜单选项或单击“摘要”页面中的“状态历史记录”（ 有关详细信息，请参阅[摘要页面）][Link 23]，可以获得此信息。

存储的历史信息量可在NiFi属性中配置，但默认为`24 hours`。有关特定配置信息，请参阅“ [系统管理员指南”的“][Link 1]组件状态存储库[”][Link 1]。打开“状态历史记录”对话框时，它会提供历史统计信息的图表：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 79][]

对话框的左侧提供有关统计信息所用组件的信息，以及绘制统计信息的文本表示。左侧提供以下信息：

*  **Id**：正在显示统计信息的组件的ID。
 *  **Group ID**：组件所在的进程组的ID。
 *  **Name**：要显示统计信息的组件的名称。
 *  **Component-Specific Entries**：显示每种不同类型组件的信息。例如，对于处理器，将显示处理器的类型。对于Connection，将显示源和目标名称和ID。
 *  **Start**：图表上显示的最早时间。
 *  **End**：图表上显示的最新时间。
 *  **Min/Max/Mean**：显示最小值，最大值和平均值（算术平均值或平均值）。如果选择了任何时间范围，这些值仅基于所选时间范围。如果对此NiFi实例进行聚类，则会为整个群集以及每个单独节点显示这些值。在群集环境中，每个节点以不同的颜色显示。这也用作图形的图例，显示图形中显示的每个节点的颜色。将鼠标悬停在群集上或图例中的其中一个节点上也会使相应的节点在图形中变为粗体。

对话框的右侧提供了下表中要呈现的不同类型度量标准的下拉列表。顶部图形较大，以便提供更容易阅读的信息呈现。在该图的右下角是一个小手柄（ ![调整][252614a6537a62d5aba8060a5246109e.png] ），可以拖动它来调整图形的大小。也可以拖动对话框的空白区域以移动整个对话框。

底部图表更短，并提供选择时间范围的能力。在此处选择时间范围将使顶部图形仅显示所选的时间范围，但是以更详细的方式显示。此外，这将导致重新计算左侧的最小值/最大值/平均值。通过在图形上拖动矩形创建选择后，双击所选部分将使选择在垂直方向上完全展开（即，它将选择此时间范围内的所有值）。单击底部图形而不拖动将删除选择。

## 版本化DataFlow ( Versioning a DataFlow ) ##

当NiFi连接到NiFi注册表时，可以在进程组级别对数据流进行版本控制。有关NiFi Registry使用和配置的更多信息，请参阅[https://nifi.apache.org/docs/nifi-registry-docs/index.html上][https_nifi.apache.org_docs_nifi-registry-docs_index.html]的文档。

### 连接到NiFi注册表 ###

要将NiFi连接到注册表，请从全局菜单中选择控制器设置。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 80][]

这将显示“NiFi设置”窗口。选择“注册表客户端”选项卡，然后单击右上角的`+`按钮以注册新的注册表客户端。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 81][]

在“添加注册表客户端”窗口中，提供名称和URL。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 82][]

单击“添加”以完成注册。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 83][]

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>版本化流程在注册表桶中存储和组织。注册管理员配置的存储桶策略和特权限定了用户可以从中导入版本化流的哪些存储桶以及用户可以将版本化流存储到哪些存储桶。有关存储桶策略和特权的信息可以在NiFi注册表用户指南（<a href="https://nifi.apache.org/docs/nifi-registry-docs/html/user-guide.html" rel="nofollow">https://nifi.apache.org/docs/nifi-registry-docs/html/user-guide.html</a>）中找到。</td> 
  </tr> 
 </tbody> 
</table>

### 版本国家 ###

版本化的进程组存在以下状态：

*  ![最新][9eff48cc903c8c179d2b7174870e6abc.png] **最新**：流程的版本是最新的。
 *  ![本地修改][b32cc76e982adc69df68753c28d84c27.png] **本地修改**：已进行本地更改。
 *  ![陈旧][22b106335d608c35d5304cd48e3e8abd.png] **陈旧**：可以使用更新版本的流程。
 *  ![本地修改和陈旧][3291026bc47e7a77fa60c88a78a1a43b.png] **本地修改和陈旧**：已进行本地更改，并且可以使用更新版本的流。
 *  ![同步失败][90df5c9bd3a89761ed0d29cb08b54bf4.png] **同步失败**：无法将流与注册表同步。

显示版本状态信息：

1.  进程组名称旁边的版本化进程组本身。将鼠标悬停在状态图标上会显示有关版本化流程的其他信息。
2.  在进程组的底部，用于进程组中包含的版本化流。
3.  在UI顶部的状态栏中，用于根进程组中包含的版本化流。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 84][]

版本状态信息也显示在摘要页面的“过程组”选项卡中。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 85][]

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>要查看最新版本状态，可能需要右键单击NiFi画布并从上下文菜单中选择“刷新”。</td> 
  </tr> 
 </tbody> 
</table>

### 导入版本化流程 ###

当NiFi实例连接到注册表时，“导入”链接将出现在“添加进程组”对话框中。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 86][]

选择链接将打开“导入版本”对话框。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 87][]

已连接的注册表将显示为“注册表”下拉菜单中的选项。对于选定的注册表，用户有权访问的存储桶将显示为“存储桶”下拉菜单中的选项。所选存储桶中的流的名称将显示为“名称”下拉菜单中的选项。选择要导入的流的所需版本，然后为要放置在画布上的数据流选择“导入”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 88][]

由于此示例中导入的版本是最新版本（MySQL CDC，版本3），因此版本化进程组的状态为“最新”（![最新的图标][9eff48cc903c8c179d2b7174870e6abc.png]）。如果导入的版本是旧版本，则状态将为“Stale”（![陈旧的图标][22b106335d608c35d5304cd48e3e8abd.png]）。

### 启动版本控制 ###

要将进程组置于版本控制之下，请右键单击进程组，然后在上下文菜单中选择“版本→启动版本控制”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 89][]

在Save Flow Version窗口中，选择Registry and Bucket并输入Flow的名称。如果需要，请为“描述”和“注释”字段添加内容。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 90][]

选择保存并保存流的版本1。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 91][]

作为流的第一个和最新版本，版本化进程组的状态为“最新”（![最新的图标][9eff48cc903c8c179d2b7174870e6abc.png]）。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>根进程组不能置于版本控制之下。</td> 
  </tr> 
 </tbody> 
</table>

### 管理本地更改 ###

当对版本化的进程组进行更改时，组件的状态将更新为“Locally modified”（![本地修改的图标][b32cc76e982adc69df68753c28d84c27.png]）。DFM可以显示，还原或提交本地更改。右键单击进程组时，可以在上下文菜单中选择这些选项：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 92][]

或者右键单击进程组内的画布：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 93][]

以下操作不被视为本地更改：

*  禁用/启用处理器和控制器服务
 *  停止/启动处理器
 *  修改敏感属性值
 *  修改远程进程组URL
 *  更新引用不存在的控制器服务的处理器以引用外部可用的控制器服务
 *  创建，修改或删除变量

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>创建变量不会触发本地更改，因为创建变量本身并未改变流程处理的任何内容。必须创建或修改使用新变量的组件，这将触发本地更改。修改变量不会触发本地更改，因为变量值在每个环境中都是不同的。导入版本化流时，假定需要一次性操作来设置特定于给定环境的变量。删除变量不会触发本地更改，因为需要修改引用该变量的组件，这将触发本地更改。</td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>变量不支持敏感值，并且在对流程组进行版本控制时将包含变量。有关更多信息，请参阅<a href="http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Variables_in_Versioned_Flows" rel="nofollow">版本化流程中的变量</a>。</td> 
  </tr> 
 </tbody> 
</table>

显示本地更改

通过从上下文菜单中选择“版本→显示本地更改”，可以在“显示本地更改”对话框中查看对版本化过程组所做的本地更改。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 94][]

您可以通过选择![去][c8c63556d56bc17f62c471b19e51a9b7.png]其行中的“转到”图标（）来导航到组件。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>如“&nbsp;<a href="http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#managing_local_changes" rel="nofollow">管理本地更改”</a>部分中所述，有些例外可以检查哪些操作是本地更改。此外，对同一属性的多次更改将仅显示为列表中的一个更改，因为更改是通过区分进程组的当前状态和“显示本地更改”对话框中记录的进程组的已保存版本来确定的。</td> 
  </tr> 
 </tbody> 
</table>

还原本地更改

通过从上下文菜单中选择“版本→还原本地更改”，还原对版本化进程组所做的本地更改。“还原本地更改”对话框显示DFM在启动还原之前要查看和考虑的本地更改列表。选择“还原”以删除所有更改。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 95][]

您可以通过选择![去][c8c63556d56bc17f62c471b19e51a9b7.png]其行中的“转到”图标（）来导航到组件。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>如“&nbsp;<a href="http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#managing_local_changes" rel="nofollow">管理本地更改”</a>部分中所述，有些例外可以将可更改的本地更改作为操作。此外，对同一属性的多次更改将仅显示为列表中的一个更改，因为更改是通过区分进程组的当前状态和“还原本地更改”对话框中记录的进程组的已保存版本来确定的。</td> 
  </tr> 
 </tbody> 
</table>

提交本地更改

要提交和保存流版本，请从上下文菜单中选择“版本→提交本地更改”。在“保存流版本”对话框中，根据需要添加注释，然后选择“保存”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 96][]

如果已修改的版本不是最新版本，则无法提交本地更改。在这种情况下，版本状态是“本地修改和陈旧”（![本地修改和陈旧][3291026bc47e7a77fa60c88a78a1a43b.png]）。

### 更改版本 ###

要更改流的版本，请右键单击版本化的流程组，然后选择“版本→更改版本”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 97][]

在“更改版本”对话框中，选择所需的版本并选择“更改”：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 98][]

流的版本已更改：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 99][]

在所示示例中，版本化流程从较旧版本升级到较新版本。但是，版本化流程也可以回滚到旧版本。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>要使“更改版本”成为可用选择，需要还原对进程组的本地更改。</td> 
  </tr> 
 </tbody> 
</table>

### 停止版本控制 ###

要停止对流的版本控制，请右键单击版本化的进程组，然后选择“版本→停止版本控制”：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 100][]

在“停止版本控制”对话框中，选择“断开连接”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 101][]

确认从版本控制中删除进程组。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 102][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 103][]

### 嵌套版本化流程 ###

版本化进程组可以包含其他版本化进程组。但是，如果父进程组包含也具有本地更改的子进程组，则无法还原或保存对父进程组的本地更改。必须首先还原子进程组，或者为要在父进程组上执行的操作提交其更改。

### 版本化流程中的变量 ###

当进程组置于版本控制之下时，会包含变量。如果导入的版本化流引用了未在版本化进程组中定义的变量，则在变量存在时保留引用。如果引用的变量不存在，则将在进程组中定义变量的副本。为了说明，假设变量“RPG\_Var”在根进程组中定义：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 104][]

创建进程组PG1：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 105][]

PG1中的GetFile处理器引用变量“RPG\_Var”：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 106][]

PG1保存为版本化流程：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 107][]

如果PG1版本化流程导入到同一个NiFi实例中：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 108][]

添加的GetFile处理器还将引用根进程组中存在的“RPG\_Var”变量：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 109][]

如果PG1版本化流程导入到不存在“RPG\_Var”的不同NiFi实例中：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 110][]

在PG1进程组中创建“RPG\_Var”变量：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 111][]

### 版本化流程中受限制的组件 ###

要导入版本化流程或还原版本化流程中的本地更改，用户必须能够访问版本化流程中的所有组件。因此，如果要在版本化流程中使用受限组件，则建议在根进程组级别创建受限组件。让我们通过一些示例来说明此配置的好处。假设如下：

*  有两个用户“sys\_admin”和“test\_user”可以访问查看和修改根进程组。
 *  “sys\_admin”可以访问所有受限制的组件。
    
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 112][]
 *  “test\_user”可以访问需要“读取文件系统”和“写入文件系统”的受限组件。
 *   
    
     
    
     
    
     
    
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 113][]
    
     
    
     
    
    ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 114][]

根进程组中创建的受限制的控制器服务

在第一个示例中，sys\_admin在根进程组级别创建KeytabCredentialsService控制器服务。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 115][]

KeytabCredentialService控制器服务是一个受限制的组件，需要“访问密钥表”权限：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 116][]

Sys\_admin使用GetFile和PutHDFS处理器创建一个包含流的进程组ABC：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 117][]

GetFile处理器是一个受限制的组件，需要“写文件系统”和“读取文件系统”权限：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 118][]

PutHDFS是一个受限制的组件，需要“写文件系统”权限：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 119][]

PutHDFS处理器配置为使用根进程组级别KeytabCredentialsService控制器服务：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 120][]

Sys\_admin将进程组保存为版本化流：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 121][]

Test\_user通过删除KeytabCredentialsService控制器服务来更改流程：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 122][]

如果test\_user选择还原此更改：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 123][]

恢复成功：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 124][]

此外，如果test\_user选择导入ABC版本化流程：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 125][]

导入成功：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 126][]

流程组中创建的受限制的控制器服务

现在，考虑第二种情况，即在进程组级别创建控制器服务。

Sys\_admin创建一个进程组XYZ：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 127][]

Sys\_admin在进程组级别创建KeytabCredentialsService控制器服务：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 128][]

在进程组中创建相同的GetFile和PutHDFS流：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 129][]

但是，PutHDFS现在引用了进程组级控制器服务：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 130][]

Sys\_admin将进程组保存为版本化流。

Test\_user通过删除KeytabCredentialsService控制器服务来更改流。但是，使用此配置，如果test\_user尝试还原此更改：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 131][]

恢复不成功，因为test\_user没有KeytabCredentialService控制器服务所需的“访问密钥表”权限：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 132][]

同样，如果test\_user尝试导入XYZ版本化流程：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 133][]

导入失败：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 134][]

## 模板 ##

DFM能够使用NiFi构建非常大且复杂的DataFlow。这是通过使用基本组件实现的：处理器，漏斗，输入/输出端口，进程组和远程进程组。这些可以被认为是构建DataFlow的最基本构建块。但是，有时候，如果需要重复多次相同的逻辑，使用这些小的构建块会变得乏味。

为了解决这个问题，NiFi提供了模板的概念。模板是将这些基本构建块组合成更大的构建块的一种方式。创建DataFlow后，可以将其中的一部分组成模板。然后可以将此模板拖到画布上，也可以将其导出为XML文件并与其他人共享。然后可以将从其他人处接收的模板导入NiFi实例并拖动到画布上。

### 创建模板 ###

要创建模板，请选择要作为模板一部分的组件，然后单击 操作选项板中的 `Create Template`（ ![创建模板][96cce223a473f4e58ddca05b2409ce09.png]）按钮（有关操作选项板的更多信息，请参阅[NiFi用户界面][NiFi]）。

单击此按钮而不选择任何内容将创建一个包含当前进程组的所有内容的模板。这意味着在根进程组上创建一个没有选择任何内容的模板将创建一个包含整个流的模板。

单击此按钮后，将提示用户提供模板的名称和可选说明。每个模板都必须具有唯一的名称。输入名称和可选说明后，单击该`Create`按钮将生成模板并通知用户模板已成功创建，或者如果由于某种原因无法创建模板，则提供相应的错误消息。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td>请务必注意，如果任何Templated处理器具有敏感属性（例如密码），则该敏感属性的值不会包含在模板中。因此，在将模板拖动到画布上时，如果新创建的处理器缺少其敏感属性的值，则它们可能无效。此外，如果连接的源或目标未包含在模板中，则在制作模板时选择的任何连接都不包含在模板中。</td> 
  </tr> 
 </tbody> 
</table>

### 导入模板 ###

在收到从另一个NiFi导出的模板后，使用该模板所需的第一步是将模板导入到此NiFi实例中。您可以将模板导入到具有相应授权的任何Process Group。

在Operate Palette中，单击`Upload Template`（ ![上传模板][dc89ba562f538ec50ee7cc71801804e9.png] ）按钮（有关Operate Palette的更多信息，请参阅[NiFi用户界面][NiFi]）。这将显示“上载模板”对话框。单击查找图标并使用“文件选择”对话框选择要上载的模板文件。选择文件，然后单击“打开”。单击该`Upload`按钮将尝试将模板导入此NiFi实例。如果导入模板时出现问题，“上载模板”对话框将更新为显示“成功”或错误消息。

### 实例化模板 ###

[创建模板][Link 24]（请参阅[创建模板][Link 24]）或导入[模板][Link 24]（请参阅[导入模板][Link 25]）后，就可以将其实例化，或添加到画布中。这是通过将模板图标（![模板][87869024dd9b572bac408cf10037d576.png] ）从组件工具栏（请参阅[NiFi用户界面][NiFi]）拖到画布上来完成的。

这将显示一个对话框，用于选择要添加到画布的模板。选择要添加的模板后，只需单击`Add`按钮即可。模板将添加到画布中，模板的左上角放置在用户放置模板图标的任何位置。

这使得新实例化的模板的内容被选中。如果出现错误，并且不再需要此模板，则可能会将其删除。

### 管理模板 ###

NiFi模板最强大的功能之一是能够轻松地将模板导出到XML文件并导入已导出的模板。这提供了一种非常简单的机制，用于与其他人共享部分DataFlow。您可以从全局菜单中选择模板（请参阅[NiFi用户界面][NiFi]）以打开一个对话框，其中显示当前可用的所有模板，过滤模板以仅查看感兴趣的模板，导出和删除模板。

导出模板

创建模板后，可以在“模板管理”页面中与其他人共享。要导出模板，请在表中找到模板。如果有几个可用的话，右上角的过滤器可用于帮助查找相应的模板。然后单击`Download`按钮（ ![出口][0b57f9e9bf4874d4cb830015ff5f6dbd.png] ）。这会将模板作为XML文件下载到您的计算机。然后可以将此XML文件发送给其他人并导入到其他NiFi实例中（请参阅[导入模板][Link 25]）。

删除模板

一旦确定不再需要模板，就可以从模板管理页面轻松删除它。要删除模板，请在表格中找到它（如果有几个可用，可以使用右上角的过滤器查找相应的模板）并单击`Delete`按钮（ ![删除][3ece91f8a007c00c82daa6a4b78cd742.png] ）。这将提示确认。确认删除后，模板将从此表中删除，不再可用于添加到画布。

## 数据来源 ##

在监视数据流时，用户通常需要一种方法来确定特定数据对象（FlowFile）的发生情况。NiFi的Data Provenance页面提供了该信息。由于NiFi在对象流经系统时记录和索引数据来源详细信息，因此用户可以执行搜索，进行故障排除以及实时评估数据流合规性和优化等内容。默认情况下，NiFi每五分钟更新一次此信息，但这是可配置的。

要访问Data Provenance页面，请从Global Menu中选择“Data Provenance”。这将打开一个对话框窗口，允许用户查看可用的最新数据源文件信息，搜索特定项目的信息，并过滤搜索结果。还可以打开其他对话框窗口以查看事件详细信息，在数据流中的任何位置重放数据，以及查看数据的沿袭或流程路径的图形表示。（这些功能将在下面详细介绍。）

启用授权后，访问Data Provenance信息需要“查询出处”全局策略以及生成事件的组件的“查看出处”组件策略。此外，访问包含FlowFile属性和内容的事件详细信息需要为生成事件的组件“查看数据”组件策略。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 135][]

### Provenance Events ###

以某种方式处理FlowFile的数据流中的每个点都被视为“起源事件”。根据数据流设计，会发生各种类型的起源事件。例如，当数据进入流程时，会发生RECEIVE事件，并且当数据从流程中发出时，会发生SEND事件。可能会发生其他类型的处理事件，例如克隆数据（CLONE事件），路由（ROUTE事件），修改（CONTENT\_MODIFIED或ATTRIBUTES\_MODIFIED事件），拆分（FORK事件），与其他数据对象（JOIN事件）相结合，并最终从流程中删除（DROP事件）。

起源事件类型是：

<table> 
 <thead> 
  <tr> 
   <th style="border-color:#dedede;text-align:left;vertical-align:top;">种源事件</th> 
   <th style="border-color:#dedede;text-align:left;vertical-align:top;">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">ADDINFO</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">当添加其他信息（例如新链接到新URI或UUID）时，表示源项事件</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">ATTRIBUTES_MODIFIED</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示以某种方式修改了FlowFile的属性</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">CLONE</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示FlowFile与其父FlowFile完全相同</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">CONTENT_MODIFIED</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示以某种方式修改了FlowFile的内容</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">CREATE</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示FlowFile是从未从远程系统或外部进程接收的数据生成的</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">DOWNLOAD</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示用户或外部实体下载了FlowFile的内容</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">DROP</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示由于对象到期之外的某些原因导致对象生命结束的起源事件</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">EXPIRE</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示由于未及时处理对象而导致对象生命结束的起源事件</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">FETCH</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">指示使用某些外部资源的内容覆盖FlowFile的内容</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">FORK</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示一个或多个FlowFiles是从父FlowFile派生的</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">JOIN</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示单个FlowFile是通过将多个父FlowFiles连接在一起而派生的</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">RECEIVE</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示从外部进程接收数据的来源事件</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;">REPLAY</td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示重放FlowFile的originance事件</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">ROUTE</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示FlowFile已路由到指定的关系，并提供有关FlowFile路由到此关系的原因的信息</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">SEND</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示将数据发送到外部进程的originance事件</p> </td> 
  </tr> 
  <tr> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">UNKNOWN</p> </td> 
   <td style="border-color:#dedede;text-align:left;vertical-align:top;"> <p style="margin-left:0px;">表示原产地事件的类型未知，因为尝试访问该事件的用户无权知道该类型</p> </td> 
  </tr> 
 </tbody> 
</table>

### 搜索活动 ###

在Data Provenance页面中执行的最常见任务之一是搜索给定的FlowFile以确定它发生了什么。为此，请单击`Search`“数据源”页面右上角的按钮。这将打开一个对话框窗口，其中包含用户可以为搜索定义的参数。参数包括感兴趣的处理事件，区分FlowFile或产生事件的组件的特征，搜索的时间范围以及FlowFile的大小。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 136][]

例如，要确定是否收到特定的FlowFile，请搜索“RECEIVE”的事件类型，并包含FlowFile的标识符，例如其uuid或文件名。星号（\*）可用作任意数量字符的通配符。因此，要确定在2015年1月6日的任何时间是否收到了文件名中任何位置带有“ABC”的FlowFile，可以执行下图所示的搜索：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 137][]

### 活动详情 ###

在Data Provenance页面的最左侧列中`View Details`，每个事件都有一个图标（![细节][f17792a92439081c2f9017ae6f96470f.png]）。单击此按钮将打开一个对话框窗口，其中包含三个选项卡：详细信息，属性和内容。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 138][]

“详细信息”选项卡显示有关事件的各种详细信息，例如事件发生的时间，事件的类型以及生成事件的组件。显示的信息将根据事件类型而有所不同。此选项卡还显示有关已处理的FlowFile的信息。除了显示在“详细信息”选项卡左侧的FlowFile的UUID之外，与“详细信息”选项卡右侧显示的与该FlowFile相关的任何父文件或子项FlowFiles的UUID也显示在该详细信息选项卡的右侧。

“属性”选项卡显示流程中该点上FlowFile中存在的属性。为了仅查看由于处理事件而修改的属性，用户可以选择“属性”选项卡右上角“仅显示已修改”旁边的复选框。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 139][]

### 重播FlowFile ###

DFM可能需要在数据流中的某个点检查FlowFile的内容，以确保按预期处理它。如果没有正确处理，DFM可能需要调整数据流并再次重放FlowFile。“查看详细信息”对话框窗口的“内容”选项卡是DFM可以执行这些操作的位置。“内容”选项卡显示有关FlowFile内容的信息，例如其在内容存储库中的位置及其大小。此外，用户可以在此处单击`Download`按钮以下载流程中此时存在的FlowFile内容的副本。用户还可以单击该`Submit`按钮以在流程中的此时重放FlowFile。点击后`Submit`，FlowFile被发送到为生成此处理事件的组件提供的连接。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 140][]

### 查看FlowFile Lineage ###

查看FlowFile在数据流中采用的谱系或路径的图形表示通常很有用。要查看FlowFile的谱系，请单击![显示血统][14693e60540a642f6950351718361aef.png]Data Provenance表的最右侧列中的“Show Lineage”图标（）。这将打开一个图形，显示FlowFile（![FlowFile][]）和已发生的各种处理事件。所选事件将以红色突出显示。它可以右键单击或任何事件双击看到事件的详细信息（参见[事件的详细信息][Link 26]）。要查看谱系如何随时间演变，请单击窗口左下角的滑块并将其向左移动以查看数据流中较早阶段的谱系状态。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 141][]

Find Parents

有时，用户可能需要跟踪从中生成另一个FlowFile的原始FlowFile。例如，当发生FORK或CLONE事件时，NiFi会跟踪生成其他FlowFiles的父FlowFile，并且可以在Lineage中找到父FlowFile。右键单击沿袭图中的事件，然后从上下文菜单中选择“查找父项”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 142][]

选择“查找父项”后，将重新绘制图形以显示父FlowFile及其谱系以及子项及其谱系。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 143][]

扩展活动

与查找父FlowFile有用的方式相同，用户可能还想确定从给定FlowFile生成的子项。要执行此操作，请右键单击沿袭图中的事件，然后从上下文菜单中选择“展开”。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 144][]

选择“展开”后，将重新绘制图形以显示子项及其谱系。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 145][]

### 提前编写源代码存储库 ###

默认情况下，Provenance Repository以Persistent Provenance配置实现。在Apache NiFi 1.2.0中，引入了Write Ahead配置以提供与Persistent Provenance相同的功能，但性能要好得多。迁移到Write Ahead配置很容易实现。只需`nifi.provenance.repository.implementation`将*nifi.properties*文件中系统属性的设置更改为默认值`org.apache.nifi.provenance.PersistentProvenanceRepository`to，`org.apache.nifi.provenance.WriteAheadProvenanceRepository`然后重新启动NiFi。

但是，为了增加迁移成功的可能性，请考虑以下因素和建议的操作。

向后兼容性

在`WriteAheadProvenanceRepository`可以使用的存储出处的数据`PersistentProvenanceRepository`。但是，`PersistentProvenanceRepository`可能无法读取所写的数据`WriteAheadProvenanceRepository`。因此，一旦将Provenance Repository更改为使用`WriteAheadProvenanceRepository`，它就不能在`PersistentProvenanceRepository`没有先删除Provenance Repository中的数据的情况下更改回。因此，建议在将实施更改为Write Ahead之前，确保您的NiFi版本稳定，以防出现需要回滚到不支持的NiFi的先前版本的问题`WriteAheadProvenanceRepository`。

较旧的现有NiFi版本

如果要从较旧版本的NiFi升级到1.2.0或更高版本，建议您在1.2.0之前确认流量和环境稳定之前，不要将起源配置更改为“预先写入”。这样可以减少升级中的变量数量，并在出现任何问题时简化调试过程。

Bootstrap.conf

虽然使用G1垃圾收集器可以获得更好的性能，但Java 8错误可能会在Write Ahead配置中更频繁地出现。建议在目录中的*bootstrap.conf*文件中注释掉以下行`conf`：

java.arg.13 = -XX：+ UseG1GC

系统属性

Persistent和Write Ahead配置都支持许多相同的系统属性，但是为Persistent Provenance配置选择了默认值。更改为Write Ahead配置时，应注意以下例外和建议：

*  `nifi.provenance.repository.journal.count` is not relevant to a Write Ahead configuration
 *  `nifi.provenance.repository.concurrent.merge.threads` and `nifi.provenance.repository.warm.cache.frequency` are new properties. The default values of `2` for threads and blank for frequency (i.e. disabled) should remain for most installations.
 *  Change the settings for `nifi.provenance.repository.max.storage.time` (default value of `24 hours`) and `nifi.provenance.repository.max.storage.size` (default value of `1 GB`) to values more suitable for your production environment
 *  Change `nifi.provenance.repository.index.shard.size` from the default value of `500 MB` to `4 GB`
 *  Change `nifi.provenance.repository.index.threads` from the default value of `2` to either `4` or `8` as the Write Ahead repository enables this to scale better
 *  If processing a high volume of events, change `nifi.provenance.repository.rollover.time` from a default of `30 secs` to `1 min` and `nifi.provenance.repository.rollover.size` from the default of `100 MB` to `1 GB`

完成这些属性更改后，重新启动NiFi。

*  **注意：**可以在“ [系统属性”中][Link 27]找到每个属性的详细说明 。

加密的源代码注意事项

上述迁移建议`WriteAheadProvenanceRepository`也适用于配置的加密版本`EncryptedWriteAheadProvenanceRepository`。

下一节提供了有关实现Encrypted Provenance Repository的更多信息。

### 加密的Provenance存储库 ###

虽然操作系统级访问控制可以提供对存储库中写入磁盘的起源数据的某些安全性，但有些情况下数据可能是敏感的，合规性和法规要求存在，或者NiFi在不受直接控制的硬件上运行。组织（云等）。在这种情况下，originance存储库允许在将所有数据持久保存到磁盘之前对其进行加密。

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td> <p><em>性能</em></p> <p style="margin-left:0px;">加密源文件库的当前实现拦截了记录编写者和读者<code>WriteAheadProvenanceRepository</code>，它提供了对遗留的显着性能改进<code>PersistentProvenanceRepository</code>并使用该<code>AES/GCM</code>算法，该算法在商品硬件上相当高效。在大多数情况下，增加的成本并不显着（在每秒数百个来源事件的流量上不明显，在每秒数千个 - 数万个事件的流量上适度显着）。但是，管理员应该执行自己的风险评估和性能分析，并决定如何继续前进。目前不建议在加密/未加密的实现之间来回切换。</p> </td> 
  </tr> 
 </tbody> 
</table>

它是什么？

这`EncryptedWriteAheadProvenanceRepository`是originance资源库的一个新实现，它在将所有事件记录信息写入存储库之前对其进行加密。这允许在OS级访问控制不足以保护数据的系统上进行存储，同时仍允许通过NiFi UI / API查询和访问数据。

它是如何工作的？

它`WriteAheadProvenanceRepository`是在NiFi 1.2.0中引入的，并提供了比以前更好的重构和更快的出处库实现`PersistentProvenanceRepository`。加密版本使用记录编写器和读取器包装该实现，该记录编写器和读取器分别加密和解密序列化字节。

完全限定的类`org.apache.nifi.provenance.EncryptedWriteAheadProvenanceRepository`在*nifi.properties中*指定为起源存储库实现，作为值`nifi.provenance.repository.implementation`。此外，必须填充[新属性][Link 28]以允许成功初始化。

StaticKeyProvider

该`StaticKeyProvider`实现直接在*nifi.properties中*定义键。各个键以十六进制编码提供。使用NiFi Toolkit中的工具，密钥也可以像*nifi.properties*中的任何其他敏感属性一样加密[`./encrypt-config.sh`][._encrypt-config.sh]。

以下配置部分将导致密钥提供程序具有两个可用密钥，“Key1”（活动）和“AnotherKey”。

nifi.provenance.repository.encryption.key.provider.implementation=org.apache.nifi.security.kms.StaticKeyProvider
    nifi.provenance.repository.encryption.key.id=Key1
    nifi.provenance.repository.encryption.key=0123456789ABCDEFFEDCBA98765432100123456789ABCDEFFEDCBA9876543210
    nifi.provenance.repository.encryption.key.id.AnotherKey=0101010101010101010101010101010101010101010101010101010101010101

FileBasedKeyProvider

在`FileBasedKeyProvider`执行从格式的加密定义文件上写着：

key1=NGCpDpxBZNN0DBodz0p1SDbTjC2FG5kp1pCmdUKJlxxtcMSo6GC4fMlTyy1mPeKOxzLut3DRX+51j6PCO5SznA==
    key2=GYxPbMMDbnraXs09eGJudAM5jTvVYp05XtImkAg4JY4rIbmHOiVUUI6OeOf7ZW+hH42jtPgNW9pSkkQ9HWY/vQ==
    key3=SFe11xuz7J89Y/IQ7YbJPOL0/YKZRFL/VUxJgEHxxlXpd/8ELA7wwN59K1KTr3BURCcFP5YGmwrSKfr4OE4Vlg==
    key4=kZprfcTSTH69UuOU3jMkZfrtiVR/eqWmmbdku3bQcUJ/+UToecNB5lzOVEMBChyEXppyXXC35Wa6GEXFK6PMKw==
    key5=c6FzfnKm7UR7xqI2NFpZ+fEKBfSU7+1NvRw+XWQ9U39MONWqk5gvoyOCdFR1kUgeg46jrN5dGXk13sRqE0GETQ==

每行定义一个密钥ID，然后定义16字节IV和包装的AES-128，AES-192或AES-256密钥的Base64编码密文，具体取决于可用的JCE策略。各个密钥由使用AES / GCM加密包裹**主密钥**通过限定`nifi.bootstrap.sensitive.key`在*CONF / bootstrap.conf*。

键旋转(Key Rotation)

只需更新*nifi.properties*即可引用新的密钥ID `nifi.provenance.repository.encryption.key.id`。只要该密钥在密钥定义文件中仍然可用，或者`nifi.provenance.repository.encryption.key.id.<OldKeyID>`密钥ID与加密记录一起序列化，以前加密的事件仍然可以被解密。

写作和阅读事件记录

初始化存储库后，所有源项事件记录写入操作将根据配置的模式编写器（`EventIdFirstSchemaRecordWriter`默认情况下`WriteAheadProvenanceRepository`）序列化为a `byte[]`。然后，这些字节被使用的一个实现加密`ProvenanceEventEncryptor`（唯一的当前的实现是`AES/GCM/NoPadding`）和加密的元数据（`keyId`，`algorithm`，`version`，`IV`）被串行化和前缀。`byte[]`然后将complete完成写入磁盘上的存储库。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 146][]

在记录读取时，该过程是相反的。解密加密元数据并用于解密序列化字节，然后将其反序列化为`ProvenanceEventRecord`对象。对正常模式记录写入器/读取器的委托允许“随机访问”（即，立即搜索而不解密不必要的记录）。

在NiFi UI / API中，加密和未加密的起源存储库之间没有可检测到的差异。Provenance Query操作按预期工作，不会对过程进行任何更改。

潜在问题

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:center;width:80px;">&nbsp;</td> 
   <td> <p><em>切换实现 (</em>Switching Implementations<em>)</em></p> <p style="margin-left:0px;">当执行“families”之间（即切换<code>VolatileProvenanceRepository</code>或<code>PersistentProvenanceRepository</code>到<code>EncryptedWriteAheadProvenanceRepository</code>），现有的存储库，必须从文件系统启动之前NiFi清除。终端命令<code>localhost:$NIFI_HOME $ rm -rf provenance_repository/</code>就足够了。</p> </td> 
  </tr> 
 </tbody> 
</table>

*  在未加密和加密的存储库之间切换
    
     *  如果用户具有未加密的现有存储库（`WriteAheadProvenanceRepository`仅 -  **非** `PersistentProvenanceRepository`）并将其配置切换为使用加密存储库，则应用程序会将错误写入日志但会启动。但是，以前的事件无法通过起源查询界面访问，新事件将覆盖现有事件。如果用户从加密存储库切换到未加密的存储库，则会发生相同的行为。自动翻转是未来的努力（[NIFI-3722][]），但NiFi不适用于物源事件的长期存储，因此影响应该是最小的。翻转有两种情况：
        
         *  加密→未加密 - 如果以前的存储库实现已加密，只要可用的密钥提供程序仍具有用于加密事件的密钥，就应无缝处理这些事件（请参阅**密钥轮换**）
         *  未加密→加密 - 如果以前的存储库实现未加密，则应无缝处理这些事件，因为先前记录的事件只需要使用明文架构记录读取器读取，然后使用加密记录写入器写回
     *  今后还有一项工作是在NiFi Toolkit中提供一个独立的工具来加密/解密现有的出处存储库，以便更容易地进行过渡。转换过程可能需要很长时间，具体取决于现有存储库的大小，并且能够在应用程序启动之外执行此任务将是有价值的（[NIFI-3723][]）。
 *  多个存储库 - 此时不再对多个存储库应用额外的工作或测试。可能/可能在不同物理设备上的存储库中会出现问题。没有选择提供异构环境（即一个加密的，一个明文存储库）。
 *  损坏 - 当磁盘被填满或损坏时，已报告存储库损坏并且需要恢复步骤的问题。这可能会继续成为加密存储库的问题，但仍然限制在单个记录的范围内（即整个存储库文件由于加密而不会无法恢复）。

## 其他管理功能 ##

除摘要页面，数据源页面，模板管理页面和公告板页面外，全局菜单中还有其他工具（请参阅[NiFi用户界面][NiFi]），这些工具对DFM很有用。选择“流配置历史记录”以查看对数据流所做的所有更改。历史记录可以帮助进行故障排除，例如，如果最近对数据流的更改导致了问题并且需要修复。DFM可以查看已进行的更改并根据需要调整流量以解决问题。虽然NiFi没有“撤消”功能，但DFM可以对数据流进行新的更改以解决问题。

全局菜单中的另外两个工具是控制器设置和用户。“控制器设置”页面提供了更改NiFi实例名称，添加描述NiFi实例的注释以及设置应用程序可用的最大线程数的功能。它还提供了DFM可以添加和配置[Controller Services][]和[Reporting Tasks的][Reporting Tasks]选项卡。“用户”页面用于管理用户访问，“ [系统管理员指南”中][Link 1]对此进行了描述。

原文:  [http://nifi.apache.org/docs.html][http_nifi.apache.org_docs.html]

[Link 1]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html
[Link 2]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#core-properties-br
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70]: /images/20220302/ff53ca7087ca4eec8c809681bfe3bdff.png
[DataFlow]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#building-dataflow
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 1]: /images/20220302/3c145692d39447d9bf272951811b51ef.png
[205aaf7cc64d1f0034dbd8aba04b6fd1.png]: /images/20220302/1b000b1fd8f44ac68b8ffb86baddb601.png
[20190319135217968.png]: /images/20220302/1593dbe6b8984c1fbe45e0b836e1b8c4.png
[2019031913523742.png]: /images/20220302/b8566929cb7c4b81863efd8984c7aefa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 2]: /images/20220302/42d56e0181d041ab9fa7625c9ed90dd5.png
[bbc311f3af857b30c96ebf6d13262cc0.png]: https://img-service.csdnimg.cn/img_convert/bbc311f3af857b30c96ebf6d13262cc0.png
[Link 3]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Restricted_Components_in_Versioned_Flows
[Link 4]: /images/20220302/360db14537ed44c0886371b68d0b7b42.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 3]: /images/20220302/2a749f45feee4968b11b7475da6b27bc.png
[Link 5]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Configuring_a_Processor
[Link 6]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#data_provenance
[e498d187f54c56dcbbc162dbdfbec5bf.png]: /images/20220302/8be5568de63f4998b656719fa7aceff7.png
[Site-to-Site]: /images/20220302/f1e920a9d73f4e668327cb4d70e607fd.png
[958df746ae1e91ba723308f363b7c9cd.png]: /images/20220302/5626a1ecd55b4a368a467b83b8487eb8.png
[7ff757372e856635053415ddf6dcb4a1.png]: /images/20220302/ff7ee5bf00674f27b1527bbf3cb44556.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 4]: /images/20220302/bb7a27e6153b4ca5bf0e8163ff517a68.png
[646a9ba71d2cd3ae2f07f3469c8b4394.png]: https://img-service.csdnimg.cn/img_convert/646a9ba71d2cd3ae2f07f3469c8b4394.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 5]: /images/20220302/3d8c476205e04173be08eb5e1fe8a378.png
[Link 7]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Remote_Group_Transmission
[c55d4cf8640f81947a4a2f5b176eebff.png]: /images/20220302/7140388a885d4119b823fd6e8869b7a2.png
[87869024dd9b572bac408cf10037d576.png]: /images/20220302/ead03dd1a53441449f449c588f9b176f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 6]: /images/20220302/61bfa13aceb74af79a37dcef32a649b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 7]: /images/20220302/67bd5093c8c14c27afe72a9b77175232.png
[80fcd8683eb661dac506c7a3e2d15594.png]: /images/20220302/7667820293df46c0bc1b1bf0e117a148.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 8]: /images/20220302/d0c794ef40ef4f319f9f3c486b6ecfee.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 9]: /images/20220302/b980803e07494eaaa0fddb26aa7be7e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 10]: /images/20220302/494e73b393bb4f26b73bb97cc3242876.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 11]: /images/20220302/3b787dd8ae504a2686e40ca42ff75264.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 12]: /images/20220302/4039815e6d48423491f7652392e2005f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 13]: /images/20220302/f8192aa981ab4935a2e3a660178fa07c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 14]: /images/20220302/fa650f00a2bc47acbe831687e01a65e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 15]: /images/20220302/1565444a88ec401987b33aac51e78c5f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 16]: /images/20220302/e3198340345b4d1894635bddd7c082be.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 17]: /images/20220302/1fac9d96076c48e48597fc8074b12a70.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 18]: /images/20220302/a8f706e722b34b84bb458b5ccf5eed6e.png
[Chron Trigger]: http://www.quartz-scheduler.org/documentation/quartz-2.x/tutorials/crontrigger.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 19]: /images/20220302/0c89d478d5bc4c99a0bf60eb8e7cc448.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 20]: /images/20220302/233de79315b34e229939a7deb939988d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 21]: /images/20220302/d58d7e4d20624ce28c17f9acf4501b44.png
[4d6d4e00cf23a833cee72db296194a39.png]: /images/20220302/88f93903bb554a3687e91fde9f6a9c9c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 22]: /images/20220302/2908c284511340d5b53a29add4162f5c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 23]: /images/20220302/5cb5be3f2e3740d8962f5b9c87cefde3.png
[3ece91f8a007c00c82daa6a4b78cd742.png]: /images/20220302/5db37a8c82f742379bb9f6664b2afe53.png
[Controller Services]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Controller_Services
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 24]: /images/20220302/b4d3a6768b0a4a5f96c6ffdae6c14f94.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 25]: /images/20220302/46fda413147345cca99612fe0319c288.png
[Link 8]: http://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 26]: /images/20220302/c081c89fc4254f038b94d781fa5c1dd2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 27]: /images/20220302/fdce77b6a89b4d428f19cd9c74315a3a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 28]: /images/20220302/85129920286c4eb79a9fd2b68952b0c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 29]: /images/20220302/f51fceb1d2044ef491f44073bb3a38e0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 30]: /images/20220302/511c134ae86b4b118c7f7440c4d7a39c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 31]: /images/20220302/c1485da067684b9eb31c3bf2e91ac513.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 32]: /images/20220302/60a417e087bd4cdeb65f8ead2e75940b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 33]: /images/20220302/fdfadb4bcd1842ce9e0f44690dcbf305.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 34]: /images/20220302/e170df24bc1343fda120d1939d9c3cdc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 35]: /images/20220302/84014d31015b4636b5831c9ea85eaa66.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 36]: /images/20220302/593b99d164a84641aa094ad904a7e8ee.png
[Link 9]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#access-policies
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 37]: /images/20220302/08c9f1003885420ca3254ed360262865.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 38]: /images/20220302/f6cd69aeee684323a564dec1ffee5afd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 39]: /images/20220302/cbdf4fb41ca54321b96599fa02143773.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 40]: /images/20220302/c1178edc65b4447cb6d1f606d5e8cd76.png
[Link 10]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#custom_properties
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 41]: /images/20220302/b4ff07e27de540a29bd1d3ddd83b8f73.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 42]: /images/20220302/8c9910057e684bcca806920a2fb274e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 43]: /images/20220302/e83e5a6f064b403f877635a2c15ecfce.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 44]: /images/20220302/7635dfb59cc246c49e40c4e78483d18e.png
[20190319175701638.png]: /images/20220302/5161cbde7dae4e98bab11a6799a73595.png
[20190319175830152.png]: /images/20220302/042e4e489ddf49eaa61e2a5a80fd8a32.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 45]: /images/20220302/373efb97d9cd4b08a3d79fffd5c94934.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 46]: /images/20220302/20a5de97b59d4be9b7715c40e613f0db.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 47]: /images/20220302/8b4103f29cad43948d23fe4e978841e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 48]: /images/20220302/3c8bcd9152c444529bcec61ad5b3c564.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 49]: /images/20220302/4094437bc7ce46b5a00b5ecd82b8372a.png
[88cfe8c8eef4812379a3ca3c6e676e2a.png]: /images/20220302/efbaa210b16645399c18a2fbe89395f7.png
[4243cd3cdb9af52b17fb8a7e3bce77fb.png]: https://img-service.csdnimg.cn/img_convert/4243cd3cdb9af52b17fb8a7e3bce77fb.png
[877c9f4dd42805ad926528690381ac9a.png]: /images/20220302/75d8053cf2bc41fe8944607f65f0c348.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 50]: /images/20220302/9360983243324e1baf7a7a0d7ac7e44f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 51]: /images/20220302/0041c54af1e54cf7bfe01f050aea85a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 52]: /images/20220302/3d1f83626ff04be4889d972073eb4c0b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 53]: /images/20220302/70b62b7a0d584bf795cd4af7a111c721.png
[20190319180257107.png]: /images/20220302/eb46ad2b33c846f3b0531d47462209fd.png
[2019031918025161.png]: /images/20220302/bc69f9b533a64d4288fe2f87d6de4a6d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 54]: /images/20220302/5265e3cb302e43798dde7aa4061c3f76.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 55]: /images/20220302/d588a736c48a4d2ab71da921009f366b.png
[569ae3773a0dbef2549ed881c5b4a203.png]: /images/20220302/08a93b25e87e45c8a2da120e21e2ddbe.png
[48c6a631161bededaed98e5264a85086.png]: /images/20220302/3ff4d11974554b3baad146c4c769d485.png
[20190319180407309.png]: /images/20220302/3a89153e7bac45ab93ce8f54e92b471a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 56]: /images/20220302/e689999089f74aa69b36a1f8b7118a7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 57]: /images/20220302/0562c623c36a4e91860d6ccce960af20.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 58]: /images/20220302/cd3ee43ae0014db7ad46add9a815dc42.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 59]: /images/20220302/2f8f133554e7415a9107e29745baeec4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 60]: /images/20220302/229c11b41d804ca2b958959df5a1eec5.png
[20190319180825236.png]: /images/20220302/f83f88f9d1204224bacd7373096ad951.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 61]: /images/20220302/81596b38ba354bd7b5774eb19379558b.png
[392e205cd217b7d07e1ec7cd62e23733.png]: /images/20220302/ecba878a73004936b3d301940b2be257.png
[20190319181231617.png]: /images/20220302/ce6214e8601b45d5b6e7109032610bfe.png
[20190319181239584.png]: /images/20220302/4461ef60b6a64de8ba697349b8b89575.png
[20190319181249889.png]: /images/20220302/dd4692491bf74108802ddb84ee571df7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 62]: /images/20220302/9dbb430f158c44bfa19e7fe4f2973db6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 63]: /images/20220302/8fbb134b61f542588e6e32dda32db589.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 64]: /images/20220302/c5e6cdf8d9854fdb9072f1eb0d5e9494.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 65]: /images/20220302/050603c9e9fa4a3bb45a1223e4cd8fba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 66]: /images/20220302/94437f0b19994f7f99c759fc4bc4bb95.png
[20190319182024945.png]: /images/20220302/4ae4bf690400415481099dd6383a10e0.png
[20190319182032354.png]: /images/20220302/eddba5fe7a3a45f0a766d38ecddc4c4b.png
[Link 11]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#security-configuration
[Link 12]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#remote_process_group
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 67]: /images/20220302/558000f9f02841bcbcbc7d7d1507ca9d.png
[Link 13]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#input_port
[Link 14]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#output_port
[Link 15]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#site_to_site_properties
[Link 16]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#processor_anatomy
[20190320100133818.png]: /images/20220302/39aa288534ae4e9d8d1f58bb78bcfb61.png
[Link 17]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#monitoring
[Link 18]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#process_group_anatomy
[Link 19]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#remote_group_anatomy
[c7617e53be601d025d765f6cc1cbf4ef.png]: /images/20220302/1d7ec1d86b904a0b84591069243fd8a1.png
[759853b6d148f8c3c6f44aa876134b94.png]: /images/20220302/e50494a6e812496782cb1c15f5e2c293.png
[3227d441bb87fb7788efc2f2210e7db1.png]: /images/20220302/b518553ff3964708ae8596a17ed4b0f6.png
[873ad4c216c3cd398d7686382b746ae3.png]: /images/20220302/5a50edfbd7724ef59182570495082e00.png
[ed5cfd0e71dcb13dff73bf28e2b4da91.png]: /images/20220302/2ca398fdffe64340bdb29bfca1ba3a24.png
[dde38ad3a9b181630fbc494a1a0bd11a.png]: /images/20220302/5a0631381e44417a9556eb218b062ca4.png
[95fa205675e8f3d1c19cd08cd565a8e0.png]: /images/20220302/e43b2b0f1935433fb3e9c5962888789c.png
[30ea0fe2c1208e12c8df0a30f99bdb84.png]: /images/20220302/7d3b37c6859c4b65b0e3a27744fcf169.png
[5f11f91dbbae6f7e76f1e126b54b3552.png]: /images/20220302/8d014bfaf3f94eeabe0a57dcffe2cf3f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 68]: /images/20220302/708b87cfda3f421587a8b04c1b17ac98.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 69]: /images/20220302/ba7d7590fa3341718c11954c76895ded.png
[66b415776252bbcedaf1ddd7355e107b.png]: /images/20220302/ad0007c70b234f259bc3adc0dab757ef.png
[NiFi]: /images/20220302/e77499ff2b29410ca8a21e8b9fe3f6aa.png
[Link 20]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#multi-tenant-authorization
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 70]: /images/20220302/29e499d9daa04e32acf85f78067cfb69.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 71]: /images/20220302/610836fff23242ce82c218b12e7eda8b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 72]: /images/20220302/5580881611df48ffa61b5ab4f8e0be80.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 73]: /images/20220302/72f3aef76b3648d8976877f9956bdc08.png
[20190320100727280.png]: /images/20220302/317226162ea646d599d69948c060d15a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 74]: /images/20220302/4123be7131ce407db07c036dbdfbc4d5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 75]: /images/20220302/ec2b0796be314465b70e11effe1f7ab7.png
[Link 21]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#version_states
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 76]: /images/20220302/908d196b242a4c48bc9da4170a64542e.png
[2887109c77395c8da193b29143b8913b.png]: https://img-service.csdnimg.cn/img_convert/2887109c77395c8da193b29143b8913b.png
[72a36a311e91e905e90ca57f4622c662.png]: /images/20220302/ec55fae8d8df44c7ab98544d28bead75.png
[f17792a92439081c2f9017ae6f96470f.png]: /images/20220302/95b8f13047424448b933406595e97037.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 77]: /images/20220302/396b92abe8da40bfbc5f6ca7e321da60.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 78]: /images/20220302/74b242c21b114abfbddee9d2a5c64af5.png
[Link 22]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Status_History
[Link 23]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Summary_Page
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 79]: /images/20220302/03f4e50b1d534d6ab905a82d7d87f19a.png
[252614a6537a62d5aba8060a5246109e.png]: /images/20220302/57299a807ab743b897cb85512f960b2b.png
[https_nifi.apache.org_docs_nifi-registry-docs_index.html]: https://nifi.apache.org/docs/nifi-registry-docs/index.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 80]: /images/20220302/5550c567e96846a0903bb3154dc5a0e0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 81]: /images/20220302/692772229b1f4d6394f0bd5332698e23.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 82]: /images/20220302/441f5af2596244028cc4b603159702ca.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 83]: /images/20220302/c858d767929942fb8e9a10c1e1cfd4ee.png
[9eff48cc903c8c179d2b7174870e6abc.png]: /images/20220302/8a72f20f73ef4c19a92128e8d6afdb33.png
[b32cc76e982adc69df68753c28d84c27.png]: /images/20220302/0c45a21995764aef978715e98bb4e217.png
[22b106335d608c35d5304cd48e3e8abd.png]: /images/20220302/920bac9509f942bd8b0daa69ff49e9d6.png
[3291026bc47e7a77fa60c88a78a1a43b.png]: /images/20220302/4f71f1a1a50644fcaf917893309ececb.png
[90df5c9bd3a89761ed0d29cb08b54bf4.png]: /images/20220302/ec4d1663aec54282bd626c44cdaa4474.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 84]: /images/20220302/7d2c71df39b5410f9a097960f34d7aa7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 85]: /images/20220302/5d919501e2354e91b30f50a28c9f0048.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 86]: /images/20220302/213df9bd9f9f4aa6815b10faab6c42f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 87]: /images/20220302/004571bcf16b4bfeae9a4ce8feed3cc9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 88]: /images/20220302/d08c2c05a25548aca74e9c666c27f4b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 89]: /images/20220302/5dddbc07faac497aac4a3d5f8e14cdda.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 90]: /images/20220302/038b07de855c44d6ba660960a5da57cd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 91]: /images/20220302/1e43641311ba430d84eda13bda577ff7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 92]: /images/20220302/3aa2a13cc6c34db9a8446660353ea437.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 93]: /images/20220302/f4bb9ca7a12048fda5427fd579bcc3b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 94]: /images/20220302/149a5695260740998425931131ac3dca.png
[c8c63556d56bc17f62c471b19e51a9b7.png]: /images/20220302/514213f950ad4103a58fcc35ac3818df.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 95]: /images/20220302/43e90941cb9e4c0a999e51c2c098ed85.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 96]: /images/20220302/a1c716edde2943cd8312fd5663aa954f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 97]: /images/20220302/fa74b9d8e1a044388265b23a63154bff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 98]: /images/20220302/4784b9e2f0db478c8e6a4af0b10b6e6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 99]: /images/20220302/ce6f835436b3489b86e6e89cc77f6c58.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 100]: /images/20220302/5002ed69c38d496f87b1054fe4774a10.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 101]: /images/20220302/cb3def187d544456b614e0c305c73385.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 102]: /images/20220302/170d896920c64bd994835105a6d640d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 103]: /images/20220302/976915f13b994ccf9b2b4b7881dde266.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 104]: /images/20220302/c34fde122b5744e0968167e465215b93.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 105]: /images/20220302/3c2dd95e44ce4ba189aab22ae9536e4c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 106]: /images/20220302/da57909f08ff466f8f7c8b391d070873.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 107]: /images/20220302/bfef36049a4f45f2bb75ec7a03939c88.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 108]: /images/20220302/417a262a411448038507d2074bb8b145.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 109]: /images/20220302/e80b9f98ccb94b6db6ab69e7b2d14190.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 110]: /images/20220302/28adcffe83a1445fabbce23c09f8acbb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 111]: /images/20220302/6428842c257a43f2a224661aed98d080.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 112]: /images/20220302/b25584d2bf5a44abb62e258f1f08002d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 113]: /images/20220302/0cf9501fe92b4410a831e36ee10dfb9f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 114]: /images/20220302/da9a640548a4424db8d1cd8c86839ae2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 115]: /images/20220302/22384875ae97447292cb546a71712c6d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 116]: /images/20220302/64f5b3b85858450fbbf1a706268d6065.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 117]: /images/20220302/b7d049772d8a4a858480f29aa50d2113.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 118]: /images/20220302/16c3586e62c44d418a679fff4c158f6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 119]: /images/20220302/f04281670307437093375fde6c637429.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 120]: /images/20220302/30634210ff6f4cb894d95216085d5c7d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 121]: /images/20220302/70d23979b7fe45c3b46a9a4052e4535a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 122]: /images/20220302/bb9f433b68a74f36a49c700bdf0e0d86.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 123]: /images/20220302/735513d091d8487786f523d2b85ac7a7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 124]: /images/20220302/ca134f9bda5f4ed2926a9a983d48f1da.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 125]: /images/20220302/b55f6328622341f0868773e3d5dfe76d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 126]: /images/20220302/3ce3f37bd3064e1388f4457a6a4b1802.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 127]: /images/20220302/206bd9731a87401aadbb1252ce4727c2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 128]: /images/20220302/d8b708b4cdc24938b96dbdfef0446b41.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 129]: /images/20220302/d9eac391db1241c5b7106a89da88fe9e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 130]: /images/20220302/d5e796aed9dc44a893bd6ea4db49a611.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 131]: /images/20220302/401808d0f8b24d69b59dc87307bf1e3c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 132]: /images/20220302/24a7d13620014414a2ceef2aae4b08d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 133]: /images/20220302/45aa07d65eb14e5f96acd0308b6ae543.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 134]: /images/20220302/6938d6f3e5f54b86a073d041259277b2.png
[96cce223a473f4e58ddca05b2409ce09.png]: https://img-service.csdnimg.cn/img_convert/96cce223a473f4e58ddca05b2409ce09.png
[dc89ba562f538ec50ee7cc71801804e9.png]: https://img-service.csdnimg.cn/img_convert/dc89ba562f538ec50ee7cc71801804e9.png
[Link 24]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Create_Template
[Link 25]: /images/20220302/02176deb70b74fb08b641e47c470bce2.png
[0b57f9e9bf4874d4cb830015ff5f6dbd.png]: https://img-service.csdnimg.cn/img_convert/0b57f9e9bf4874d4cb830015ff5f6dbd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 135]: /images/20220302/9fb31be85a934cebbf35c81af81d1fe6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 136]: /images/20220302/3f5dd71da0574ab4ab19cff671557e9c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 137]: /images/20220302/345acf22913a42d9bd230b40227f183a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 138]: /images/20220302/78cecaadd3e347d3bcf0e83439ec5351.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 139]: /images/20220302/f9b41d4395dd4f5baf30d366550280fa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 140]: /images/20220302/13d496985f684416827336342fb6b17b.png
[14693e60540a642f6950351718361aef.png]: https://img-service.csdnimg.cn/img_convert/14693e60540a642f6950351718361aef.png
[FlowFile]: /images/20220302/d14e047e66f74c738a137bb93240bc61.png
[Link 26]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#event_details
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 141]: /images/20220302/c693aa0f4ff643a7b5bf95c7faee24a4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 142]: /images/20220302/c4db00aa1d664812bfa390ba5e7107a5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 143]: /images/20220302/fb22aea841004fa1ba976dd9ad1f1459.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 144]: /images/20220302/2d260d6e87e5450eafd00be6a066dd36.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 145]: /images/20220302/4b9a96c9642d467a85cd8b3e26da8a8e.png
[Link 27]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#system_properties
[Link 28]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#encrypted-write-ahead-provenance-repository-properties
[._encrypt-config.sh]: http://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#encrypt-config_tool
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly96aGFuZ2JveWkuYmxvZy5jc2RuLm5ldA_size_16_color_FFFFFF_t_70 146]: /images/20220302/16a4d0c5ff5b4ded99b5e062af464eed.png
[NIFI-3722]: https://issues.apache.org/jira/browse/NIFI-3722
[NIFI-3723]: https://issues.apache.org/jira/browse/NIFI-3723
[Reporting Tasks]: http://nifi.apache.org/docs/nifi-docs/html/user-guide.html#Reporting_Tasks
[http_nifi.apache.org_docs.html]: http://nifi.apache.org/docs.html