Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

Lambda 事件筛选

对于 Amazon Kinesis、Amazon DynamoDB 和 Amazon Simple Queue Service（Amazon SQS）事件源，您可以使用事件筛选来控制 Lambda 发送给函数进行处理的事件。例如，您可以定义筛选条件，以便仅处理具有状态代码 ERROR 的 Kinesis 流中的记录。

您可以为单个事件源定义最多五个不同的筛选条件。如果事件满足这五个筛选条件中的任意一个，则 Lambda 会将事件发送到您的函数。否则，Lambda 会丢弃该事件。事件要么符合筛选条件，要么不符合筛选条件。如果您使用的是批处理时段，则 Lambda 会对每个新事件应用筛选条件，以确定是否将其添加到当前批处理中。

事件筛选基础知识

筛选条件 (FilterCriteria) 对象是一个由筛选条件 (Filters) 列表组成的结构。每个筛选条件 (Filter) 是一个用于定义事件筛选模式 (Pattern) 的结构。Pattern 是 JSON 筛选条件规则的字符串表示。FilterCriteria 对象与以下示例类似：

{
   "Filters": [
        {
            "Pattern": "{ \"Metadata1\": [ rule1 ], \"data\": { \"Data1\": [ rule2 ] }}"
        }
    ]
}

为了更清楚起见，以下是在纯 JSON 中展开的筛选条件 Pattern 的值。

{
    "Metadata1": [ pattern1 ],
    "data": {
        "Data1": [ pattern2 ]
    }
}

FilterCriteria 对象具有三个主要部分：元数据属性、数据属性和筛选条件模式。例如，假设您从事件源收到一个与以下类似的 Kinesis 事件：

"kinesis": {
    "partitionKey": "1",
    "sequenceNumber": "49590338271490256608559692538361571095921575989136588898",
    "data": {
        "City": "Seattle",
        "State": "WA",
        "Temperature": "46",
        "Month": "December"
    },
    "approximateArrivalTimestamp": 1545084650.987
}

在创建 FilterCriteria 对象时，仅指定您想要筛选条件与之匹配的元数据属性和数据属性。要使 Lambda 将事件视为匹配项，事件必须包含筛选条件中包含的所有字段名称。Lambda 将会忽略筛选条件中未包含的字段。

筛选条件规则语法

对于筛选条件规则，Lambda 支持与 Amazon EventBridge 相同的语法和规则集。有关更多信息，请参阅《Amazon EventBridge 用户指南》中的 Amazon EventBridge 事件模式。

以下是可用于 Lambda 事件筛选的所有比较运算符的汇总。

筛选示例

假设您有一个 Kinesis 事件源，并且您希望函数只处理具有特定 partitionKey（元数据属性）的事件。此外，您只希望处理 Location 字段（数据属性）等于“Los Angeles”的事件。在这种情况下，您的 FilterCriteria 对象与以下类似：

{
   "Filters": [
        {
            "Pattern": "{ \"partitionKey\": [ \"1\" ], \"data\": { \"Location\": [ \"Los Angeles\" ] }}"
        }
    ]
}

为了更清楚起见，以下是在纯 JSON 中展开的筛选条件 Pattern 的值。

{
    "partitionKey": [ "1" ],
    "data": {
        "Location": [ "Los Angeles" ]
    }
}

上一个示例为 partitionKey 和 Location 使用了等于比较运算符。

在另一个示例中，假设您想要只处理 Temperature 数据属性大于 50，但小于等于 60 的事件。在这种情况下，您的 FilterCriteria 对象与以下类似：

{
   "Filters": [
        {
            "Pattern": "{ \"data\": { \"Temperature\": [ {\"numeric\": [ \">\", 50, \"<=\", 60 ] }]}"
        }
    ]
}

为了更清楚起见，以下是在纯 JSON 中展开的筛选条件 Pattern 的值。

{
    "data": {
        "Temperature": [ {"numeric": [ ">", 50, "<=", 60 ] } ]
    }
}

上一个示例为 Temperature 使用了数值（范围）用于比较运算符。

多层筛选

您还可以使用事件筛选来处理多层 JSON 筛选。例如，假设您收到一个 DynamoDB 流事件，其中包含与以下类似的数据对象：

"dynamodb": {
    "Keys": {
        "Id": {
            "N": "101"
        }
    },
    "NewImage": {
        "Message": {
            "S": "New item!"
        },
        "Id": {
            "N": "101"
        }
    },
    "SequenceNumber": "111",
    "SizeBytes": 26,
    "StreamViewType": "NEW_AND_OLD_IMAGES"
}

假设您只想处理键 ID 值 N 为 101 的事件。在这种情况下，您的 FilterCriteria 对象与以下类似：

{
   "Filters": [
        {
            "Pattern": "{ \"dynamodb\": { \"Keys\": { \"Id\": { \"N\": [ "101" ] } } } }"
        }
    ]
}

为了更清楚起见，以下是在纯 JSON 中展开的筛选条件 Pattern 的值。

{
    "dynamodb": {
        "Keys": {
            "Id": {
                "N": [ "101" ]
            }
        }
    }
}

上一个示例为 N 使用了等于比较运算符，它是嵌套在 dynamodb 数据字段中的多个层。

将筛选条件附加到事件源映射（控制台）

按照以下步骤使用 Lambda 控制台创建包含筛选条件的新事件源映射。

使用控制台输入筛选条件时，您只需提供筛选条件模式。在上述说明的第 6 步中，{ "a" : [ 1, 2 ] } 对应于下面的 FilterCriteria：

{
   "Filters": [
      {
          "Pattern": "{ \"a\" : [ 1, 2 ] }"
      }
   ]
}

在控制台中创建事件源映射后，您可以在触发器详细信息中看到格式化后的 FilterCriteria。请注意，在使用控制台输入筛选条件时，您无需提供 Pattern 键或转义引号。

将筛选条件附加到事件源映射（Amazon CLI）

假设您希望事件源映射具有以下 FilterCriteria：

{
   "Filters": [
      {
          "Pattern": "{ \"a\" : [ 1, 2 ] }"
      }
   ]
}

要使用 Amazon Command Line Interface（Amazon CLI）创建包含这些筛选条件的新事件源映射，请运行以下命令：

aws lambda create-event-source-mapping \
    --function-name my-function \
    --event-source-arn arn:aws:sqs:us-east-2:123456789012:my-queue \
    --filter-criteria "{\"Filters\": [{\"Pattern\": \"{ \"a\" : [ 1, 2 ]}\"}]}"

此 CreateEventSourceMapping 命令将为包含指定 FilterCriteria 的函数 my-function 创建新的 Amazon SQS 事件源映射。

要将这些筛选条件添加到现有事件源映射中，请运行以下命令：

aws lambda update-event-source-mapping \
    --uuid "a1b2c3d4-5678-90ab-cdef-11111EXAMPLE" \
    --filter-criteria "{\"Filters\": [{\"Pattern\": \"{ \"a\" : [ 1, 2 ]}\"}]}"

请注意，要更新事件源映射，您需要其 UUID。您可以通过 ListEventSourceMappings 调用获取 UUID。此外，Lambda 还会在CreateEventSourceMapping API 响应中返回 UUID。

要从事件源中删除筛选条件，您可以运行以下包含空 FilterCriteria 对象的 UpdateEventSourceMapping 命令：

aws lambda update-event-source-mapping \
    --uuid "a1b2c3d4-5678-90ab-cdef-11111EXAMPLE" \
    --filter-criteria "{}"

正确筛选 Amazon SQS 消息

如果 Amazon SQS 消息不符合您的筛选条件，Lambda 会自动从队列中删除该消息。您无需在 Amazon SQS 中手动删除这些消息。

对于 Amazon SQS，消息 body 可以是任何字符串。但如果您的 FilterCriteria 期望 body 为有效的 JSON 格式，则可能会导致问题。反之亦然 — 如果传入的消息 body 为有效的 JSON 格式，则在您的筛选条件期望 body 为纯字符串时，这可能会导致出现意外行为。

要避免此问题，请确保 FilterCriteria 中 body 的格式与您从队列中收到的消息中的 body 的期望格式一致。在筛选消息之前，Lambda 会自动评估传入消息 body 的格式以及 body 的筛选条件模式的格式。如果不一致，Lambda 将会删除此消息。下表汇总了此评估：

如果您的 FilterCriteria 不包括 body，则 Lambda 将会跳过此检查。

正确筛选 Kinesis 和 DynamoDB 消息

在筛选条件处理了 Kinesis 或 DynamoDB 记录后，流迭代器会跳过此记录。如果记录不符合筛选条件，您无需从事件源手动删除记录。保留期结束后，Kinesis 和 DynamoDB 会自动删除这些旧记录。如果您希望提前删除记录，请参阅更改数据保留期。

要正确筛选流事件源中的事件，数据字段和数据字段的筛选条件都必须为有效的 JSON 格式。（对于 Kinesis，数据字段为 data。对于 DynamoDB，数据字段为 dynamodb。） 如果任一字段不为有效的 JSON 格式，Lambda 将会丢弃消息或引发异常。下表汇总了具体行为：