NiFi如何在UpdateAttribute处理器中获得更新的JSON值? | 您所在的位置:网站首页 › putfile翻译 › NiFi如何在UpdateAttribute处理器中获得更新的JSON值? |
在现有流中,您正在更改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 实验室设备网 版权所有 |