使用单表设计的Dynamodb流-仅处理特定的项目类型

Question

我一直在使用Dynamodb作为数据库构建一个无服务器应用程序，并且一直遵循单表设计模式（例如https://www.alexdebrie.com/posts/dynamodb-single-table/）。我开始遇到的问题是使用Dynamodb流——我希望能够使用Dynamodb流来保持Elasticsearch实例的最新状态。

在单个dynamodb表容纳大约10种不同类型的项目（将继续扩展）的那一刻，其中一种项目类型“事件”（如在体育赛事中）将被发送到弹性搜索实例，以进行复杂的查询/搜索。因此，需要通过流触发的lambda函数在Elasticsearch中更新对“事件”项的任何更改。

我正在努力的是，我将有一个lambda在任何表项的“更新”上被触发，但这也可能是其他9种项目类型之一的更新，我在lambda中可以检查已更新的项目并检查其类型等，但似乎浪费了任何项目类型的任何更新都会触发lambda，这可能比需要的次数要多得多。

有没有更好的方法来处理这一问题，以减少浪费，并且只针对一种项目类型？我认为，随着应用程序的增长，需要更多的流触发器，至少会有一个“更新”lambda已经被触发，我可以运行一些逻辑，看看什么类型的项目被更新，但我只是担心我错过了一点东西。

Answer 1

不幸的是，您描述的方法是处理DynamoDb流的唯一方法。我自己也走了同样的路，认为这可能不是正确的用法，但这是处理流的唯一方法。

Answer 2

可以使用Lambda事件过滤。这将允许您防止特定事件调用您的函数。在单表DynamoDB设计模式中，只能过滤出类型为：EVENT的记录。

如果您碰巧使用了无服务器框架，下面的yaml代码片段将展示如何轻松实现此功能。

functionName:
  handler: src/functionName/function.handler
  # other properties
  events:
  - stream:
      type: dynamodb
      arn: !GetAtt DynamoDbTable.StreamArn
      maximumRetryAttempts: 1
      batchSize: 1
      filterPatterns:
        - eventName: [MODIFY]
          dynamodb:
             MyTableName:
               type:
                 S: [EVENT]

注意存在多个比较运算符，例如以开头，即[{"prefix"："EVENT"}]~有关更多信息，请参阅过滤器规则语法。

• 来源Pawel Zubkiewicz在Dev.to