Атрибут процессора Apache NiFi JoltTransformJSON как спецификация толчка

Question

У меня есть процессор JoltTransformJSON. Я хочу использовать атрибут FlowFile (содержащий спецификацию Jolt) в качестве спецификации.

Когда я пытаюсь это сделать, возникает ошибка проверки «Указана спецификация JSON не в формате JSON».

Я использую NiFi 1.6

Можно ли указать спецификацию толчка в качестве атрибута?

Answer 1

Jolt Specification поддерживает NiFi Expression Language, но только для подстановки значений внутри спецификации. То есть:

Скажем, у вас есть атрибут NiFi: jolt.operation: shift вы можете ссылаться на него в спецификации как:

[
    {
        "operation" : ${jolt.operation},
        ...
        ...
    }
]

Вся спецификация не может быть отправлена ​​как атрибут потока файла, по крайней мере, на данный момент.