Я прошел документацию ConsumeKafka_2_0 .Однако не ясно, как настроить потребителя Kafka с JAAS SASL...
Я пытаюсь интегрировать ldap с моим экземпляром Apache Nifi.Когда я пытаюсь подключиться, я получаю...
Мне нужно получить второй атрибут из файла JSON.и попытался использовать процессор 'valuJsonPath' и...
Чтение CSV и вставка данных в таблицу.Используя convertJsonToSQL и поставить sql процессор. Для...
Я в основном получаю файл потока, и мне нужно получить значение ключа. import json import java.io...
Я пытаюсь запустить код Python в процессоре Nifi ExecuteStreamCommand. Код включает в себя не...
Я хотел бы конвертировать файлы Avro в паркет в NiFi.Я знаю, что можно конвертировать в ORC с...
Я пытаюсь загрузить данные из моей локальной системы в хранилище Azure Data Lake с помощью NiFi.Мне...
Я хочу знать, доступен ли какой-либо способ для изменения "AttributesToJSON".Проблема в том, что я...
У меня есть такой объект json. [{ A:"XXX", B:"ss", C:"qee", Z:[...
Можем ли мы передать java.security.auth.login.config, содержащий путь конфигурации JaaS, процессору...
Я хочу использовать отдельные значения, поступающие в виде массива в полезной нагрузке JSON
При использовании DELETE /buckets/{bucketId}/flows/{flowId}, он не может удалить поток, который...
Мой поток работает правильно, но через час данные о потоке исчезают.Я уменьшил и увеличил размер...
В следующей таблице я хочу получить только целевые записи Далласа, для которых мне нужно...
Я хочу добиться нижеприведенного сценария запрос-ответ в Nifi.Моя цель состоит в том, чтобы...
Я должен запустить удаленный API в Nifi и получить ответ типа Json: {"data":[{...}, {...}...
Я хочу создать поток обработки ошибок, и мне нужно записать имя неисправного процессора только в...
Можно ли загрузить группы пользователей и политики с помощью провайдера на основе файлов? В...
пролог Имя таблицы MySQL: ar_tmp имеет два столбца id int и name int для выполнения Я выполняю sql...
Я использовал процессор ExecuteSQL для запуска хранимой процедуры, в результате чего появилась одна...
Я пытаюсь получить все документы за определенный промежуток времени, используя RunMongoAggreation.В...
Я ищу хранилище управления версиями в BitBucket, например, GitHub.Я нашел хранилище Nifi Git.Но в...
Есть ли способ в nifi 1.8 для PutDatabaseRecord, чтобы сообщить вам, в какой строке CSV-файла у вас...
У меня есть поток, в котором мне приходится каждый раз ждать точные 12 файлов. , поэтому я написал...