Proposed fix for issue #5

Author: nonspecialist

lambda/backuplambda.py

@@ -324,9 +324,22 @@ def snapshot_resource(self, resource, description, tags):
         date = datetime.today().strftime('%d-%m-%Y-%H-%M-%S')
         snapshot_id = self.period+'-'+self.resolve_backupable_id(resource)+"-"+date+"-"+self.date_suffix
 
-        current_snap = self.conn.create_db_snapshot(DBInstanceIdentifier=self.resolve_backupable_id(resource),
-                                                    DBSnapshotIdentifier=snapshot_id,
-                                                    Tags=aws_tagset)
+        if is_cluster(resource):
+            current_snap = self.conn.create_db_cluster_snapshot(
+                    DBClusterIdentifier=self.resolve_backupable_id(resource),
+                    DBClusterSnapshotIdentifier=snapshot_id,
+                    Tags=aws_tagset)
+        else:
+            current_snap = self.conn.create_db_snapshot(
+                    DBInstanceIdentifier=self.resolve_backupable_id(resource),
+                    DBSnapshotIdentifier=snapshot_id,
+                    Tags=aws_tagset)
+
+    def is_cluster(self, resource):
+        try:
+            return resource['DBClusterIdentifier'] is not None
+        except:
+            return False
 
     def list_snapshots_for_resource(self, resource):
         snapshots = self.conn.describe_db_snapshots(DBInstanceIdentifier=self.resolve_backupable_id(resource),