问NiFi:在ExecuteSQL处理器中引用FlowFile内容

EN

是否可以在后续的ExecuteSQL处理器中引用FlowFile的内容？

例如：

• 我使用GenerateTableFetch和ExecuteSQL来轮询数据库表。
• 接下来，我使用QueryRecord来转换结果--特别是使用MAX()和GROUP BY操作，因为我不能在GenerateTableFetch处理器上使用这个操作符。

。

SELECT
    hu_id
    ,wh_id
    ,MAX(audit_timestamp) AS "newest_timestamp"
FROM FLOWFILE
GROUP BY
    hu_id
    ,wh_id

• 我希望能够使用另一个ExecuteSQL来做以下事情：

。

SELECT
    FLOWFILE.hu_id
    ,FLOWFILE.wh_id
    ,FLOWFILE.newest_timestamp
    ,hum.status
    ,hum.location_id
FROM FLOWFILE
INNER JOIN AAD.dbo.t_hu_master hum ON
    FLOWFILE.hu_id = hum.hu_id
    AND FLOWFILE.wh_id = hum.wh_id

..。有效地引用Avro FlowFile内容来执行多连接。

如果这是不可能的，那么有一个优雅的解决办法吗？，到目前为止，我唯一能想到的解决方案是.

1. SplitAvro
2. ConvertAvroToJSON
3. EvaluateJSONPath
4. ReplaceText (用wh_id和hu_id创建一组单独的SELECT语句)，然后.
5. ExecuteSQL

任何想法或见解都是值得赞赏的！