Decode kinesis data

2021-02-07 18:34:17 +00:00 · 2021-02-07 18:34:17 +00:00 · 5b3ccf0f5f
parent 61d644c032
commit 5b3ccf0f5f
2 changed files with 3 additions and 2 deletions
--- a/action/index.js
+++ b/action/index.js
--- a/src/model/aws.js
+++ b/src/model/aws.js
@ -144,7 +144,8 @@ class AWS {
      iterator = records.NextShardIterator;
      if (records.Records.length > 0) {
        for (let index = 0; index < records.Records.length; index++) {
-          const record = records.Records[index].Data;
+          const record = records.Records[index].Data.toString();
+          core.info(records.Records[index]);
          core.info(Buffer.from(record, 'base64').toString('ascii'));
        }
      }