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
|
import threading
import subprocess
def worker(host, dbtype, db, dbuser):
"""thread worker function"""
print(r"/home/myuser/python/scripts/refresh_vm/refresh_vm.sh {} {} {} {}".format(host, dbtype, db, dbuser))
cmd = r"/home/myuser/python/scripts/refresh_vm/refresh_vm.sh {} {} {} {}".format(host, dbtype, db, dbuser)
subprocess.run(cmd, shell=True)
def dbname():
with open("db_info.txt") as db_info:
return db_info.read().strip().split('\n')
threads = []
for dbname in dbname():
l = str(dbname).split(';')
#print(l)
host = l[0]
db = l[1][4:] if "PDB_" in l[1] else l[1]
dbtype = '-p' if "PDB_" in l[1] else '-s'
dbuser = l[2]
print(l, ' ==> {} | {} | {} | {}'.format(host, dbtype, db, dbuser))
t = threading.Thread(target=worker, args=(host, dbtype, db, dbuser,))
threads.append(t)
t.start()
print('-'*50) |
Partager