def create()

in db_schema/db_schema_lambda/main.py [0:0]


def create(event, context):
    """
    DB Schema creation/update Lambda function entry point
    """
    global resource_id

    logger.info(f'Retrieving database access information from Secrets Manager\'s secret: "{db_secret_name}"')
    secrets = get_db_secrets()
    db_name = secrets['dbname']
    db_conn_string = f"postgresql://{secrets['username']}:{secrets['password']}@{db_proxy_endpoint}:{secrets['port']}/{db_name}?sslmode=require"

    logger.info(f'Creating SQLAlchemy database engine for database: "{db_name}"')
    engine = create_db_engine(db_conn_string)

    logger.info(f'Creating or Updating DB schema for database: "{db_name}"')
    Base.metadata.create_all(engine)

    return f'{db_name}-schema'