diff --git a/lib/inputs/dynamodb-data.js b/lib/inputs/dynamodb-data.js index 9b98b37..96035c4 100644 --- a/lib/inputs/dynamodb-data.js +++ b/lib/inputs/dynamodb-data.js @@ -1,3 +1,5 @@ +const AWS = require('aws-sdk'); +const cloudwatch = new AWS.CloudWatch({ apiVersion: '2010-08-01' }); const dynamo = require('../dynamo'); const logger = require('../logger'); const timestamp = require('../timestamp'); @@ -16,6 +18,8 @@ module.exports = class DynamodbData { constructor(records) { this._records = (records || []).filter(rec => this.check(rec)); + logger.debug('Records for DynamoDB', { count: this._records.length }); + // organize into payloads and segments, grouping by key this.payloads = {}; this.segments = {}; diff --git a/package.json b/package.json index 68ae48b..a703fe5 100644 --- a/package.json +++ b/package.json @@ -40,7 +40,6 @@ }, "homepage": "https://github.com/PRX/analytics-ingest-lambda#readme", "devDependencies": { - "aws-sdk": "^2.802.0", "chai": "^4.2.0", "codecov": "^3.1.0", "dotenv": "^6.2.0", @@ -55,6 +54,7 @@ }, "dependencies": { "@google-cloud/bigquery": "2.0.6", + "aws-sdk": "^2.802.0", "follow-redirects": "^1.13.0", "ioredis": "^4.19.2", "ipaddr.js": "^2.0.0",