in functions/source/CreateDatabase/handler.py [0:0]
def create(event, context):
logger.info("Got Create")
# Connect to PostgreSQL DBMS
database, cursor = createConnection(event)
# check if database exist
cursor.execute("SELECT datname FROM pg_database;")
list_database = cursor.fetchall()
if (database,) in list_database:
logger.info(f"Database {database} exist, skip create")
else:
# Create database
cursor.execute(f"create database {database};")
logger.info("Complete create")