task that processes DynamoDB Stream and pushes onto a queue for onward processing - View it on GitHub