Интеграция Spring Boot в Apache NIFI

Question

Я пытаюсь создать процесс в Nifi, который будет выглядеть следующим образом => прочитать csv, преобразовать в json и записать его в db, но я должен использовать классы dao из моего весеннего загрузочного проекта вместо PutDatabaseRecord.

Я пытался использовать SpringContextProcessor (сделал Spring-проект, в котором в качестве зависимости использовался Spring-загрузочный проект), но Nifi, похоже, не догоняет конфигурационный yml-файл и не может создать соединение с БД.

Есть ли способ обойти это?

Answer 1

Уже есть процессоры, которые могут конвертировать между CSV и JSON, такие как ConvertRecord. Поэтому я бы предложил написать собственный процессор, который ожидает JSON и использует ваши классы DAO с начальной загрузкой.