Apache NiFi dynamici c атрибуты для процессора PutDatabaseRecord - PullRequest
Новая
       103

Apache NiFi dynamici c атрибуты для процессора PutDatabaseRecord

0 голосов
/ 13 января 2020

У меня есть этот поток в NiFi:

GetFile -> ConvertExcelToCSVProcessor -> ReplaceText -> PutDatabaseRecord.

Работает нормально, но я хочу установить "имя таблицы "свойство

PutDatabaseRecord

, основанное на имени файла CSV (и, если возможно, настроить его). Я не могу найти ничего в документах или в Интернете. Спасибо!

1 Ответ

1 голос
/ 13 января 2020

Согласно документации, параметр table name процессора PutDatabaseRecord поддерживает язык выражений nifi .

Итак, если атрибут filename вашего потока Файл содержит значение MyTableName.csv. Вы можете использовать выражение с регулярным выражением для преобразования имени файла в имя таблицы в процессоре PutDatabaseRecord следующим образом: 

Table Name = ${filename:replaceAll('\\..*','')}
...