nifi добавляет пару значений ключа в файл потока json

Question

Как я могу добавить пару ключ / значение в файл потока json в Nifi.Я попытался replaceText процессор со стратегией замены как append, но пара ключ / значение не могла быть правильно вставлена ​​в JSON.

Answer 1

Я упоминал об этом в другом посте, но вам нужно будет использовать процессор, который понимает JSON.Вы можете использовать UpdateRecord для этого ... для этого потребуется, чтобы в вашей схеме было дополнительное поле, которое вы можете сделать обнуляемым, чтобы эту же схему можно было использовать с самого начала, или у вас может быть вторая копия схемы, которую читатель может прочитать в UpdateRecordбудет использовать схему с 10 полями, а писатель будет использовать схему с 11 полями.