У меня есть csv-файлы, и я хочу переместить содержимое файлов вместе с его метаданными (имя файла, источник (быть жестко запрограммированным), контрольный номер (часть имени файла - для извлечения из самого имени файла), используя NiFi. Вот пример имени файла и макета -
Имя файла - 12345_user_data.csv (control_number_user_data.csv)
источник - Нью-Йорк
Содержимое файла CSV / столбцы -
Поля - abc1, abc2, abc3, abc4
значения - 1,2,3,4
Postgres Структура таблицы базы данных
Имя таблицы - User_Education
имя поля -
control_number, имя_файла, источник, abc1, abc2, abc3, abc4
Значения -
12345, 12345_user_data.csv, Newyork, 1,2,3,4
Я планирую использовать следующие процессоры -
ListFile
FetchFile
UpdateAttributes
PutDatabaseRecords
Журнал Атрибуты
Но я не уверен, как объединить фактический контент с метаданными для загрузки в одну таблицу. Пожалуйста, помогите