如何为NiFi EvaluateJsonPath传递动态属性处理数组数据？

要处理JSON中的members数组并将每个成员数据写入DataStax Astra，单靠EvaluateJsonPath无法直接拆分数组生成多个数据流，推荐以下流程：

1. 用SplitJson拆分数组 #

添加SplitJson处理器，配置Json Path Expression为$.members。该处理器会将原始FlowFile拆分为多个独立的FlowFile，每个FlowFile对应members数组中的一个成员对象，示例拆分后单个FlowFile内容：

{
    "id": "345",
    "full_name": "John",
    "role": "Front-End"
}

2. 用EvaluateJsonPath提取字段 #

在SplitJson之后添加EvaluateJsonPath处理器，通过动态属性提取单个成员的字段：

• 添加属性member_id，值为$.id
• 添加属性full_name，值为$.full_name
• 添加属性member_role，值为$.role
  这些属性会被注入到每个拆分后的FlowFile属性中，供后续API调用使用。

3. 调用DataStax Astra API写入数据 #

使用InvokeHTTP处理器完成数据写入：

• 设置HTTP Method为POST
• 填写Remote URL：{BaseURL}/api/rest/v1/keyspaces/{keyspaces_name}/tables/{table_name}/rows（替换占位符为你的Astra实例信息）
• 在HTTP Headers中配置认证和内容类型：
  • Authorization: Bearer <你的Astra认证令牌>
  • Content-Type: application/json
• 构造请求Payload，引用提取的属性生成JSON：

  {
      "id": "${member_id}",
      "full_name": "${full_name}",
      "role": "${member_role}"
  }
  

可选替代方案 #

如果需要更灵活的JSON处理，也可以使用JoltTransformJSON将数组展平，或者用ExecuteScript（Groovy/JavaScript）编写自定义逻辑拆分数组并处理数据，但SplitJson+EvaluateJsonPath的组合是最轻量化、易维护的方案。

内容的提问来源于stack exchange，提问作者Kien Nguyen