文件名称：lifion-kinesis:Amazon Kinesis Data Streams的本机Node.js生产者和使用者库
文件大小：211KB
文件格式：ZIP
更新时间：2024-05-31 22:07:25
client aws big-data amazon kinesis
*运动 Lifion的的Node.js客户端。 入门 要安装模块： npm install lifion-kinesis --save 主模块导出是一个Kinesis类，该类实例化为。 const Kinesis = require ( 'lifion-kinesis' ) ; const kinesis = new Kinesis ( { streamName : 'sample-stream' /* other options from AWS.Kinesis */ } ) ; kinesis . on ( 'data' , data => { console . log ( 'Incoming data:' , data ) ; } ) ; kinesis . startConsumer ( ) ; 为了利用背压，可以将客户端通过管道传递给可写流： const
【文件预览】：
lifion-kinesis-develop
----.gitignore(34B)
----.eslintrc(523B)
----templates()
--------CHANGELOG.hbs(699B)
--------README.hbs(2KB)
----package.json(3KB)
----jsconfig.json(310B)
----package-lock.json(340KB)
----.auto-changelog(70B)
----CODE_OF_CONDUCT.md(3KB)
----LICENSE(1KB)
----CHANGELOG.md(58KB)
----.github()
--------workflows()
--------dependabot.yml(418B)
----README.md(16KB)
----.eslintignore(29B)
----.lintstagedrc(116B)
----lib()
--------bucket.test.js(10KB)
--------polling-consumer.test.js(18KB)
--------heartbeat-manager.js(2KB)
--------polling-consumer.js(10KB)
--------kinesis-client.js(14KB)
--------table.js(5KB)
--------stats.js(5KB)
--------consumers-manager.js(7KB)
--------lease-manager.test.js(16KB)
--------state-store.test.js(44KB)
--------index.test.js(27KB)
--------compression.js(2KB)
--------index.js(26KB)
--------dynamodb-client.js(8KB)
--------fan-out-consumer.test.js(21KB)
--------__mocks__()
--------constants.test.js(314B)
--------records.js(9KB)
--------s3-client.js(8KB)
--------lease-manager.js(11KB)
--------utils.js(2KB)
--------deaggregate.js(3KB)
--------stream.test.js(12KB)
--------stats.test.js(4KB)
--------aggregate-protobuf.json(1KB)
--------state-store.js(29KB)
--------deaggregate.test.js(3KB)
--------utils.test.js(3KB)
--------dynamodb-client.test.js(5KB)
--------constants.js(927B)
--------kinesis-client.test.js(10KB)
--------stream.js(11KB)
--------fan-out-consumer.js(17KB)
--------records.test.js(14KB)
--------heartbeat-manager.test.js(4KB)
--------table.test.js(6KB)
--------compression.test.js(985B)
--------bucket.js(4KB)
--------consumers-manager.test.js(7KB)
--------s3-client.test.js(6KB)
----.jest.json(349B)
----.npmignore(64B)
----.husky()
--------pre-push(68B)
--------.gitignore(2B)
--------pre-commit(93B)
----.prettierrc(97B)