我正在尝试替换从 nifi 中的另一个处理器获取的查询中的值,我该如何实现这一点或最好的方法是什么?处理器详细信息如下,
- 执行 SQL 处理器 ->
SELECT Rno FROM sampleDB WHERE operation = 1;
- SplitAvro 处理器
- 将 Avro 转换为 Json -> 在这里我得到以下 JSON
{'Rno':'121'}
- 执行 SQL 处理器 ->
DELETE FROM NewDB WHERE Rno = X
(此处 X 应替换为从前一个处理器接收到的 Rno,即“121”)
如何实现第 4 步除上述处理器外还应使用哪些处理器?