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'