Apache NiFi：将流文件属性添加到 ExecuteStreamCommand 处理器

【问题标题】：Apache NiFi: Adding flow file attribute to ExecuteStreamCommand processorApache NiFi：将流文件属性添加到 ExecuteStreamCommand 处理器
【发布时间】：2019-09-24 21:35:33
【问题描述】：

我正在尝试在 ExecuteStreamComamnd 处理器上添加一个属性，该属性应该可以作为下游处理器的流文件属性使用。 属性名称为“dc”，值为“abc”。当我使用 ${dc} 在下一个下游处理器中评估此属性的值时，我得到一个空值。

在这种情况下添加新流文件属性的正确方法是什么。

谢谢

【问题讨论】：

  • 你可以在 ExecuteStreamCommand 之后添加 UpdateAttribute Processor

标签： apache-nifi


【解决方案1】：

ExecuteStreamCommand 处理器中的动态属性允许您定义传递给由该处理器生成的进程的环境变量。

该值在下游处理器中不可用。

但是您可以使用 UpdateAttribute 处理器来设置流文件的属性。

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.6.0/org.apache.nifi.processors.standard.ExecuteStreamCommand/

【讨论】：

  • 所以我应该在 ExecuteStreamCommand 处理器之后连接一个带有新属性的 UpdateAttribute 处理器，然后将该 UpdateAttribute 处理器连接到任何下游处理器。对吗？
  • 没错。或者将它放在 ExecuteStreamCommand 处理器之前。
  • 顺便说一句，你为什么从 nifi 开始 java？考虑使用 executegroovyscript 处理器。
  • 谢谢 daggett，代码已经用 Scala 编写，所以我正在使用它。
猜你喜欢
  • 2019-06-13
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2021-07-09
相关资源
最近更新 更多
热门标签
Java Python linux javascript Mysql C# Docker 算法 前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库 数据结构 大数据 js 机器学习 微服务 Android Go 程序员 面试 JVM ASP.net core 云原生 人工智能 后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习 多线程 React 架构 devops 爬虫 云计算 Spring Boot LeetCode