backuplambda.py 文件源码

def snapshot_resource(self, resource, description, tags):

        aws_tagset = []
        for k in tags:
            aws_tagset.append({"Key": k, "Value": tags[k]})

        date = datetime.today().strftime('%d-%m-%Y-%H-%M-%S')
        snapshot_id = self.period + '-' + self.resolve_backupable_id(resource) + "-" + date + "-" + self.date_suffix

        if 'DBClusterIdentifier' in 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)