使用自托管Kafka的Lambda事件源映射过滤功能限制问询

我们通过事件源映射从自托管Kafka集群调用AWS Lambda函数，调用过程中需通过过滤确保仅处理相关消息。但当前Lambda的过滤机制仅支持简单过滤，不支持基于对象数组的过滤。

以下是我们尝试过的示例过滤规则：

Filter #1 - { "value": { "message": { "header": { "sourcePlatforms": [ { "recordKeepingSystem": ["CBA"] } ] } } } }
Filter #2 - { "value": { "message": { "header": { "publishingApplication": {"publisherApplicationDatabaseSchema": ["DV1"] } } } } }
Filter #3 - { "value": { "message": { "body": {"create": {"person": {"sourceSchemaName": ["DV1"] } } } } } }
Filter #4 - { "value": { "message": { "body": {"create": {"testCfg": ["DV1"] } } } } }

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