如何从Netflix Conductor工作流/任务输出参数中提取状态码

HTTP任务调用成功时可直接从任务输出的response.statusCode字段拿到值为"200"的状态码；调用失败时状态码不会出现在常规响应字段中，仅会拼接在任务的reasonForIncompletion字符串字段内，可通过以下三种方案提取状态码并统一写入输出：

方案1：内置INLINE任务提取（无额外依赖，最推荐） #

不需要额外开发部署Worker，直接在工作流定义中追加内联处理任务，兼容成功/失败双场景：

• 处理逻辑：优先读取成功场景下的原生状态码字段，失败场景用正则匹配错误字符串中100-599区间的3位标准HTTP状态码
• 任务定义示例：

{
  "name": "parse_http_status",
  "taskReferenceName": "parse_http_status_ref",
  "type": "INLINE",
  "inputParameters": {
    "httpTaskOutput": "${your_http_task_ref.output}",
    "httpTaskReason": "${your_http_task_ref.reasonForIncompletion}"
  },
  "expression": "(function(){
    // 成功场景直接返回原生状态码
    if (httpTaskOutput?.response?.statusCode) {
      return {
        statusCode: Number(httpTaskOutput.response.statusCode),
        responseBody: httpTaskOutput.response.body
      }
    }
    // 失败场景正则提取状态码
    const statusMatch = httpTaskReason ? httpTaskReason.match(/\b[1-5]\d{2}\b/) : null;
    return {
      statusCode: statusMatch ? Number(statusMatch[0]) : null,
      rawErrorMsg: httpTaskReason,
      responseBody: httpTaskOutput?.response
    };
  })()"
}

配置完成后，工作流内所有后续节点都可以通过${parse_http_status_ref.output.statusCode}拿到统一格式的数值型状态码，不需要再区分成功失败分支做判断。

方案2：自定义HTTP Worker（生产高稳定场景适用） #

替换Conductor默认的系统HTTP任务实现，自定义Worker逻辑：

• 在HTTP调用的异常捕获逻辑中，直接从HTTP客户端抛出的响应异常对象中读取标准状态码字段，和成功场景保持一致，将statusCode字段直接写入任务输出
• 完全避免字符串正则匹配的误判问题，不会因为Conductor版本升级、异常提示文案调整导致提取逻辑失效，适合稳定性要求高的生产环境。

方案3：工作流输出参数直接转换（轻量场景适用） #

如果不想追加额外任务节点，可以直接在工作流根节点的outputParameters配置中，用Conductor内置表达式函数做提取，示例配置：

{
  "outputParameters": {
    "statusCode": "${function:ifElse($.your_http_task_ref.output.response.statusCode != null, $.your_http_task_ref.output.response.statusCode, function:regexExtract($.your_http_task_ref.reasonForIncompletion, '([1-5][0-9]{2})', 1))}"
  }
}

该方案需要确认当前使用的Conductor版本支持regexExtract等内置字符串处理函数，低版本环境可能不兼容。

注意：所有正则匹配逻辑必须限定状态码范围为100-599的3位数字，避免把异常信息中的任务ID片段、超时时间、错误编号等其他数字误识别为HTTP状态码。

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