RDS

import sys
import logging
import pymysql
import json

# RDS settings
rds_host = "mysqlforlambda.cdipnbm2csku.us-west-2.rds.amazonaws.com"
user_name = "admin"
password = "password"
db_name = "ExampleDB"

logger = logging.getLogger()
logger.setLevel(logging.INFO)

# Create the database connection outside of the handler to allow connections
# to be re-used by subsequent function invocations.
try:
    conn = pymysql.connect(host=rds_host, user=user_name, passwd=password,
                            db=db_name, connect_timeout=5)
except pymysql.MySQLError as e:
    logger.error("ERROR: Unexpected error: Could not connect to MySQL instance.")
    logger.error(e)
    sys.exit()

logger.info("SUCCESS: Connection to RDS MySQL instance succeeded")

def lambda_handler(event, context):
    """
    This function creates a new RDS database table and writes records to it.
    """
    message = event['Records'][0]['body']
    data = json.loads(message)
    CustID = data['CustID']
    Name = data['Name']

    item_count = 0
    sql_string = f"insert into Customer (CustID, Name) values({CustID}, '{Name}')"

    with conn.cursor() as cur:
        cur.execute("create table if not exists Customer "
                    "( CustID int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (CustID))")
        cur.execute(sql_string)
        conn.commit()
        cur.execute("select * from Customer")
        logger.info("The following items have been added to the database:")
        for row in cur:
            item_count += 1
            logger.info(row)

    conn.commit()

    return "Added %d items to RDS MySQL table" % (item_count)

import sys
import logging
import pymysql
import json

# RDS settings
rds_host = "mysqlforlambda.cdipnbm2csku.us-west-2.rds.amazonaws.com"
user_name = "admin"
password = "password"
db_name = "ExampleDB"

logger = logging.getLogger()
logger.setLevel(logging.INFO)

# Create the database connection outside of the handler to allow connections
# to be re-used by subsequent function invocations.
try:
    conn = pymysql.connect(host=rds_host, user=user_name, passwd=password,
                            db=db_name, connect_timeout=5)
except pymysql.MySQLError as e:
    logger.error("ERROR: Unexpected error: Could not connect to MySQL instance.")
    logger.error(e)
    sys.exit()

logger.info("SUCCESS: Connection to RDS MySQL instance succeeded")

def lambda_handler(event, context):
    """
    This function creates a new RDS database table and writes records to it.
    """
    message = event['Records'][0]['body']
    data = json.loads(message)
    CustID = data['CustID']
    Name = data['Name']

    item_count = 0
    sql_string = f"insert into Customer (CustID, Name) values({CustID}, '{Name}')"

    with conn.cursor() as cur:
        cur.execute("create table if not exists Customer "
                    "( CustID int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (CustID))")
        cur.execute(sql_string)
        conn.commit()
        cur.execute("select * from Customer")
        logger.info("The following items have been added to the database:")
        for row in cur:
            item_count += 1
            logger.info(row)

    conn.commit()

    return "Added %d items to RDS MySQL table" % (item_count)

# Create a manual DB snapshot
aws rds create-db-snapshot \
    --db-instance-identifier mydatabase \
    --db-snapshot-identifier mydatabase-manual-snapshot

# Find the latest restorable time for point-in-time recovery
aws rds describe-db-instances \
    --db-instance-identifier mydatabase \
    --query "DBInstances[0].LatestRestorableTime"

# Restore a new DB instance from a snapshot (creates a new endpoint)
aws rds restore-db-instance-from-db-snapshot \
    --db-instance-identifier mydatabase-restored \
    --db-snapshot-identifier mydatabase-manual-snapshot

# List and then delete a manually created snapshot
aws rds describe-db-snapshots --db-instance-identifier mydatabase
aws rds delete-db-snapshot --db-snapshot-identifier mydatabase-manual-snapshot

# Create a manual DB snapshot
aws rds create-db-snapshot \
    --db-instance-identifier mydatabase \
    --db-snapshot-identifier mydatabase-manual-snapshot

# Find the latest restorable time for point-in-time recovery
aws rds describe-db-instances \
    --db-instance-identifier mydatabase \
    --query "DBInstances[0].LatestRestorableTime"

# Restore a new DB instance from a snapshot (creates a new endpoint)
aws rds restore-db-instance-from-db-snapshot \
    --db-instance-identifier mydatabase-restored \
    --db-snapshot-identifier mydatabase-manual-snapshot

# List and then delete a manually created snapshot
aws rds describe-db-snapshots --db-instance-identifier mydatabase
aws rds delete-db-snapshot --db-snapshot-identifier mydatabase-manual-snapshot