Kinesis buffer to string

pull/218/head
Frostebite 2021-02-07 16:35:40 +00:00
parent b5a399ba08
commit 38525bbc33
2 changed files with 3 additions and 3 deletions

File diff suppressed because one or more lines are too long

View File

@ -131,7 +131,7 @@ class AWS {
}) })
.promise() .promise()
).ShardIterator; ).ShardIterator;
while ((await getTaskStatus()) === 'RUNNING') { while ((await getTaskStatus()) === 'RUNNING') {
const records = await kinesis const records = await kinesis
.getRecords({ .getRecords({
@ -140,7 +140,7 @@ class AWS {
.promise(); .promise();
iterator = records.NextShardIterator; iterator = records.NextShardIterator;
if (records.Records.length > 0){ if (records.Records.length > 0){
core.info(Buffer.from(records.Records[0].Data, 'base64').toString('utf-8')); core.info(Buffer.from(records.Records[0].Data.toString(), 'base64').toString('utf-8'));
} }
} }