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": {
    "kinesisSchemaVersion": "1.0",
    "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（元数据属性）的事件。此外，您只希望处理 City 字段（数据属性）等于“Los Angeles”的事件。在这种情况下，您的 FilterCriteria 对象与以下类似：

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

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

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

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

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

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

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

{
    "kinesisSchemaVersion": [ {"prefix": "1."} ],
    "data": {
        "Temperature": [ {"numeric": [ ">", 50, "<=", 60 ] } ]
    }
}

上一个示例在 kinesisSchemaVersion 中使用开头对象比较运算符，并在 Temperature 中使用数字（范围）比较运算符。

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

按照以下步骤使用 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，消息 body 可以是任何字符串。但是，如果您的 FilterCriteria 希望 body 采用有效的 JSON 格式，则这可能会出现问题。相反的情况也是如此 — 如果传入的消息 body 采用有效的 JSON 格式，那么，在您的筛选条件希望 body 为纯字符串时，这可能会导致出现意外行为。

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

如果您未将 body 作为 FilterCriteria 的一部分包括在内，则 Lambda 将会跳过此检查。

正确筛选 Kinesis 和 DynamoDB 消息

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