Как обрабатывать потоковые события DynamoDB с помощью Chalice

Question

Я пишу проект, в котором мне нужно обрабатывать вставки и обновления таблицы DynamoDB в Chalice.Я вижу в Chalice обработку событий для SNS, SQS, планировщика, но не для таблицы DynamoDB.В настоящее время это не в чаше, но AWS определенно может это сделать.Что такое рекомендуемый обходной путь?

Я делаю это вручную, не вызывая, но это не так хорошо из-за разделения проблем и модульности

Я хотел бы иметь что-то вроде:

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

Мне нужно, чтобы моя функция domyligic () вызывалась при вставке события в таблицу 'mytable'

Answer 1

У вас есть несколько вариантов:

• Участие в проекте Chalice в GitHub для создания существующего предложения в Добавление поддержки потоковых событий Kinesis и DynamoDB .

• Используйте декоратор Chalice pure Lambda для создания вашего обработчика. Отдельно закодируйте логику для настройки этой лямбда-функции в потоке DynamoDB, используя boto3. Вы можете найти подробную информацию в Использование AWS Lambda с Amazon DynamoDB .