Update app.py
Browse files
app.py
CHANGED
@@ -1,10 +1,22 @@
|
|
1 |
from flask import Flask, jsonify
|
2 |
import psycopg2
|
3 |
import os
|
|
|
4 |
|
5 |
app = Flask(__name__)
|
6 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
7 |
def connect_db():
|
|
|
8 |
try:
|
9 |
connection = psycopg2.connect(
|
10 |
dbname=os.getenv('POSTGRES_DB'),
|
@@ -28,8 +40,20 @@ def connect_db():
|
|
28 |
|
29 |
@app.route('/')
|
30 |
def home():
|
|
|
|
|
|
|
|
|
31 |
db_info = connect_db()
|
32 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
33 |
|
34 |
if __name__ == '__main__':
|
35 |
app.run(host='0.0.0.0', port=7860)
|
|
|
1 |
from flask import Flask, jsonify
|
2 |
import psycopg2
|
3 |
import os
|
4 |
+
import socket
|
5 |
|
6 |
app = Flask(__name__)
|
7 |
|
8 |
+
def check_port(host: str, port: int):
|
9 |
+
"""Check if a specific port on a host is open."""
|
10 |
+
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
|
11 |
+
sock.settimeout(1) # 1 second timeout
|
12 |
+
try:
|
13 |
+
sock.connect((host, port))
|
14 |
+
return True
|
15 |
+
except socket.error:
|
16 |
+
return False
|
17 |
+
|
18 |
def connect_db():
|
19 |
+
"""Attempt to connect to the PostgreSQL database and retrieve version info."""
|
20 |
try:
|
21 |
connection = psycopg2.connect(
|
22 |
dbname=os.getenv('POSTGRES_DB'),
|
|
|
40 |
|
41 |
@app.route('/')
|
42 |
def home():
|
43 |
+
# Check if PostgreSQL is running and port is open
|
44 |
+
db_running = check_port('localhost', 5432)
|
45 |
+
|
46 |
+
# Perform database connection test
|
47 |
db_info = connect_db()
|
48 |
+
|
49 |
+
result = {
|
50 |
+
"message": "Database Connection Test Results",
|
51 |
+
"database_running": db_running,
|
52 |
+
"port_open": db_running, # The same check, for clarity
|
53 |
+
"connection_result": db_info
|
54 |
+
}
|
55 |
+
|
56 |
+
return jsonify(result)
|
57 |
|
58 |
if __name__ == '__main__':
|
59 |
app.run(host='0.0.0.0', port=7860)
|