我们如何使用 UpdateAttribute 处理器在 Apache Nifi 中分配 FlowFile 内容的变量

【问题标题】：How can we use UpdateAttribute processor for assigning variable of FlowFile content in Apache Nifi我们如何使用 UpdateAttribute 处理器在 Apache Nifi 中分配 FlowFile 内容的变量
【发布时间】：2022-08-18 17:40:12
【问题描述】：

我在 UpdateAttribute 处理器中需要一些帮助：我有一个包含主机名的 CSV 文件。我需要分隔 FlowFile 中的每个主机名并将其作为变量传递给 REST API。
手动传递数据时，我的 REST API 部分工作正常。但是，我不知道如何在其中将变量值作为主机名传递。

共享示例文件：

SRHAPP001,SRHWEBAPP002,SRHDB006,SRHUATAPP4,ARHUATDB98

检查这个：stackoverflow.com/questions/71140748/…

标签： apache-nifi update-attributes

【解决方案1】：

我不太了解您的目标，但我假设您尝试使用 FlowFile 变量将主机名传递给您的 REST API 模块。

您可以通过使用ExtractText-Processor 来实现这一点。您只需使用 RegEx 将您的主机名与 CSV 文件分开。

有关详细信息，请参阅 https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.12.1/org.apache.nifi.processors.standard.ExtractText/

How can I extract a substring from a flowfile data in Nifi?

如果需要，您可以使用 SplitContent-Processor 在每个主机名上拆分传入的流文件

【讨论】：

是的，SplitContent 有效，为了将主机名作为变量传递，我又添加了一个处理器 ExtractText，并将属性添加到其中。