У меня есть некоторые атрибуты myId, count.Теперь с этими атрибутами я хочу записать формат Jolt,...

У меня есть следующий JSON, который я хотел бы преобразовать в CSV. Элементы JSON будут постоянными...

Следующий поток принимает комбинацию имени пользователя и пароля и аутентифицируется по API через...

Контекст: У меня есть несколько приложений, которые публикуют сообщения в режиме реального времени...

У меня есть поток QueryDatabaseTable-> ConvertRecord-> PutElasticseachHttpRecord. То, что я пытаюсь...

Мы сталкиваемся с очень странным состоянием с Apache NiFi и SQS.Мы используем сервис...

У меня есть этот образец csv файла: school, city, person_id, drivers_license_number Georgetown, DC,...

Я использую NiFi ExecuteScript для вызова Groovy-скрипта, который извлекает текст из PDF-файлов

Мой поток содержит получение XML-файлов из каталога, а затем преобразование их в json.Прежде чем...

Попытка добавить тег к входящему файлу nifi json. Ввод: [{"HIT":"DUMMY_3"...

У меня миллионы записей в MongoDB, и я хочу использовать NiFi для перемещения данных.Вот сценарий,...

Я пытаюсь прочитать сообщения (16-значное число) от процессора Nifi (Collected_data) в другом...

Есть ли предпочтительный способ маршрутизации FlowFile на основе условий нисходящего потока? В...

Кто-нибудь устанавливал минифи С2 (управление и контроль)?Мне нужно несколько шагов, чтобы это...

Может быть, это глупый вопрос, но я должен спросить. У меня есть процессор Collect_data в Nifi, и...

Мне нужно изменить введенную дату в удобном для SQL формате, чтобы вставить ее в БД.При попытке...

У меня есть поток Apache NiFi, где я читаю в массивном файле .csv.Вот пример .csv: school, date,...

Я пытаюсь обновить документ, просто добавляю новые данные.Для этого я использую ListFile и...

Я пытаюсь использовать Nifi 1.7 с процессором Hive 3.0 и PutHive3Streaming.В моем случае записи...

Пытаясь настроить докерский контейнер Apache NiFi, с traefik в качестве балансировщика нагрузки по...

У меня есть главный CSV с именем Test1.CSV с 1000+ полями, а затем у меня есть еще один CSV с...

Я пытаюсь создать POC, используя ExecuteProcess для запуска файла .sh на удаленном сервере.Сейчас я...

Я пытаюсь использовать службу DistributedMapCacheClient в качестве свойства в моем пользовательском...

У меня есть flowfile с 3 атрибутами a, b, c.Я хочу создать 2 новых атрибута a_b_hash, c_hash....

У меня есть случай: в потоке содержимого всегда в формате json и данные внутри json всегда меняются...