in codes/sample-backend-fastapi/app/main.py [0:0]
def connect_database(rds_host, rds_port, db_name, secret_value):
user_info = json.loads(secret_value)
user_name = user_info['username']
user_pw = user_info['password']
try:
conn = pymysql.connect(host=rds_host, port=rds_port, user=user_name, passwd=user_pw, 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()
else:
return conn