#apache-nifi
Вопрос:
используемый процессор GetFile -> SplitRecord ->> ConvertJSONToSQL ->>> PutSQL
Цель: Вставить динамическое значение в столбец базы данных с именем list_index Для вставки текущей даты в столбец базы данных дата Для вставки необработанных данных в столбец базы данных raw_data_text
Комментарии:
1. Можете ли вы предоставить некоторые примеры входных данных, определение таблицы и пример? Также вы пробовали PutDatabaseRecord вместо SplitRecord -> ConvertJSONToSQL ->> PutSQL? Это делает все это для вас
2. ввод: имя, фамилия, возраст, затем я динамически добавляю значение в list_index.
Ответ №1:
Откуда берется динамическое значение? Вместо этого попробуйте GetFile -> updateRecord ->> PutDatabaseRecord. updateRecord позволит вам добавить поле list_index с нужным значением (оно также может использовать язык выражений), а затем PutDatabaseRecord вставит все столбцы в виде строки для каждой записи.
Комментарии:
1. Динамическим значением должно быть получение его из csv-файла, например, получение номера позиции каждой записи в csv-файле перед вставкой в имя базы данных list_index.