Когда потоковый файл появляется из внешнего источника, но знает uuid предыдущего потокового файла, из которого он получен, как я могу пометить существующий потоковый файл как родительский для этого.
Я вижуя сталкивался с несколькими способами, поэтому я намеренно попытался сохранить общий вопрос, но конкретный случай:
Потоковый файл отправляется во внешнюю систему через AMQP (процессор PublishAMQP), который выполняет асинхронноработать и отчитываться в более поздний момент через AMQP (процессор ConsumeAMQP).
FlowFile1: Процессор -> AMQP (с FF1 UUID)
FlowFile2: AMQP (с FF1 UUID) -> Процессор
Поскольку ответ имеет uuid исходного потокового файла, я бы хотел связать этот ответ с исходным потоковым файлом
Я не вижу способа сделать это из ProcessSession, FlowFile, ProvenanceEventRecord иливсе остальное у меня есть доступ через привязки или иным образом.Большинство моих попыток были сделаны через процессор ExecuteScript, где у меня есть доступ к объекту flowfile и nifi dev api.