Merge pull request #23 from markitx/dwkerwin-iam-role-compatibility

IAM role compatibility

Author: dylanlingelbach

lib/dynamo-backup.js

@@ -12,6 +12,7 @@ var Uploader = require('s3-streaming-upload').Uploader;
 var ReadableStream = require('./readable-stream');
 
 function DynamoBackup(options) {
+    var params = {};
     options = options || {};
     this.excludedTables = options.excludedTables || [];
     this.includedTables = options.includedTables;
@@ -21,16 +22,20 @@ function DynamoBackup(options) {
     this.stopOnFailure = options.stopOnFailure || false;
     this.base64Binary = options.base64Binary || false;
     this.saveDataPipelineFormat = options.saveDataPipelineFormat || false;
-    this.awsAccessKey = options.awsAccessKey || process.env.AWS_ACCESS_KEY_ID;
-    this.awsSecretKey = options.awsSecretKey || process.env.AWS_SECRET_ACCESS_KEY;
-    this.awsRegion = options.awsRegion || process.env.AWS_DEFAULT_REGION || 'us-east-1';
+    this.awsAccessKey = options.awsAccessKey;
+    this.awsSecretKey = options.awsSecretKey;
+    this.awsRegion = options.awsRegion;
     this.debug = Boolean(options.debug);
 
-    AWS.config.update({
-        accessKeyId: this.awsAccessKey,
-        secretAccessKey: this.secretAccessKey,
-        region: this.awsRegion
-    });
+    if (this.awsRegion) {
+        params.region = this.awsRegion;
+    }
+    if (this.awsAccessKey && this.awsSecretKey) {
+        params.accessKeyId = this.awsAccessKey;
+        params.secretAccessKey = this.awsSecretKey;
+    }
+
+    AWS.config.update(params);
 }
 
 util.inherits(DynamoBackup, events.EventEmitter);
@@ -49,15 +54,21 @@ DynamoBackup.prototype.backupTable = function (tableName, backupPath, callback)
         backupPath = self._getBackupPath();
     }
 
-    var upload = new Uploader({
-        accessKey: self.awsAccessKey,
-        secretKey: self.awsSecretKey,
-        region: self.awsRegion,
-        bucket: self.bucket,
-        objectName: path.join(backupPath, tableName + '.json'),
-        stream: stream,
-        debug: self.debug
-    });
+   var params = {};
+   if (self.awsRegion) {
+       params.region = self.awsRegion;
+   }
+   if (self.awsAccessKey && self.awsSecretKey) {
+        params.accessKey = self.awsAccessKey;
+        params.secretKey = self.awsSecretKey;
+    }
+
+   params.bucket = self.bucket;
+   params.objectName = path.join(backupPath, tableName + '.json');
+   params.stream = stream;
+   params.debug = self.debug;
+
+   var upload = new Uploader(params);
 
     var startTime = moment.utc();
     self.emit('start-backup', tableName, startTime);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dynamo-backup-to-s3",
-  "version": "0.4.1",
+  "version": "0.4.2",
   "author": "Dylan Lingelbach (https://github.com/dylanlingelbach)",
   "license": "MIT",
   "repository": {