def connect_database()

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