This Serverless-offline-kinesis plugin emulates AWS λ and Kinesis streams on your local machine. To do so, it listens Kinesis stream and invokes your handlers.
Features:
- Serverless Webpack support.
- Kinesis configurations: batchsize and startingPosition.
First, add serverless-offline-kinesis
to your project:
npm install serverless-offline-kinesis
Then inside your project's serverless.yml
file, add following entry to the plugins section before serverless-offline
(and after serverless-webpack
if presents): serverless-offline-kinesis
.
plugins:
- serverless-webpack
- serverless-offline-kinesis
- serverless-offline
Ths configuration of function of the plugin follows the serverless documentation.
functions:
myKinesisHandler:
handler: handler.compute
events:
- stream:
enabled: true
type: kinesis
arn: arn:aws:kinesis:eu-west-1:XXXXXX:stream/polls
batchSize: 10
startingPosition: TRIM_HORIZON
The configuration of aws.Kinesis
's client of the plugin is done by defining a custom: serverless-offline-kinesis
object in your serverless.yml
with your specific configuration.
You could use mhart's Kinesalite with the following configuration:
custom:
serverless-offline-kinesis:
apiVersion: '2013-12-02'
endpoint: http://0.0.0.0:4567
region: eu-west-1
accessKeyId: root
secretAccessKey: root
skipCacheInvalidation: false
readInterval: 500