35 lines
843 B
Python
35 lines
843 B
Python
import os
|
|
import psycopg2
|
|
import time
|
|
|
|
|
|
DB_USER = os.getenv("POSTGRES_USER");
|
|
DB_PASSWWORD = os.getenv("POSTGRES_PASSWORD");
|
|
DB_NAME = os.getenv("POSTGRES_DB");
|
|
DB_HOST = os.getenv("POSTGRES_HOST");
|
|
|
|
|
|
|
|
def connect_db():
|
|
while True:
|
|
try:
|
|
conn = psycopg2.connect(
|
|
host=DB_HOST,
|
|
database=DB_NAME,
|
|
user=DB_USER,
|
|
password=DB_PASSWWORD
|
|
)
|
|
print("Connected to the database successfully!")
|
|
return conn
|
|
except psycopg2.OperationalError as e:
|
|
print(f"Database connection failed: {e}")
|
|
time.sleep(3)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
print("starting app.")
|
|
conn = connect_db();
|
|
cursor = conn.cursor()
|
|
cursor.execute("SELECT postgis_full_version();")
|
|
|
|
print("obst", cursor.fetchone()); |