如何使用 Chalice 处理 DynamoDB 流事件

Question

我正在编写一个项目，需要在 Chalice 中处理 DynamoDB 表插入和更新。我在 SNS、SQS、调度程序的 Chalice 事件处理中看到，但没有看到 DynamoDB 表。目前它不在圣杯中，但 AWS 绝对可以做到。什么是推荐的解决方法？我在没有触发的情况下手动执行但由于关注点和模块化的分离而没有那么好我想要它像：@app.on_dynamodb_table_trigger(table='mytable', event='insert')def myhandler(event):    for record in event:        domyligic()我需要在将事件插入表“mytable”时调用我的 domyligic() 函数

Answer 1

您有几个选择：

• 为 GitHub 中的 Chalice 项目做出贡献，以构建现有提案，以添加对 Kinesis 和 DynamoDB 流事件的支持。

• 使用 Chalice纯 Lambda 函数装饰器来创建您的处理程序。使用 boto3 单独编码逻辑以在 DynamoDB 流上配置此 Lambda 函数。您可以在将 AWS Lambda 与 Amazon DynamoDB 结合使用中找到详细信息。

Answer 2

此功能已于 2020 年 10 月 2 日添加到 Chalice：

https://aws.amazon.com/blogs/developer/aws-chalice-now-supports-amazon-kinesis-and-amazon-dynamodb-streams/

要求.txt

chalice>=1.21

应用程序

@app.on_dynamodb_record(stream_arn=os.environ['TABLE_STREAM_ARN'])

def on_table_update(event):

    for record in event:

        process_record(record)