Как выполнить запрос скручивания в Apache NiFi, используя InvokeHTTP или ExecuteStreamCommand Processor? - PullRequest
Новая
       31

Как выполнить запрос скручивания в Apache NiFi, используя InvokeHTTP или ExecuteStreamCommand Processor?

0 голосов
/ 09 июля 2019

Так что у меня возникли проблемы с отправкой запроса завитка в Hive.Я хочу взять созданный мной файл потока json и отправить его в качестве команды в Hive, но у меня продолжают появляться ошибки при попытке настроить процессор InvokeHTTP.Для справки вот мой рабочий процесс в его нынешнем виде.Замените Text-> Update Attributes -> InvokeHTTP-> Поставьте процессор

Я в основном пытался заставить работать процессор InvokeHTTP.У меня есть следующие конфигурации: 1.HTTP метод: POST 2.Remote URL: $ {https://hive -prod-1.sample_text / alert } 3.SSL Context Service: Стандартная служба SSLContext 4. Тип прокси: https -Content-type: application / json

Затем я добавил свойство 5.curl: curl-XPOST-H "Авторизация: Bearer xWJbexxxxxxxx -H" Content-Type: application / json '

Я не уверен, что моя конфигурация неверна или есть другая проблема.

Когда я пытался использовать / настроить ExecuteStreamCommand: 1.Command Аргументы: curl-XPOST-H "Authorization xxxxx -H" Тип содержимого: application / json 2. Путь к команде: application / json Разделитель аргументов:;

Опять же, я не уверен, является ли конфигурация правильной для любого из этих процессоров или имеет ли она какое-либо отношение к сертификату.Когда я запускаю его, я также получаю сообщение об ошибке «java.lang.illegalstateexception: trustmanagerfactory = не инициализирован.

1 Ответ

0 голосов
/ 09 июля 2019

Звучит так, как будто вы не / полностью не настроили SSLContextService, который требуется для InvokeHTTP при подключении к службе, использующей TLS. Ваш экземпляр Hive защищен TLS, поэтому вам необходимо получить открытый сертификат экземпляра Hive (вы можете сделать это через браузер, используя openssl s_client и т. Д.), Загрузить общий сертификат в отформатированное хранилище ключей Java (JKS) Файл truststore в виде trustedCertEntry , а затем укажите SSLContextService на этот файл хранилища доверенных сертификатов. Для получения дополнительной информации посмотрите первый раздел статьи Томаса Зезулы о конфигурации SSL NiFi .

...