Получить файлы от SFTP NiFi - PullRequest
0 голосов
/ 14 апреля 2020

В потоке NiFi я читаю файл JSON из веб-службы, который содержит информацию о SFTP-сервере (сервер, порт, путь к каталогу, где я должен искать файлы, пользователь). Мне нужно получить все файлы, которые содержатся в каталоге, указанном в этом файле. Я не могу просто использовать процессор ListSFTP, подключенный к FetchSFTP, или процессор GetSFTP, поскольку они не допускают входные соединения и, следовательно, не могут читать потоковый файл. Как я мог сделать что-то подобное в NiFi?

1 Ответ

0 голосов
/ 14 апреля 2020

Вы можете поместить требуемую информацию (сервер, порт ..) в атрибуты FlowFile или реестр переменных, а затем использовать процессор FetchSFTP

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.11.4/org.apache.nifi.processors.standard.FetchSFTP/

...