yum install -y mysql #在EC2的服务器里安装mysql主要是在服务器里做连接mysql用(mysql -h rds-instance-endpoint -u admin -P 3306 -p 12345678)
pip3 install --target ./ PyMySQL #安装pymysql模块在vscode本地里
import sys
import logging
import pymysql
#rds settings
rds_host = "rds-instance-endpoint"
name = "admin"
password = "12345678"
db_name = "user"
logger = logging.getLogger()
logger.setLevel(logging.INFO)
try:
conn = pymysql.connect(host=rds_host, 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 fetches content from MySQL RDS instance
"""
with conn.cursor() as cur:
cur.execute("create table Employee ( EmpID int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (EmpID))")
cur.execute('insert into Employee (EmpID, Name) values(1, "Joe")')
cur.execute('insert into Employee (EmpID, Name) values(2, "Bob")')
cur.execute('insert into Employee (EmpID, Name) values(3, "Mary")')
conn.commit()
cur.execute("select * from Employee")
conn.commit()
return (cur.fetchall())