ewen/ar_redadeg
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Revert "version avec boucle (test)"

Browse source 
This reverts commit 7c0a9f7b6d.
This commit is contained in:
MaelREBOUX 2021-11-07 07:47:23 +01:00
parent 7c0a9f7b6d
commit e7071c8507
1 changed files with 12 additions and 43 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

51
scripts_v2/phase_3_prepare.py
View file

@ -153,7 +153,7 @@ try:
# ------------------------------------------------------ # ------------------------------------------------------
print(" Suppression des données du secteur "+secteur) print(" Suppression des données du secteur "+secteur)
sql_delete = "DELETE FROM phase_3_troncons_pgr WHERE secteur_id = "+secteur +" ;" sql_delete = "DELETE FROM phase_3_troncons_pgr WHERE secteur_id = "+secteur +" ;"
#db_redadeg_cursor.execute(sql_delete) db_redadeg_cursor.execute(sql_delete)
print(" fait") print(" fait")
print("") print("")
@ -185,7 +185,7 @@ FROM
CROSS JOIN generate_series(0,10000) AS n CROSS JOIN generate_series(0,10000) AS n
WHERE n*"""+longueur_densification+"""/length < 1;""" WHERE n*"""+longueur_densification+"""/length < 1;"""
#db_redadeg_cursor.execute(sql_insert) db_redadeg_cursor.execute(sql_insert)
print(" fait") print(" fait")
print("") print("")
@ -209,56 +209,25 @@ reverse_cost =
END END
WHERE secteur_id = """ + secteur + """ ;""" WHERE secteur_id = """ + secteur + """ ;"""
#db_redadeg_cursor.execute(sql_update_costs) db_redadeg_cursor.execute(sql_update_costs)
# optimisation
db_redadeg_cursor.execute("VACUUM FULL phase_3_troncons_pgr ;")
print(" fait") print(" fait")
print("") print("")
# ------------------------------------------------------ # ------------------------------------------------------
print(" Création de la topologie pgRouting pour les tronçons nouvellement créés") print(" Création / maj de la topologie pgRouting pour les tronçons nouvellement créés")
db_redadeg_cursor.execute(f"SELECT MIN(id), MAX(id) FROM phase_3_troncons_pgr WHERE secteur_id = {secteur} ;") sql_create_pgr_topology = "SELECT pgr_createTopology('phase_3_troncons_pgr', 0.001, rows_where:='true', clean:=true);"
min_id, max_id = db_redadeg_cursor.fetchone() db_redadeg_cursor.execute(sql_create_pgr_topology)
nb_edges = max_id - min_id + 1
print(f" {nb_edges} tronçons à traiter")
# #estimation du temps de traitement avec 400 edges / s
# temps_sec = round(nb_edges/400)
# minutes, seconds = divmod(temps_sec, 60)
# print(f" temps de traitement évalué à {minutes} min et {seconds} sec")
# now = datetime.datetime.now()
# fin_sec = now.second + seconds
# fin_min = now.minute + minutes + 1
# fin_heure = now.hour
# print(f" donc fin estimée à {fin_heure}h{fin_min} maximum")
#
# print(" Début du traitement...")
# sql_create_pgr_topology = f"SELECT pgr_createTopology('phase_3_troncons_pgr', 0.000001, rows_where:='secteur_id={secteur}', clean:=true);"
# db_redadeg_cursor.execute(sql_create_pgr_topology)
# print(" fait")
# print("")
# on fait une boucle pour optimiser
interval = 10000
i = 1
for x in range(min_id, max_id + 1, interval):
db_redadeg_cursor.execute(
f"SELECT pgr_createTopology('phase_3_troncons_pgr', 0.000001, rows_where:='id>={x} and id<{x + interval}', clean := true);"
)
print(f" {interval*i} tronçons traités")
i += 1
# optimisation
print(" vacuum")
db_redadeg_cursor.execute("VACUUM FULL phase_3_troncons_pgr ;")
print(" fait") print(" fait")
print("") print("")
# ------------------------------------------------------ # ------------------------------------------------------
print(" Récupération id des nœuds de début et fin du secteur, et la longueur") print(" Récupération id des nœuds de début et fin du secteur, et la longueur")