python - 如何使用 Chalice 处理 DynamoDB 流事件

Question

我正在编写一个项目，我需要在 Chalice 中处理 DynamoDB 表插入和更新。我在 Chalice 事件处理中看到了 SNS、SQS、调度程序，但没有看到 DynamoDB 表。目前它不在 Chalice 中，但 AWS 绝对可以做到。推荐的解决方法是什么？

我在没有触发的情况下手动完成，但由于关注点和模块化的分离，它不是那么好

我想要这样的东西：

@app.on_dynamodb_table_trigger(table='mytable', event='insert')
def myhandler(event):
    for record in event:
        domyligic()

我需要在将事件插入表'mytable'时调用我的domyligic（）函数

Answer 1

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

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

要求.txt

chalice>=1.21

应用程序.py

@app.on_dynamodb_record(stream_arn=os.environ['TABLE_STREAM_ARN'])
def on_table_update(event):
    for record in event:
        process_record(record)

Answer 2

你有几个选择：

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

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