AWS Step Functions：如何比对不同数组中的元素

核心问题说明 #

你之前的States.ArrayContains用法错误——该函数的语法是States.ArrayContains(目标数组, 单个元素)，你传入整个Array1作为第二个参数，实际是在检查Array2中是否包含整个Array1数组，而非逐个元素比对。

方案一：用Step Functions内置组件实现（无需Lambda） #

通过Map组件遍历Array1的每个元素，逐个检查是否存在于Array2，再用States.Some/States.All判断结果：

状态机示例代码 #

{
  "Comment": "检查Array1与Array2的元素匹配情况",
  "StartAt": "CheckForMatches",
  "States": {
    "CheckForMatches": {
      "Type": "Map",
      "ItemProcessor": {
        "ProcessorConfig": {
          "Mode": "INLINE",
          "InlineProcessor": {
            "States": [
              {
                "Type": "Pass",
                "End": true,
                "Parameters": {
                  "isMatch.$": "States.ArrayContains($.Array2, $.Item)"
                }
              }
            ]
          }
        }
      },
      "ItemsPath": "$.Data.Array1",
      "Parameters": {
        "Array2.$": "$.Data.Array2",
        "Item.$": "$$.Map.Item.Value"
      },
      "ResultPath": "$.matchResults",
      "Next": "EvaluateResults"
    },
    "EvaluateResults": {
      "Type": "Pass",
      "End": true,
      "Parameters": {
        "hasAnyMatch.$": "States.Some($.matchResults[*].isMatch, $$.Item == true)",
        "hasAllMatches.$": "States.All($.matchResults[*].isMatch, $$.Item == true)"
      }
    }
  }
}

逻辑说明 #

1. Map组件遍历Array1的每个元素，将Array2和当前元素传入子状态机
2. 子状态机用States.ArrayContains检查当前元素是否在Array2中，返回布尔值
3. EvaluateResults步骤：
   • States.Some：判断是否至少有一个元素匹配
   • States.All：判断是否所有元素都匹配

方案二：用Lambda函数实现（更灵活） #

如果需要更复杂的匹配逻辑，可编写Lambda函数处理数组比对：

Lambda函数示例（Python） #

import json

def lambda_handler(event, context):
    # 从输入中提取两个数组
    array1 = event["Data"]["Array1"]
    array2 = event["Data"]["Array2"]
    
    # 转成集合提升查找效率
    array2_set = set(array2)
    
    # 计算匹配结果
    has_any_match = any(item in array2_set for item in array1)
    has_all_match = all(item in array2_set for item in array1)
    
    return {
        "hasAnyMatch": has_any_match,
        "hasAllMatches": has_all_match
    }

Step Functions调用Lambda的状态配置 #

"CheckWithLambda": {
  "Type": "Task",
  "Resource": "arn:aws:lambda:REGION:ACCOUNT_ID:function:YOUR_LAMBDA_FUNCTION_NAME",
  "End": true,
  "InputPath": "$"
}

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