adminmpmcz/patchcenter
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Use autocommit mode to persist inserts immediately

Browse Source
This commit is contained in:
Pierre & Lumière 2026-04-14 13:43:25 +02:00
parent c6113bc537
commit b72f1244dd
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tools/import_sanef_assets.py
View File

@ -57,7 +57,8 @@ def main():
rows = list(reader) rows = list(reader)
print(f"[INFO] {len(rows)} lignes lues dans le CSV") print(f"[INFO] {len(rows)} lignes lues dans le CSV")
with engine.begin() as conn: conn = engine.connect().execution_options(isolation_level="AUTOCOMMIT")
try:
if args.truncate: if args.truncate:
print("[INFO] Nettoyage des tables référençant servers") print("[INFO] Nettoyage des tables référençant servers")
if not args.dry_run: if not args.dry_run:
@ -121,7 +122,6 @@ def main():
continue continue
try: try:
sp = conn.begin_nested()
conn.execute(text(""" conn.execute(text("""
INSERT INTO servers INSERT INTO servers
(hostname, fqdn, domain_ltd, os_family, os_version, machine_type, (hostname, fqdn, domain_ltd, os_family, os_version, machine_type,
@ -130,13 +130,10 @@ def main():
(:hostname, :fqdn, :domain_ltd, :os_family, :os_version, :machine_type, (:hostname, :fqdn, :domain_ltd, :os_family, :os_version, :machine_type,
:etat, :site, :vcenter_vm_name, :responsable_nom, :patch_owner_details) :etat, :site, :vcenter_vm_name, :responsable_nom, :patch_owner_details)
"""), params) """), params)
sp.commit()
inserted += 1 inserted += 1
if ip: if ip:
ip_map.append((hostname, ip)) ip_map.append((hostname, ip))
except Exception as e: except Exception as e:
try: sp.rollback()
except Exception: pass
print(f" [ERR] {hostname}: {str(e)[:200]}") print(f" [ERR] {hostname}: {str(e)[:200]}")
skipped += 1 skipped += 1
@ -153,6 +150,8 @@ def main():
except Exception: except Exception:
pass pass
finally:
conn.close()
print(f"[DONE] Inséré/mis à jour: {inserted} | Ignoré: {skipped}") print(f"[DONE] Inséré/mis à jour: {inserted} | Ignoré: {skipped}")