Как сделать один потоковый файл дочерним по отношению к отдельному ранее существующему потоковому файлу?

Question

Когда потоковый файл появляется из внешнего источника, но знает uuid предыдущего потокового файла, из которого он получен, как я могу пометить существующий потоковый файл как родительский для этого.

Я вижуя сталкивался с несколькими способами, поэтому я намеренно попытался сохранить общий вопрос, но конкретный случай:

Потоковый файл отправляется во внешнюю систему через AMQP (процессор PublishAMQP), который выполняет асинхронноработать и отчитываться в более поздний момент через AMQP (процессор ConsumeAMQP).

FlowFile1: Процессор -> AMQP (с FF1 UUID)

FlowFile2: AMQP (с FF1 UUID) -> Процессор

Поскольку ответ имеет uuid исходного потокового файла, я бы хотел связать этот ответ с исходным потоковым файлом

Я не вижу способа сделать это из ProcessSession, FlowFile, ProvenanceEventRecord иливсе остальное у меня есть доступ через привязки или иным образом.Большинство моих попыток были сделаны через процессор ExecuteScript, где у меня есть доступ к объекту flowfile и nifi dev api.

Answer 1

В настоящее время вы можете отслеживать происхождение только с момента создания файла потока до момента, когда он покидает NiFi.Как только он покидает NiFi, вы попадаете в кросс-системную линию.