Почему вы меняете сценарий с ответа? У тебя есть nifi 1.5.0?

ьзуя InferAvroSchema, я получил схему Avro моего файла. Я хочу создать таблицу в PostregSql, используя эту схему Avro. Какой процессор я должен использовать. Я использую: GetFile-> InferAvroSchema-> Я хочу создать таблицу из этой схемы ...

 У proc есть опция «Сохранить исходный файл», это опция перемещения / удаления / сохранения при обработке. Вы можете переместить его в область подготовки и переместить обратно после обработки

у написатьnifi процессор, который может читать XML-файл из каталога hdfs, а затем извлекать его данные в атрибуты потока файловТакже, если есть случай, когда два процессора nifi могут получить этот файл и прочитать данные или записать что-нибудь ...

 свойство является необязательным, и если оно опущено, вся коллекция будет запрошена и возвращена как потоковые файлы Пример запроса должен быть таким: {a: 1, b: 2}

ичок в Apache NIFI инструмент. Я пытаюсь импортировать данные из Монго БД и поместить эти данные в HDFS. Я создал 2 процессора, один для MongoDB, а второй для HDFS, и настроил их правильно. Задание выполняется успешно и сохраняет данные в HDFS, ...

Конвертируйте файл CSV в JSON, используя Apache NiFi

попробуйте запустить его. и если порт 4557 не используется другим программным обеспечением, установленный кэш должен работать.

ичок в NiFi и просто играю с процессорами.Я пытаюсь включить

{v1} & param2 = $ {v2}, а затем вы можете установить v1 и v2 в качестве атрибутов перед этим процессором, используя UpdateAttribute.

ли использовать xmlHttpRequest в процессоре NIFI для вызова службы удаленного отдыха? В моем случаеExecuteScript процессор (использующий Javascript) не может оценитьXMLHttpRequest; Есть ли подобное решение, которое я могу использовать ...

Достаточно смешно! Я нашел ответ на свой вопрос. Пожалуйста, используйте sql.args.n.value -> $ {sql.args.n.value: format ("гггг-ММ-дд ЧЧ: мм: сс.ССС")}. Работал на меня!

робовал решение, предложенное для устранения ошибки преобразования формата отметки времени с помощью процессора «UpdateAttribute», т.е. ConvertJSONtoSQL-> UpdateAttribute -> PutSQL В UpdateAttribute я использовал Property Value --------------- ...

 чтобы получить начало даты

я есть CSV-файл, который содержит сотни тысяч строк, а ниже приведены некоторые примеры строк ..,

Отлично! стратегия ограничителя сделала свое дело! :) Я также попробую использовать процессор MergeRecord и протестировать его. Спасибо за помощь @Shu

я есть поток ниже, настроенный для чтения данных JSON и преобразовать его в CSV с помощью процессора convertRecord. Тем не менее, выходной файл потока заполняется только одной записью(Я предполагаю только первую запись) вместо ...

 на ваш связанный вопрос о выборе столбцов CSV.

я есть CSV-файл, скажем, со 100+ столбцами, и я хочу извлечь только определенные 60 столбцов в качестве подмножества (оба имени столбца + его значение). Я знаю, что мы можем использовать процессоры Extract Text.Может кто-нибудь сказать мне, что ...