解读Mulesoft过滤映射代码并实现等效Python逻辑

你看到的这段不是Java代码，是MuleSoft专属的DataWeave转换脚本，是Mule流程里做数据格式转换的专用语言，具体执行逻辑拆解如下：

• 代码最终输出一个单键对象，键名为custListInqResponse
• 括号包裹的表达式块是该键对应的值，DataWeave中用括号包裹表达式代表直接执行表达式、将结果作为当前位置的内容
• 表达式分三步串行执行：
  1. 取当前消息负载payload中的custBasic字段，该字段一般为存储客户基础信息的数组
  2. 对数组做过滤：遍历每一条客户记录，用$指代当前遍历到的客户对象，保留taxId（税号）字段值和流程变量flowVars.varLoanAcctTaxId（贷款账户绑定的税号）完全相等的记录，过滤后得到匹配的客户子数组
  3. 对过滤后的子数组做结构映射：同样用$指代当前遍历的客户记录，每条记录只保留custPermId（客户永久ID）字段，丢弃其他冗余字段，最终生成仅含客户永久ID的对象数组
• 最终生成的结构等价于：{"custListInqResponse": [{"custPermId": "客户1ID"}, {"custPermId": "客户2ID"}...]}，列表内所有客户的税号都和目标税号完全匹配

实现逻辑和原DataWeave完全对齐，同时保留原代码默认的空值容错能力（字段缺失时不抛出异常），代码如下：

# 变量对应关系：target_tax_id 等价于 Mule流程里的flowVars.varLoanAcctTaxId
target_tax_id = "替换为实际业务中拿到的贷款账户对应税号"
# payload 等价于 Mule里的消息负载，替换为实际业务中拿到的入参/接口响应字典
payload = {}

# 核心逻辑：列表推导式先过滤、后映射，和原代码filter->map的执行顺序完全一致
matched_cust_list = [
    {"custPermId": single_cust.get("custPermId")}
    for single_cust in payload.get("custBasic", [])
    if single_cust.get("taxId") == target_tax_id
]

# 组装最终返回结构
final_result = {
    "custListInqResponse": matched_cust_list
}

实现说明：

• 采用列表推导式实现和原代码一致的「先过滤、再转换结构」的流程，执行顺序和返回结果完全对齐
• 用字典get方法做字段访问，和DataWeave默认的空安全行为一致：如果custBasic字段不存在、单条客户记录缺失taxId或custPermId字段，不会抛出KeyError，会按照空列表/空值处理，和原Mule代码运行表现一致
• 如果确认输入数据100%结构完整无缺失，可以把get写法替换为字典键索引写法（比如single_cust["taxId"]），执行效率更高但容错性下降

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