Nifi: поток контента (динамический формат JSON) в CSV - PullRequest
Новая
       27

Nifi: поток контента (динамический формат JSON) в CSV

0 голосов
/ 26 сентября 2018

У меня есть случай: в потоке содержимого всегда в формате json и данные внутри json всегда меняются (как kyes, так и значения) .Возможно ли преобразовать это содержимое потока в csv ?

Обратите внимание, что ключи в json всегда меняются.

Большое спасибо,

1 Ответ

0 голосов
/ 27 сентября 2018

Чтобы реализовать этот сценарий, нам нужно сгенерировать авро-схему динамически для каждой json-записи сначала, затем , конвертировать в AVRO , наконец , конвертировать AVRO в CSV

Поток: enter image description here

1.SplitJson //split the array of json records into individual records

2.InferAvroSchema //infer the avro schema based on Json record and store in attribute

3.ConvertJSONToAvro //convert each json record into Avro data file

4.ConvertRecord //read the avro data file dynamically and convert into CSV format

5.MergeContent (or) MergeRecord processor //to merge the splitted flowfiles into one flowfile based on defragment strategy.

Сохранить это xml и загрузить в свой экземпляр nifi и изменить в соответствии с вашими требованиями.

...