У меня проблемы с получением процессора ListSFTP.
Сначала я проверил доступ к серверу sftp с помощью командной строки на сервере NiFi. Это работает, но я должен предоставить парольную фразу для частного файла ключа s sh.
Затем я убедился, что настроил процессор ListSFTP, используя те же настройки, что и в командной строке sftp:
- Имя хоста: ip-адрес сервера
- Порт: 22 * 1010 *
- Имя пользователя: имя пользователя с доступом к серверу и привязано к ключу
- Путь к личному ключу: установлен полный путь к файлу, содержащему
- Фраза закрытого ключа: пароль для файла ключа
- Удаленный путь:.
- Строгая проверка ключа хоста: false
- Файл ключа хоста: Файл содержит вывод s sh -keyscan для данного сервера
С этими настройками Я получаю сообщение об ошибке в лог-файле. Любая идея, почему NiFi не может получить доступ к файлу ключа и получить доступ к серверу sftp. Приветствия
2020-03-19 15: 43: 19,736 ОШИБКА [Управляемый таймером поток процессов-2] oanifi.processors.standard.ListSFTP ListSFTP [id = d343fa19-0170-1000-3352-999829a448cc ] Не удалось выполнить листинг на удаленном хосте из-за java .io.IOException: Не удалось получить c соединение с удаленным хостом из-за com.jcraft.jsch.JSchException: недействительный privatekey: [B@6d9b662: {} java .io.IOException: Не удалось получить соединение с удаленным хостом из-за com.jcraft.jsch.JSchException: недопустимый закрытый ключ: [B@6d9b662 в организации. apache .nifi.processors.standard.util.SFTPTransfer.getChannel (SFTPTransfer . java: 515) в орг. apache .nifi.processors.standard.util.SFTPTransfer.getListing (SFTPTransfer. java: 212) в орг. apache .nifi.processors.standard.util.SFTPTransfer .getListing (SFTPTransfer. java: 175) в орг. apache .nifi.processors.standard.ListFileTransfer.performListing (ListFileTransfer. java: 106) в орг. apache .nifi.processors.standard.ListSFTP .performListing (ListSFTP. java: 146) в орг. apache .nifi.processor.util.list.Ab stractListProcessor.listByTrackingTimestamps (AbstractListProcessor. java: 472) в орг. apache .nifi.processor.util.list.AbstractListProcessor.onTrigger (AbstractListProcessor. java: 414) в орг. apache .nifipro. AbstractProcessor.onTrigger (AbstractProcessor. java: 27) на орг. apache .nifi.controller.StandardProcessorNode.onTrigger (StandardProcessorNode. java: 1162) на орг. apache .nifi.controller.tasks.ConnectableTask. вызвать (ConnectableTask. java: 209) в орг. apache .nifi.controller.scheduling.TimerDrivenSchedulingAgent $ 1.run (TimerDrivenSchedulingAgent. java: 117) в орг. apache .nifi.engine.FlowEngine $ 2. выполнить (FlowEngine. java: 110) в java .util.concurrent.Executors $ RunnableAdapter.call (Executors. java: 511) в java .util.concurrent.FutureTask.runAndReset (FutureTask. java: 308) в java .util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 301 (ScheduledThreadPoolExecutor. java: 180) в java .util.concurrent.ScheduledThreadPoolExecutor $ ScheduledRunchTunTю adPoolExecutor. java: 294) в java .util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor. java: 1149) в java .util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor: ThreadPoolExecutor: ThreadPoolExecutor: ThreadPoolExecutor: ThreadPoolExecutor: ThreadPoolExecutor: ThreadPoolExecutor: 624) в java .lang.Thread.run (поток. java: 748). Причина: com.jcraft.jsch.JSchException: неверный закрытый ключ: [B@6d9b662 at com.jcraft.jsch.KeyPair.load ( KeyPair. java: 664) на com.jcraft.jsch.KeyPair.load (KeyPair. java: 561) на com.jcraft.jsch.IdentityFile.newInstance (IdentityFile. java: 40) на com.jcraft .jsch.JSch.addIdentity (JSch. java: 407) на com.jcraft.jsch.JSch.addIdentity (JSch. java: 388) на орг. apache .nifi.processors.standard.util.SFTPTransfer .getChannel (SFTPTransfer. java: 485) ... 18 общих кадров опущено