71 lines
2.4 KiB
Python
71 lines
2.4 KiB
Python
"""Complete servers.domain_ltd depuis qualys_assets.fqdn.
|
|
|
|
Pour chaque serveur sans domain_ltd renseigne, extrait le domaine
|
|
(tout ce qui suit le 1er point) depuis le FQDN Qualys.
|
|
|
|
Ex: fqdn='vposapapp1.sanef.groupe' -> domain_ltd='sanef.groupe'
|
|
|
|
Usage:
|
|
python tools/import_domain_ltd_from_qualys.py [--dry-run] [--overwrite]
|
|
"""
|
|
import os
|
|
import argparse
|
|
from sqlalchemy import create_engine, text
|
|
|
|
DATABASE_URL = os.getenv("DATABASE_URL_DEMO") or os.getenv("DATABASE_URL") \
|
|
or "postgresql://patchcenter:PatchCenter2026!@localhost:5432/patchcenter_demo"
|
|
|
|
|
|
def main():
|
|
parser = argparse.ArgumentParser()
|
|
parser.add_argument("--dry-run", action="store_true")
|
|
parser.add_argument("--overwrite", action="store_true",
|
|
help="Remplace domain_ltd existant (sinon ne remplit que les vides)")
|
|
args = parser.parse_args()
|
|
|
|
engine = create_engine(DATABASE_URL)
|
|
print(f"[INFO] DB: {DATABASE_URL.split('@')[-1]}")
|
|
conn = engine.connect().execution_options(isolation_level="AUTOCOMMIT")
|
|
|
|
where_clause = "" if args.overwrite else "AND (s.domain_ltd IS NULL OR s.domain_ltd = '')"
|
|
|
|
rows = conn.execute(text(f"""
|
|
SELECT s.id as sid, s.hostname, s.domain_ltd, qa.fqdn
|
|
FROM servers s
|
|
JOIN qualys_assets qa ON (qa.server_id = s.id
|
|
OR LOWER(qa.hostname) = LOWER(s.hostname))
|
|
WHERE qa.fqdn IS NOT NULL
|
|
AND qa.fqdn != ''
|
|
AND qa.fqdn LIKE '%.%'
|
|
{where_clause}
|
|
""")).fetchall()
|
|
print(f"[INFO] {len(rows)} candidats")
|
|
|
|
updated = skipped = unchanged = 0
|
|
for r in rows:
|
|
# Extract domain = tout apres le 1er point du FQDN
|
|
parts = r.fqdn.split(".", 1)
|
|
if len(parts) != 2 or not parts[1]:
|
|
skipped += 1
|
|
continue
|
|
new_domain = parts[1].strip().lower()[:50]
|
|
if not new_domain:
|
|
skipped += 1
|
|
continue
|
|
if r.domain_ltd == new_domain:
|
|
unchanged += 1
|
|
continue
|
|
if args.dry_run:
|
|
print(f" DRY: {r.hostname:25s} {r.domain_ltd or '(vide)':20s} -> {new_domain}")
|
|
else:
|
|
conn.execute(text("UPDATE servers SET domain_ltd=:d WHERE id=:sid"),
|
|
{"d": new_domain, "sid": r.sid})
|
|
updated += 1
|
|
|
|
conn.close()
|
|
print(f"\n[DONE] Maj: {updated} | Inchanges: {unchanged} | Skip: {skipped}")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|