使用 DB 快照和 AWS Lambda 在 Amazon RDS for Oracle 上实现跨区域自动灾难恢复

{    "Version": "2012-10-17",    "Statement": [        {            "Effect": "Allow",            "Action": [                "logs:CreateLogGroup",                "logs:CreateLogStream",                "logs:PutLogEvents"            ],            "Resource": "arn:aws:logs:*:*:*"        },        {            "Action": [                "rds:AddTagsToResource",                "rds:CopyDBSnapshot",                "rds:CopyDBClusterSnapshot",                "rds:DeleteDBSnapshot",                "rds:CreateDBSnapshot",                "rds:CreateDBClusterSnapshot",                "rds:RestoreDBInstanceFromDBSnapshot",                "rds:Describe*",                "rds:ListTagsForResource"            ],            "Effect": "Allow",            "Resource": "*"        }    ]}

import botocore  import datetime  import re  import loggingimport boto3
region='us-west-1'  db_instance_class='db.m4.large'  db_subnet='default'  instances = ['master']
print('Loading function')
def lambda_handler(event, context):       source = boto3.client('rds', region_name=region)     for instance in instances:         try:             #timestamp1 = '{%Y-%m-%d %H:%M:%S}'.format(datetime.datetime.now())             timestamp1 = str(datetime.datetime.now().strftime('%Y-%m-%d-%H-%-M-%S')) + "lambda-snap"             snapshot = "{0}-{1}-{2}".format("mysnapshot", instance,timestamp1)             response = source.create_db_snapshot(DBSnapshotIdentifier=snapshot, DBInstanceIdentifier=instance)             print(response)         except botocore.exceptions.ClientError as e:             raise Exception("Could not create snapshot: %s" % e)

import boto3  import botocore  import datetime  import reimport json
SOURCE_REGION = 'us-west-1'  TARGET_REGION = 'us-east-1'  iam = boto3.client('iam')  instances = ['master']
print('Loading function')
def byTimestamp(snap):    if 'SnapshotCreateTime' in snap:    return datetime.datetime.isoformat(snap['SnapshotCreateTime'])  else:    return datetime.datetime.isoformat(datetime.datetime.now())
def lambda_handler(event, context):      print("Received event: " + json.dumps(event, indent=2))    account_ids = []    try:        iam.get_user()    except Exception as e:        account_ids.append(re.search(r'(arn:aws:sts::)([0-9]+)', str(e)).groups()[1])        account = account_ids[0]
    source = boto3.client('rds', region_name=SOURCE_REGION)
    for instance in instances:        source_instances = source.describe_db_instances(DBInstanceIdentifier= instance)        source_snaps = source.describe_db_snapshots(DBInstanceIdentifier=instance)['DBSnapshots']        source_snap = sorted(source_snaps, key=byTimestamp, reverse=True)[0]['DBSnapshotIdentifier']        source_snap_arn = 'arn:aws:rds:%s:%s:snapshot:%s' % (SOURCE_REGION, account, source_snap)        target_snap_id = (re.sub('rds:', '', source_snap))        print('Will Copy %s to %s' % (source_snap_arn, target_snap_id))        target = boto3.client('rds', region_name=TARGET_REGION)
        try:            response = target.copy_db_snapshot(            SourceDBSnapshotIdentifier=source_snap_arn,            TargetDBSnapshotIdentifier=target_snap_id,            CopyTags = True)            print(response)        except botocore.exceptions.ClientError as e:            raise Exception("Could not issue copy command: %s" % e)        copied_snaps = target.describe_db_snapshots(SnapshotType='manual', DBInstanceIdentifier=instance)['DBSnapshots']

import boto3  import botocore  import datetime  import re  import logging
region='us-east-1'  db_instance_class='db.m4.large' db_subnet='orcldbsng'  #db_subnet='subnet-12345d6a'instances = ['master']
print('Loading function')
def byTimestamp(snap):    if 'SnapshotCreateTime' in snap:    return datetime.datetime.isoformat(snap['SnapshotCreateTime'])  else:    return datetime.datetime.isoformat(datetime.datetime.now())
def lambda_handler(event, context):      source = boto3.client('rds', region_name=region)    for instance in instances:        try:            source_snaps = source.describe_db_snapshots(DBInstanceIdentifier = instance)['DBSnapshots']            print "DB_Snapshots:", source_snaps            source_snap = sorted(source_snaps, key=byTimestamp, reverse=True)[0]['DBSnapshotIdentifier']            snap_id = (re.sub( '-\d\d-\d\d-\d\d\d\d ?', '', source_snap))            print('Will restore %s to %s' % (source_snap, snap_id))            response = source.restore_db_instance_from_db_snapshot(DBInstanceIdentifier=snap_id,DBSnapshotIdentifier=source_snap,DBInstanceClass=db_instance_class,DBSubnetGroupName=db_subnet,MultiAZ=False,PubliclyAccessible=False)            print(response)
        except botocore.exceptions.ClientError as e:            raise Exception("Could not restore: %s" % e)

import jsonimport boto3from datetime import datetime, timedelta, tzinfo
class Zone(tzinfo):    def __init__(self,offset,isdst,name):        self.offset = offset        self.isdst = isdst        self.name = name    def utcoffset(self, dt):        return timedelta(hours=self.offset) + self.dst(dt)    def dst(self, dt):        return timedelta(hours=1) if self.isdst else timedelta(0)    def tzname(self,dt):        return self.name
UTC = Zone(10,False,'UTC')
# Setting the retention period to 6 days#retentionDate = datetime.now(UTC) - timedelta(days=6)retentionDate = datetime.now(UTC) 
def lambda_handler(event, context):    print("Connecting to RDS")    rds = boto3.setup_default_session(region_name='us-east-1')    client = boto3.client('rds')    snapshots = client.describe_db_snapshots(SnapshotType='manual',DBInstanceIdentifier='master')
    print('Deleting all DB Snapshots older than %s' % retentionDate)
    for i in snapshots['DBSnapshots']:        if i['SnapshotCreateTime'] < retentionDate:            print ('Deleting snapshot %s' % i['DBSnapshotIdentifier'])            client.delete_db_snapshot(DBSnapshotIdentifier=i['DBSnapshotIdentifier'])