NiFi如何在UpdateAttribute处理器中获得更新的JSON值? 您所在的位置:网站首页 putfile翻译 NiFi如何在UpdateAttribute处理器中获得更新的JSON值?

NiFi如何在UpdateAttribute处理器中获得更新的JSON值?

2024-06-13 22:32| 来源: 网络整理| 查看: 265

在现有流中,您正在更改attribute associated to the flowfile的值,而不是流文件的实际内容。

在UpdateAttribute处理器使用AttributesToJson处理器并重新创建您的输出JSON内容之后。

流:

代码语言:javascript复制1. ConsumeKafkaData 2. EvaluateJsonFlow //Extract all json data attributes as flowfile attributes 3. UpdateAttribute 4. AttributeToJSON //AttributesList -> name,active; Destination -> flowfile Content 5. Putfile

有关AttributesToJSON处理器的详细信息/使用情况,请参阅这链接。

此外,对于这种情况,您可以使用面向记录的处理器,即UpdateRecord/QueryRecord处理器,然后使用LiteralValue策略,并对name属性值使用Expression language if-else。

如果您使用的是QueryRecord processor,那么在sql查询中编写一个case语句。

有关更多详细信息/使用这处理器,请参阅updateRecord链接。

有关QueryRecord处理器的详细信息/使用情况,请参阅QueryRecord链接。



【本文地址】

公司简介

联系我们

今日新闻

    推荐新闻

    专题文章
      CopyRight 2018-2019 实验室设备网 版权所有