pg8000 connect

.py

# Convert port to an int
db_port = int(db_port)

# Connect to the database
try:
    db_connection = pg8000.connect(user=db_user, host=db_host,port=db_port,database=db_database,password=db_pass)
    db_connection.autocommit = True
except Exception as e:
    logger.critical(
        'Unable to connect! Ensure $SRDBHOST, $SRDATABASE, $SRDBUSER and $SRDBPASS environmental variables are '
        'properly set\n{0}'.format(e))
    sys.exit(1)