in use-cases/rag-pipeline/alloy-db-setup/src/alloydb_connect.py [0:0]
def getconn():
logger.info("Creating connection to database '%s' as user '%s'", db, user)
conn = connector.connect(
db=db,
driver="pg8000",
enable_iam_auth=True,
instance_uri=instance_uri,
ip_type=IPTypes.PSC,
user=user,
)
return conn