Amazon DynamoDB Streams のレコードを Fluentd で扱いたい要件があり、ググっても見当たらなかったのでプラグインを実装してみました。 takus/fluent-plugin-dynamodb-streams 使い方 README に書いてある通りですが、こんな設定でお使いいただけます。他の Fluentd のプラグインと組み合わせることで、AWS Official Blog にある、Logstash + Elasticsearch のような用途にもお使いいただけるのではないかと思います。 <source> type dynamodb_streams stream_arn YOUR_DDB_STREAMS_ARN pos_file /var/lib/fluent/dynamodb_streams_table_name fetch_interval 1 fetch_