代码之家 › 专栏 › 技术社区 › TMichel

NiFi SplitJSON和ExecuteSQL

apache-nifi

TMichel · 技术社区 · 9 年前

在NiFi流中,我希望读取JSON结构,将其拆分,使用负载执行SQL查询,最后将每个结果输出到JSON文件中。

ExecuteSQL 加工机

GenerateFlowFile 处理器,JSON结构如 Custom Text

SplitJSON

,使用 SplitJSON's ${id}

此时,我得到了一个SQL语法错误的日志错误。显然 ExecuteQuery 处理器未分析其上的表达式 SQL select query

1 回复 | 直到 9 年前

Andy 9 年前

EvaluateJsonPath (或 ExtractText )处理器介于 SplitJson 和 ExecuteSQL --表达式语言表达式无法计算流文件内容以进行参数替换,因此您的SQL表达式最终为 SELECT * FROM foo WHERE id = ; 这就是为什么你有语法错误。

EvaluateJsonPath 处理器正是这样做的。只需添加一个自定义属性(单击 + 在“属性”对话框的右上角),并提取 id matched 从该处理器到 执行SQL

推荐文章

venkata · 在Nifi中,FirstInfirstOutpriorizer和OldestFlowFileFirstPriorizer之间的区别是什么

8 年前

Sateesh Telaprolu · nifi是否支持将单个流文件传输到处理器中的多个关系?

8 年前

Arnab Biswas · Apache Nifi慢速群集问题

8 年前

Prabhu Bentick · Apache nifi和pentaho端口问题

8 年前

Atanu chatterjee · Nifi Spark集成,不使用Kafka和Pyspark

8 年前

Samuel Miller · 群集上的Nifi 1.5不受信任代理

8 年前

data_addict · 针对多个流文件的单一通知邮件Nifi

8 年前

MiamiBeach · 是否可以在WildFly上部署Apache Nifi?

8 年前

Gaurang Shah · NIFI查询数据库组织。阿帕奇。阿夫罗。SchemaParseException:COUNT(*)中的非法字符;

8 年前

watery · 如何通过MongoDB查询结果有条件地处理流文件?

8 年前