我正在设计一项工作,将数据从ConvertAvroToJson中的on数据库接收到另一个数据库( MySQl ),使用ExecuteSQL处理器,然后是ConvertJsonToSQL,然后是PutSQL,如下图所示

返回空值的ConvertJSONToSQL,如下所示
INSERT INTO source_count (field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)处理器配置是

在这个工作流中会有什么问题?
发布于 2017-12-07 18:00:26
除了注释中给出的答案(在ConvertJSONToSQL中使用sql )之外,如果您至少有NiFi 1.2.0,那么您可以用PutDatabaseRecord替换ExecuteSQL之后的所有内容。它允许您配置读取器(您可以选择使用嵌入式模式的AvroReader )并将操作类型设置为INSERT,它将为您处理SQL生成和执行。
https://stackoverflow.com/questions/47693683
复制相似问题