-
Notifications
You must be signed in to change notification settings - Fork 0
/
api.py
94 lines (73 loc) · 3.35 KB
/
api.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
from flask import Flask, jsonify
from datetime import datetime
import psycopg2
app = Flask(__name__)
# Informations de connexion à la base de données PostgreSQL
db_host = "localhost"
db_port = "5432"
db_name = "medical_crawler"
db_user = "crawler"
db_password = "bG9jYWxob3N0"
@app.route('/urls', methods=['GET'])
def get_urls():
try:
# Connexion à la base de données
conn = psycopg2.connect(host=db_host, port=db_port, database=db_name, user=db_user, password=db_password)
cursor = conn.cursor()
# Récupération des URLs et des champs "dom" à partir de la table "urls"
cursor.execute("SELECT url, dom, turn, turn_time FROM urls")
rows = cursor.fetchall()
# Fermeture de la connexion à la base de données
cursor.close()
conn.close()
# Conversion des résultats en une liste de dictionnaires
urls_list = [{'url': row[0], 'dom': row[1], 'turn': row[2], 'turn_time': row[3]} for row in rows]
# Retourne les URLs sous forme de JSON
return jsonify(urls_list)
except (Exception, psycopg2.Error) as error:
print("Erreur lors de la connexion à PostgreSQL :", error)
return jsonify({'error': 'Erreur lors de la connexion à la base de données'})
@app.route('/urls/without-dom', methods=['GET'])
def get_urls_without_dom():
try:
# Connexion à la base de données
conn = psycopg2.connect(host=db_host, port=db_port, database=db_name, user=db_user, password=db_password)
cursor = conn.cursor()
# Récupération des URLs et des champs "dom" à partir de la table "urls"
cursor.execute("SELECT url, turn, turn_time FROM urls")
rows = cursor.fetchall()
# Fermeture de la connexion à la base de données
cursor.close()
conn.close()
# Conversion des résultats en une liste de dictionnaires
urls_list = []
for row in rows:
urls_list.append({'url': row[0], 'turn': row[1], 'turn_time': row[2]})
# Retourne les URLs sous forme de JSON
return jsonify({'pages_nb': len(urls_list), 'urls': urls_list})
except (Exception, psycopg2.Error) as error:
print("Erreur lors de la connexion à PostgreSQL :", error)
return jsonify({'error': 'Erreur lors de la connexion à la base de données'})
@app.route('/urls/pages_nb', methods=['GET'])
def get_urls_pages_nb():
try:
# Connexion à la base de données
conn = psycopg2.connect(host=db_host, port=db_port, database=db_name, user=db_user, password=db_password)
cursor = conn.cursor()
# Récupération des URLs et des champs "dom" à partir de la table "urls"
cursor.execute("SELECT url FROM urls")
rows = cursor.fetchall()
# Fermeture de la connexion à la base de données
cursor.close()
conn.close()
# Conversion des résultats en une liste de dictionnaires
urls_list = []
for row in rows:
urls_list.append({'url': row[0]})
# Retourne les URLs sous forme de JSON
return jsonify({'pages_nb': len(urls_list)})
except (Exception, psycopg2.Error) as error:
print("Erreur lors de la connexion à PostgreSQL :", error)
return jsonify({'error': 'Erreur lors de la connexion à la base de données'})
if __name__ == '__main__':
app.run(debug=True)