У меня есть установка кластера HDInsight в облаке Azure.Также установили Apache NiFi на отдельную виртуальную машину.Обратите внимание: у меня включен доступ по SCP и SSH из виртуальной машины в мой кластерЯ пытаюсь настроить некоторые процессоры в соответствии с моим требованием, первым в списке является процессор «ExecuteProcess».С помощью этого я пытаюсь установить соединение SSH с моим HDInsight Cluster, и после успешного прохождения этого результата (соединение установлено = 'Y') через FlowFile ко второму процессору, который является процессором "GetFile", который в основном будетчитать JSON-файл по определенному пути в этом кластере HDInsight.
Я добавил процессор «ExecuteProcess» и в разделе «Настройка» -> Свойства установил следующее:
Команда: sshsshdepuser@demodepdata-ssh.azurehdinsight.net аргументы команды: sshdepuser@demodepdata-ssh.azurehdinsight.net Длительность пакета: нет набора ошибок Ошибка перенаправления Система: True Рабочий каталог: нет набора значений Разделитель аргументов: нет набора значений
Команда: ssh sshdepuser@demodepdata-ssh.azurehdinsight.net Аргументы команды: sshdepuser@demodepdata-ssh.azurehdinsight.net Длительность пакета: Нет набора значений Ошибка перенаправления системы: True Рабочий каталог: Нет набора значений Разделитель аргументов: Нет набора значений
ПльПримечание. sshdepuser@demodepdata-ssh.azurehdinsight.net - это имя хоста сервера для моего кластера HDInsight, к которому я пытаюсь установить соединение с моей виртуальной машины (DNS-имя сервера: dep-hadoop.eastus.cloudapp.azure.com)
Я пытаюсь настроить некоторые процессоры в соответствии с моим требованием, первым в списке является процессор "ExecuteProcess".С помощью этого я пытаюсь установить соединение SSH с моим HDInsight Cluster, и после успешного прохождения этого результата (соединение установлено = 'Y') через FlowFile ко второму процессору, который является процессором "GetFile", который в основном будетчитать файл JSON по определенному пути в этом кластере HDInsight.