CovertJSONtoSQL 在 NiFi 中返回空值答案

【问题标题】：covertJSONtoSQL returning empty values in NiFiCovertJSONtoSQL 在 NiFi 中返回空值
【发布时间】：2018-05-21 11:29:51
【问题描述】：

我正在设计一项工作，它使用 ExecuteSQL 处理器将数据从 MySQl 中的数据库获取到另一个数据库（MySQL），然后使用 ConvertAvroToJson 然后 ConvertJsonToSQL 然后 PutSQL 如下流程图所示

ConvertJSONToSQL 返回如下所示的空值

 INSERT INTO source_count (field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)

处理器配置是

这个工作流程有什么问题？

【问题讨论】：

一般convertJsonTosql只会这样返回。你应该在putSQL处理器中配置sql关系，但是你把failure,original,sql给putSQL处理器。修改关系并检查数据到哪个关系？它可以解决您的问题
成功了！！我重定向失败，原始关系到 convertJsontoSQL 本身和 SQL 到 putSQL

标签： mysql apache-nifi processor

【解决方案1】：

除了cmets中给出的答案（使用与ConvertJSONToSQL的sql关系），那么如果你至少有NiFi 1.2.0，你可以用PutDatabaseRecord替换ExecuteSQL之后的所有内容。它允许您配置阅读器（您可以选择使用嵌入式模式的AvroReader）并将操作类型设置为 INSERT，它会为您处理 SQL 的生成和执行。

【讨论】：