如何在NiFi自定义处理器中启用表达式语言（EL）？

要让自定义处理器的动态属性支持表达式语言，需要完成以下关键步骤：

1. 重写getSupportedDynamicPropertyDescriptor方法 #

NiFi通过这个方法识别并处理动态属性，你需要在方法中为每个动态属性构建支持EL的PropertyDescriptor：

@Override
protected PropertyDescriptor getSupportedDynamicPropertyDescriptor(final String propertyName) {
    return new PropertyDescriptor.Builder()
        .name(propertyName)
        .description("动态属性：" + propertyName)
        .addValidator(Validators.NON_EMPTY_VALIDATOR) // 根据业务需求选择验证器，也可自定义
        .expressionLanguageSupported(true) // 核心配置：开启EL支持
        .dynamic(true)
        .build();
}

这里的expressionLanguageSupported(true)是关键，它告诉NiFi该动态属性允许使用表达式语言，从而避免UI中出现属性不支持EL的验证错误。

2. 在onTrigger中正确解析EL表达式 #

启用EL后，不能直接获取属性的原始字符串，必须通过ProcessContext的evaluateAttributeString方法解析表达式，传入当前FlowFile以获取实际值：

@Override
public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {
    FlowFile flowFile = session.get();
    if (flowFile == null) {
        return;
    }

    // 遍历所有动态属性并解析EL
    final Map<PropertyDescriptor, String> dynamicProperties = context.getProperties();
    for (Map.Entry<PropertyDescriptor, String> entry : dynamicProperties.entrySet()) {
        PropertyDescriptor prop = entry.getKey();
        // 解析EL得到实际值
        String resolvedValue = context.getProperty(prop).evaluateAttributeString(flowFile);
        // 在这里使用resolvedValue执行你的业务逻辑
    }

    // 后续的FlowFile流转等逻辑
    session.transfer(flowFile, REL_SUCCESS);
}

3. 可选：自定义动态属性验证器 #

如果需要对动态属性的EL表达式或解析后的值做特定校验，可以自定义Validator并应用到动态属性上：

private static final Validator CUSTOM_DYNAMIC_VALIDATOR = new Validator() {
    @Override
    public ValidationResult validate(final String subject, final String input, final ValidationContext context) {
        // 示例：校验属性值非空
        if (org.apache.commons.lang3.StringUtils.isBlank(input)) {
            return new ValidationResult.Builder()
                .subject(subject)
                .input(input)
                .valid(false)
                .explanation("动态属性值不能为空")
                .build();
        }
        return new ValidationResult.Builder()
            .subject(subject)
            .input(input)
            .valid(true)
            .build();
    }
};

然后在构建PropertyDescriptor时替换验证器：

.addValidator(CUSTOM_DYNAMIC_VALIDATOR)

内容的提问来源于stack exchange，提问作者Giorgi Tsiklauri