PutHDFS от NiFi, пользовательское имя файла на основе содержимого - PullRequest
Новая
       10

PutHDFS от NiFi, пользовательское имя файла на основе содержимого

0 голосов
/ 06 февраля 2020

В NiFi процессор PutHDFS используется для загрузки данных в каталог HDFS. Существует более 100 вариантов типов файлов (все в формате json). json начинается с типа файла. Этот тип файла должен быть сделан с префиксом имени файла. Как этого добиться? Пожалуйста, сообщите. 

{
"FILE_TYPE_1": [
        {
                "ORG_FIELD_1" : 38,
                "ORG_FIELD_2" : 1,
                "ORG_FIELD_3" : "Per Km",
                "ORG_FIELD_4" : "x1",
                "ORG_FIELD_5" : 1,
                "ORG_FIELD_6" : 10.0,
                "ORG_FIELD_7" : 0.0,
                "ORG_FIELD_8" : 0.0,
                "ORG_FIELD_9" : 96.0,
                "ORG_FIELD_10" : 0
        }
    ]
}

1 Ответ

1 голос
/ 07 февраля 2020

Вы можете использовать EvaluateJsonPath , чтобы получить префикс имени для атрибута, а затем использовать UpdateAttribute , чтобы изменить имя

...