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

Question

我正在编写一个项目，需要在 Chalice 中处理 DynamoDB 表插入和更新。我在 SNS、SQS、调度程序而非 DynamoDB 表的 Chalice 事件处理中看到。目前它不在 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/

requirements.txt

chalice>=1.21

app.py

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