Apache NiFi如何检查每个处理器的输出



我是Apache NiFi的新手,我试图创建一个模板,该模板接受JSON文件并将其转换为一组SQL插入语句。

到目前为止,我已经创建了一个使用JSON文件的模板,并将其应用于PutSQL。目前没有可连接的数据库,但我无法检查的是输出。这能做到吗?我需要检查的是JSON数组是否已转换为数组中每个元素的INSERT

就检查输出而言,您的流是什么样子的?如果您有类似ConvertJSONToSQL的东西->PutSQL,您可以停止PutSQL并运行ConvertJSONToSQL,然后您将在两个处理器之间的连接中看到FlowFile。然后,您可以右键单击连接并选择"列出队列",然后单击;眼睛;要检查的FlowFile右侧的图标。这将在FlowFile进入PutSQL之前向您显示它的内容。

话虽如此,如果您的JSON文件包含与数据库中的列相对应的字段,请考虑PutDatabaseRecord而不是ConvertJSONToSQL->PutSQL。它可以使用JsonTreeReader来解析每条记录,并将使用FlowFile的所有记录中的值生成和执行必要的SQL作为一条准备好的语句。这样,您就不需要自己生成SQL,也不需要担心碎片化的事务或其他任何事务。

最新更新