4
ответа
Использование модуля python 'lxml' в Apache Nifi [duplicate]
Я написал сценарий python для работы в процессоре NiFi ExecuteScript. У меня установлен модуль «lxml», но когда я запускаю процессор, он выдает сообщение об ошибке «Невозможно импортировать имя etree». Является ...
вопрос задан: 5 April 2013 07:19
3
ответа
NiFi PutFile установленное имя файла не работает
Получите данные JSON через брокера Kafka. Данные представлены в следующем формате, а данные изображения закодированы в Base64. например: {"имя файла": "test.jpg", "filedata": "/ 9j / 4AAQSkZJRgABAQEAYABgA ....."} Я хочу ...
вопрос задан: 17 January 2019 13:04
2
ответа
Доступ к сервисам AWS из Apache Nifi, работающего на AWS
У меня есть экземпляр Nifi, работающий на машине EC2, и я пытаюсь получить доступ к ограниченному ведру s3. Поскольку генерация ключей доступа вручную не рекомендуется, я хочу дать машине правильный IAM ...
вопрос задан: 22 March 2019 21:42
1
ответ
MiNiFi - NiFi не может связаться с хостом: истекло время подключения к порту
Я запускаю MiNiFi на сервере Windows, который находится за брандмауэром моей компании. Мой NiFi работает в кластере Hortonworks (3 узла, например: sj46, sj47, sj48). Я пытаюсь отправить данные с MiNiFi на NiFi. ...
вопрос задан: 2 April 2019 00:52
1
ответ
Делать преобразование ключей JSON с Apache NIFI
Мне нужно сделать преобразование JSON в Apache NIFI. Ключи JSON в полезной нагрузке будут генерироваться динамически. Например, во входных данных, приведенных ниже, у 'customer' есть атрибуты 'fname' и 'lname'. ...
вопрос задан: 24 March 2019 07:34
1
ответ
PyCryptodome альтернатива для Jython
Я пытаюсь включить простой процессор шифрования для Apache Nifi. Я использую модуль Script Processor для включения скрипта Python, который выполняет функцию шифрования и дешифрования с помощью AES ....
вопрос задан: 27 February 2019 15:05
1
ответ
Разница между свойствами процессора и атрибутами потокового файла в Apache NiFi
Насколько я понимаю, свойства процессора NiFi специфичны для этого процессора. Таким образом, добавление нового свойства в процессор будет видно только внутри этого процессора и не будет передано ...
вопрос задан: 19 January 2019 19:53
1
ответ
Как загрузить процессор в Apache NiFi во время его работы?
Можно ли загрузить новый процессор в Apache NiFi во время его работы Кроме того, возможно ли обновить уже загруженный процессор в запущенном экземпляре Apache NiFi? Я исхожу из ...
вопрос задан: 18 January 2019 18:58
1
ответ
Поступают ли события в одном разделе в один и тот же FlowFile с использованием Kafka Consumer в NiFi
В сообщении для записей Max Poll установлено значение 1, чтобы гарантировать, что события в одном файле потока происходят из одного и того же раздела. https: //community.hortonworks.com/articles/223849/simple-backup-and-restore-of-kafka -...
вопрос задан: 18 January 2019 16:01
1
ответ
В NiFi, как хранить атрибуты, извлеченные из БД, которые меняются не очень часто?
Я запланировал процессор ExecuteSQL, который извлекает ограничение скорости из БД. Это ограничение скорости не меняется часто, поэтому я создал интервал времени в 24 часа. Но я заметил, что следующий процессор, например ...
вопрос задан: 18 January 2019 12:57
1
ответ
Системный журнал для Кафки: самый эффективный рабочий процесс в NIFI?
На самом деле я работаю в крупной французской компании, и мы стремимся загружать журналы системного журнала (формат rfc5424) всех наших серверов (около 1400 серверов) в kafka через NIFI. Мы выбираем NIFI, потому что хотим проложить маршрут ...
вопрос задан: 18 January 2019 08:45
1
ответ
преобразовать e-нотацию в число в процессе nifi
Я создаю нифи-процесс, который глотает файлы .xml. У меня есть один .xml, где все числовые поля проходят через E-нотацию, то есть 1.6777777777E-001. Я пытаюсь выяснить лучшее ...
вопрос задан: 13 July 2018 13:50
0
ответов
NiFi Max количество потоков
У меня есть узел NiFi с 40 процессорами и 12 ядрами на процессор. Я установил для параметра «Максимальное число потоков, управляемых таймером» значение 30. Тем не менее, некоторые процессоры работают очень медленно. Может кто-нибудь, пожалуйста, скажите м
вопрос задан: 31 March 2019 00:35
0
ответов
MiNiFi: процессор ListFile, показывающий, что каталог недействителен, потому что каталог не существует
Я использую NiFi и MiNiFi. версии: NiFi - 1.5 MiNiFi - 0.4 среда: NiFi - 3-х узловый кластер hortonworks linux. MiNiFi - windows 7. Я создаю поток ListFile -> FetchFile -> ...
вопрос задан: 28 March 2019 05:12
0
ответов
Может ли Nifi загружать данные из DB2 в Cassandra?
Я изучаю варианты загрузки данных из DB2 в Cassandra с использованием инструментов с открытым исходным кодом. Я прочитал некоторые блоги и статьи и обнаружил, что Nifi - один из рекомендуемых инструментов. Нужны некоторые входы на ...
вопрос задан: 19 March 2019 17:22
0
ответов
Ошибка службы поиска NiFi - не удалось найти координаты в службе поиска
Мы продолжаем получать эту ошибку при попытке использовать любую службу поиска (NiFi или стороннюю) для добавления дополнительных атрибутов к нашему начальному запросу DB2: не удалось найти координаты {LEGAL_ENTITY_ID_NUM = 13366} ...
вопрос задан: 11 March 2019 15:11
0
ответов
nipyapi: AssertionError: недопустимые или нечитаемые файловые ресурсы / data / nifi / http_to_hdfs.xml
При попытке загрузить шаблон с помощью: nipyapi.templates.upload_template (pg_id, file) я получаю AssertionError: Файловые ресурсы / data / nifi / http_to_hdfs.xml недопустимы или не читаются, хотя это ...
вопрос задан: 22 February 2019 12:53
0
ответов
Процессор Nifi запускается дважды для одного файла потока ввода
В настоящее время я новичок в Apache Nifi и до сих пор изучаю его. Я сделал специальный процессор, где я буду получать данные с сервера с нумерацией страниц. Я передаю входной файл, который будет содержать атрибут «URL». ...
вопрос задан: 18 January 2019 09:14
0
ответов
Многие потоки для одного URL-адреса вызывающего абонента. Как установить переменную для каждого пути потока для чтения в URL-адресе?
Я довольно новичок в Nifi и мне не повезло найти ответ, поэтому я публикую свой вопрос здесь. В потоке, который у меня есть, мне нужно иметь возможность установить переменную для каждого пути потока, чтобы URL-адрес был ...
вопрос задан: 15 January 2019 15:11
0
ответов
Разница между Apache NiFi и StreamSets
Я планирую сделать проект класса и прошел через несколько технологий, где я могу автоматизировать или настроить поток данных между системами, и обнаружил, что есть несколько из них, то есть Apache NiFi и ...
вопрос задан: 16 June 2016 15:09
0
ответов
НИФИ - Dev to Test to Prod
Мы пытаемся найти лучший подход к обновлению конфигураций процессора по мере прохождения этапов dev, test и prod. Мы действительно хотели бы избежать ...
вопрос задан: 15 April 2016 13:20