aws-lambda-stream
Advanced tools
@@ -33,3 +33,3 @@ "use strict"; | ||
const adornKinesisMetrics = (uow, event) => { | ||
const time = `${uow.record.kinesis.approximateArrivalTimestamp}`; | ||
const time = `${uow.record.kinesis.approximateArrivalTimestamp}`.padEnd(14, '0'); | ||
uow.metrics = startUow(Number(`${time.substring(0, 10)}${time.substring(11)}`), event.Records.length); | ||
@@ -36,0 +36,0 @@ }; |
@@ -50,3 +50,3 @@ "use strict"; | ||
const assemble = opt => (head, includeFaultHandler = true) => { | ||
const keys = Object.keys(thePipelines); | ||
const keys = Object.keys(thePipelines).filter(k => !process.env.DISABLED_PIPELINES?.includes(k)); | ||
debug('assemble: %j', keys); | ||
@@ -53,0 +53,0 @@ if (includeFaultHandler) { |
{ | ||
"name": "aws-lambda-stream", | ||
"version": "1.0.14", | ||
"version": "1.0.15", | ||
"description": "Create stream processors with AWS Lambda functions.", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
218804
0.03%2
Infinity%175
0.57%