def _connect(self) -> None:
logger.info("initializing database connection:")
logger.info("host: %s", self.host)
logger.info("port: %s", self.port)
logger.info("dbname: %s", self.dbname)
try:
self.conn = psycopg2.connect(host=self.host,
port=self.port,
user=self.user,
password=self.password,
dbname=self.dbname,
connect_timeout=5)
self.conn.set_session(autocommit=True)
logger.info("successfully initialized database connection")
except psycopg2.Error as error:
logger.exception("unable to connect to database")
raise error
评论列表
文章目录