covertJSONtoSQL 在 NiFi 中返回空值
covertJSONtoSQL returning empty values in NiFi
我正在设计一项工作，使用 ExecuteSQL 处理器将数据从 MySQl 中的数据库获取到另一个数据库 (MySQL)，然后是 ConvertAvroToJson 然后 ConvertJsonToSQL 然后 PutSQL 如下图所示
ConvertJSONToSQL 返回如下空值
INSERT INTO source_count (field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
处理器配置为
此工作流程可能有什么问题？
除了评论中给出的答案（使用sql与ConvertJSONToSQL的关系），那么如果你至少有NiFi 1.2.0，你可以在Execute[=之后替换所有内容14=] 与 PutDatabaseRecord. It lets you configure a reader (you would choose an AvroReader 使用嵌入式模式）并将操作类型设置为 INSERT，它将为您处理 SQL 生成和执行。
我正在设计一项工作，使用 ExecuteSQL 处理器将数据从 MySQl 中的数据库获取到另一个数据库 (MySQL)，然后是 ConvertAvroToJson 然后 ConvertJsonToSQL 然后 PutSQL 如下图所示
ConvertJSONToSQL 返回如下空值
INSERT INTO source_count (field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
处理器配置为
此工作流程可能有什么问题？
除了评论中给出的答案（使用sql与ConvertJSONToSQL的关系），那么如果你至少有NiFi 1.2.0，你可以在Execute[=之后替换所有内容14=] 与 PutDatabaseRecord. It lets you configure a reader (you would choose an AvroReader 使用嵌入式模式）并将操作类型设置为 INSERT，它将为您处理 SQL 生成和执行。