Вопросы по теме 'apache-nifi'
Результаты слияния процессора ExecuteSQL с содержимым Json в nifi 6.0
Я имею дело с объектами json, содержащими точки географических координат. Я хотел бы запустить эти точки на сервере postgis, который у меня есть локально, чтобы оценить точку в сопоставлении многоугольников.
Я надеюсь сделать это с уже...
1970 просмотров
schedule
09.11.2021
не удалось получить данные от hbase из-за исключения сетевого подключения Java: в соединении отказано в Nifi
Работаю на Nifi с Hbase. В этом случае я получаю данные от Hbase, используя процессор Gethbase и отправляю данные в процессор Putfile в Nifi. Но я получаю сообщение об ошибке «не удалось получить данные от Hbase из-за исключения сетевого подключения...
221 просмотров
schedule
03.12.2021
NiFi ExecuteScript с Groovy: java.lang.ClassNotFoundException: com.microsoft.sqlserver.jdbc.SQLServerDriver
Я пытаюсь выполнить сценарий Groovy, который использует драйвер JDBC сервера Microsoft SQL. Я пытаюсь указать путь к банке sql jdbc в каталоге модулей. Однако мой отличный скрипт жалуется, что класс SQLServerDriver не найден.
Вот как выглядит...
1339 просмотров
schedule
18.09.2021
GetKafka не получает сообщения в Apache Nifi
Я пытаюсь получить сообщения с помощью процессора GetKafka, но не могу его получить. Я тестировал использование сообщений с помощью потребителя командной строки Kafka, и он работает. Я также смог успешно использовать процессор PutKafka, чтобы...
827 просмотров
schedule
12.11.2021
Apache NIFI: из содержимого потока данных, разделенного и преобразованного в атрибуты Json
Я получил от своего Apache Kafka следующее содержимое потокового файла, и моя цель - разделить эти данные на разные атрибуты.
например дата расстояние и т. д.
а затем преобразовать эти атрибуты в Json (я знаю, какой процессор мне для этого...
1008 просмотров
schedule
18.10.2021
log.info в ExecuteScript
Я пытаюсь войти в компонент ExecuteScript с помощью Groovy. Когда я вызываю log.info, в nifi-app.log ничего не записывается, но когда я вызываю log.errorit, делает это. Есть ли какая-то конфигурация log4j или что-то еще, что мне нужно сделать?...
2933 просмотров
schedule
18.10.2021
ExecuteSQL не выбирает таблицу, если она имеет значение смещения dateTime?
Я создал таблицу с одним столбцом, имеющим значение типа данных -dateTimeOffset, и вставил несколько значений.
create table dto (dto datetimeoffset(7))
insert into dto values (GETDATE()) -- inserts date and time with 0 offset
insert into dto...
396 просмотров
schedule
26.11.2021
NiFi-1.0.0 Связанные с GetFile
У меня есть поток, первый процессор - это GetFile, который читает из исходного каталога и запускается каждые [x] секунд или минут. Если я скопирую файл в исходный каталог, и GetFile начнет читать файл в этот момент, получу ли я частичные данные по...
113 просмотров
schedule
27.09.2021
Невозможно получить доступ к NIFI Rest api другого сервера в защищенном режиме
Я пытаюсь получить доступ к NIFI rest api другого сервера со своей машины, используя ajax, как показано ниже,
url:"https://serverip:port/nifi-api/",
{Authorization : 'Bearer ' + 'access token here'}
Получение ответа на предполетный запрос...
1311 просмотров
schedule
20.11.2021
Планирование задания с Apache NiFi путем передачи значений динамических свойств
Я создал рабочий процесс NiFi, как показано ниже: GenerateFlowFile -> Custom Processor -> LogAttribute Мой пользовательский процессор имеет свойство в качестве даты начала. Но дата начала должна изменяться при каждом запланированном запуске в...
1316 просмотров
schedule
20.11.2021
Http как источник для Nifi - не работает должным образом
Я пытаюсь отправить файл через почтальона с запросом POST, и этот файл необходимо сохранить в локальной FS. Перепробовал все 4 варианта GetHttp,InvokeHttp,ListenHttp,HandleHttpRequest . Похоже, GetHttp,InvokeHttp требует, чтобы веб-сервис был...
291 просмотров
schedule
16.11.2021
Nifi: как удалить сеанс на основе значения атрибута в nifi
Я хочу удалить сеанс в случае, если я получу определенные данные из файла. У меня есть такой код, но у меня возникли ошибки: «Flowfile уже отмечен для удаления». Что мне следует изменить, чтобы избавиться от лишних ошибок?
В случае отката сеанса...
167 просмотров
schedule
22.11.2021
Подключение NiFi к Vertica
Я пытаюсь загрузить CSV-файл, полученный с SFTP-сервера, в Vertica в качестве новой таблицы. Я настроил процессор GetSFTP , но я не понимаю, как мне установить соединение с Vertica и выполнить SQL?
424 просмотров
schedule
03.10.2021
Как связать информацию о происхождении с результатом ExecuteSQL в NiFi?
Я выполняю серию запросов после перечисления таблиц в базе данных, в основном делаю дампы базы данных с добавлением некоторых умов.
Когда данные поступают из ExecuteSql процессора, они имеют формат Avro. Я могу использовать ConvertAvroToJson...
677 просмотров
schedule
01.10.2021
Ссылка на переменные, определенные в пользовательских свойствах NiFi
Я пытаюсь автоматизировать развертывание конфигурации в моем кластере NiFi с помощью NiFi REST API. Я определил переменные как файл настраиваемых свойств: nifi.variable.registry.properties=./conf/dbconfig.properties
Содержание...
804 просмотров
schedule
02.10.2021
Как получить статус flowStatus при установке Windows Apache Minifi
Ответ - НЕТ, но команда Apache разрабатывает эту функцию в соответствии с ответом @apiri ниже.
У меня есть сервер Apache NiFi, который я использую для сбора данных из нескольких источников (Windows / Linux), где у меня установлен minifi.
На...
476 просмотров
schedule
13.11.2021
NiFi Как использовать процессор InvokeHTTP с SOAP
Я вижу, что другим удалось заставить это работать, однако я не могу найти достаточно подробностей, объясняющих, как они это сделали, чтобы я мог заставить это работать.
Этот парень на эту ссылку утверждает, что он смог это сделать. Хотя есть...
5519 просмотров
schedule
24.09.2021
Apache Nifi getFile обработчик
Файл копируется из исходного каталога в целевой каталог с помощью getfile и putFile Processor, но файл в источнике не удаляется, и если я делаю это вручную, он удаляется из обоих каталогов. Я новичок в Apache nifi. Я слежу за видео, в котором файлы...
270 просмотров
schedule
12.10.2021
Объедините две схемы в одну в Apache nifi
Я пытаюсь объединить два файла csv в json с помощью Apache nifi. Два csv-файла - это person.csv, содержащие информацию о людях:
Id|Name|Surname
ABC-123|John|Smith
ABC-111|Allan|Wood
ABC-001|Grace|Kelly
И второй csv содержит список...
630 просмотров
schedule
20.10.2021
Последовательность 2 или более вызовов SOAP для Apache NiFi?
Благодаря NiFi Как использовать процессор InvokeHTTP с SOAP , я смог совершить вызов по протоколу SOAP. Используемая стратегия заключалась в использовании процессора GenerateFlowFile и вставке моего контента в пользовательский контент. Для вызова...
408 просмотров
schedule
10.12.2021
