基于动态accountId的Jolt Spec配置问题：获取用户onlineId与signinId

需求场景 #

输入为包含请求体（指定inputAccountId）和多组用户账户数据的JSON数组，需根据inputAccountId匹配对应的用户，返回其onlineId和signinId。原Jolt配置运行时触发java.lang.NullPointerException，尝试使用${requestedId}时被解析为数值类型，导致匹配失败。

输入示例 #

[
  {
    "request": {
      "body": {
        "inputAccountId": "1234"
      }
    }
  },
  {
    "accountId": "1234",
    "ageGroup": 3,
    "role": 1,
    "gender": "f",
    "signinId": "aa@aa.com",
    "onlineId": "one"
  },
  {
    "accountId": "1122",
    "ageGroup": 3,
    "role": 2,
    "gender": "f",
    "signinId": "bb@aa.com",
    "onlineId": "two"
  },
  {
    "accountId": "2211",
    "ageGroup": 1,
    "role": 1,
    "gender": "f",
    "signinId": "cc@aa.com",
    "onlineId": "three"
  }
]

修正后的Jolt配置 #

[
  // 提取请求的inputAccountId到顶层，同时整理用户数据到users数组
  {
    "operation": "shift",
    "spec": {
      "0": {
        "request": {
          "body": {
            "inputAccountId": "requestedId"
          }
        }
      },
      "*": {
        "$": {
          "0": {}, // 跳过第一个request元素
          "*": {
            "@2": "users[]"
          }
        }
      }
    }
  },
  // 确保requestedId为字符串类型，避免数值解析问题
  {
    "operation": "modify-overwrite-beta",
    "spec": {
      "requestedId": "=toString"
    }
  },
  // 匹配accountId与requestedId一致的用户，提取目标字段
  {
    "operation": "shift",
    "spec": {
      "users": {
        "*": {
          "accountId": {
            "@(3,requestedId)": {
              "@2,onlineId": "onlineId",
              "@2,signinId": "signInId"
            }
          }
        }
      }
    }
  }
]

配置说明 #

1. 第一个shift操作：

   • 定位数组第一个元素（索引0）中的request.body.inputAccountId，将其赋值给顶层的requestedId
   • 遍历数组所有元素，跳过第一个request元素，将其余用户数据统一收集到users数组中，便于后续批量匹配

2. modify-overwrite-beta操作：

   • 使用=toString转换器强制将requestedId转为字符串类型，避免Jolt自动将其解析为数值，导致与字符串类型的accountId匹配失败

3. 第二个shift操作：

   • 遍历users数组中的每个用户，通过@(3,requestedId)引用顶层的requestedId，匹配用户的accountId
   • 匹配成功时，提取该用户的onlineId和signinId到结果的顶层字段

输出结果 #

{
  "onlineId": "one",
  "signInId": "aa@aa.com"
}

原配置问题分析 #

• 原modify操作的路径@(3,request.body.inputAccountId)层级计算错误，因输入为数组结构，无法正确提取inputAccountId，触发空指针异常
• 原shift操作硬编码索引"1"仅处理第二个用户，无法覆盖所有用户数据；同时未使用正确的变量引用语法@(...)来匹配requestedId，导致匹配逻辑失效

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