文件名称:kinesis-stream-consumer:用于构建来自Amazon Web Services(AWS)Kinesis流的流事件的强大AWS Lambda使用者的实用程序
文件大小:106KB
文件格式:ZIP
更新时间:2024-05-31 07:01:40
JavaScript
kinesis-stream-consumer v2.1.9 用于构建来自Amazon Web Services(AWS)Kinesis流的流事件的健壮AWS Lambda使用者的实用程序。 模块: kinesis-consumer.js模块用于配置和可靠使用AWS Kinesis流中的消息的实用程序和功能 kinesis-processing.js模块用于配置Kinesis流处理的实用程序,用于配置和确定Kinesis流使用者的处理行为 kinesis-identify.js模块Kinesis流使用者将使用的实用程序和功能来标识消息 kpl-deagg-async.js模块副本kpl-deagg.js一个新的承诺,返回deaggregateAsync基于函数deaggregate作用 依存关系 aws-stream-consumer-core模块-此Kinesis流使用者模块使用的通
【文件预览】:
kinesis-stream-consumer-master
----kinesis-processing.js(40KB)
----.gitignore(938B)
----README.md(10KB)
----test()
--------persisting.test.js(60KB)
--------batch-10-state.json(10KB)
--------batch-1-tasks-failed-state-2.json(1KB)
--------batch.test.js(75KB)
--------kinesis-consumer-handler.test.js(15KB)
--------kinesis-processing.test.js(105KB)
--------sequencing-none.test.js(11KB)
--------persisting-unseq.test.json(8KB)
--------kinesis-identify.test.js(19KB)
--------batch-1-task-x1-state-1.json(1KB)
--------kinesis-consumer-config.test.js(20KB)
--------sequencing-per-shard.test.js(34KB)
--------kinesis-consumer.unseq.test.js(161KB)
--------sequencing-per-key.test.js(34KB)
--------settings.test.js(19KB)
--------samples.js(15KB)
--------batch-1-task-x2-state-1.json(1KB)
--------persisting.test.json(5KB)
--------batch-1-task-x2-state-2.json(2KB)
--------kinesis-consumer.test.js(174KB)
--------batch-1-tasks-failed-state-1.json(1KB)
----LICENSE(11KB)
----CHANGES.md(2KB)
----default-kinesis-options.json(1KB)
----package.json(947B)
----kinesis-identify.js(9KB)
----kpl-deagg-async.js(7KB)
----.npmignore(979B)
----kinesis-consumer.js(12KB)
----package-lock.json(14KB)