lifion-kinesis
Advanced tools
Comparing version 1.1.0 to 1.1.1
@@ -10,2 +10,8 @@ ## Changelog | ||
### v1.1.1 (2019-09-11) | ||
- [`#230`](https://github.com/lifion/lifion-kinesis/pull/230): bugfix: s3 config missing default values | ||
- [`#229`](https://github.com/lifion/lifion-kinesis/pull/229): Update dependency aws-sdk to ^2.526.0 | ||
- [`714f723`](https://github.com/lifion/lifion-kinesis/commit/714f7238b726fd7ebbe612220f8db6dd807cda9a): Upgrade aws-sdk | ||
### v1.1.0 (2019-09-09) | ||
@@ -12,0 +18,0 @@ |
@@ -142,13 +142,14 @@ /** | ||
let normData = typeof data !== 'string' ? JSON.stringify(data) : data; | ||
const nonS3KeysData = {}; | ||
if (data && typeof data === 'object') { | ||
Object.keys(data).forEach(key => { | ||
if (nonS3Keys.includes(key)) { | ||
nonS3KeysData[key] = data[key]; | ||
} | ||
}); | ||
} | ||
if (useS3ForLargeItems && s3Client && normData.length > largeItemThreshold * 1024) { | ||
const nonS3KeysData = {}; | ||
if (useS3ForLargeItems && s3Client && normData.length > largeItemThreshold * 1024) { | ||
if (data && typeof data === 'object') { | ||
Object.keys(data).forEach(key => { | ||
if (nonS3Keys.includes(key)) { | ||
nonS3KeysData[key] = data[key]; | ||
} | ||
}); | ||
} | ||
const s3ItemKey = `${streamName}-${shortUuid.generate()}.json`; | ||
@@ -155,0 +156,0 @@ const putData = await s3Client.putObject({ |
{ | ||
"name": "lifion-kinesis", | ||
"version": "1.1.0", | ||
"version": "1.1.1", | ||
"description": "Lifion client for Amazon Kinesis Data streams", | ||
@@ -52,3 +52,3 @@ "keywords": [ | ||
"async-retry": "^1.2.3", | ||
"aws-sdk": "^2.525.0", | ||
"aws-sdk": "^2.527.0", | ||
"aws4": "^1.8.0", | ||
@@ -55,0 +55,0 @@ "fast-deep-equal": "^2.0.1", |
229654
Updatedaws-sdk@^2.527.0