Compare commits
8 Commits
1a63a81555
...
master
Author | SHA1 | Date | |
---|---|---|---|
524aef91f9 | |||
84834a228f | |||
f081522e1e | |||
441fbd22d2 | |||
0f3c332923 | |||
4b11e407be | |||
32bfaa523f | |||
244cc1a716 |
@ -10,7 +10,7 @@ from collections import OrderedDict
|
|||||||
|
|
||||||
def display_help():
|
def display_help():
|
||||||
print("Modification de la valeur d'une variable d'un serveur")
|
print("Modification de la valeur d'une variable d'un serveur")
|
||||||
print("{} [--d domain --integration --save]".format(sys.argv[0]))
|
print("{} [--d domain --integration --save --no-save]".format(sys.argv[0]))
|
||||||
|
|
||||||
|
|
||||||
def argparser():
|
def argparser():
|
||||||
@ -20,6 +20,8 @@ def argparser():
|
|||||||
integration = None
|
integration = None
|
||||||
if "--save" in sys.argv:
|
if "--save" in sys.argv:
|
||||||
save = True
|
save = True
|
||||||
|
if "--no-save" in sys.argv:
|
||||||
|
save = False
|
||||||
if "--integration" in sys.argv:
|
if "--integration" in sys.argv:
|
||||||
integration = True
|
integration = True
|
||||||
if arglen == 1:
|
if arglen == 1:
|
||||||
@ -71,11 +73,15 @@ def main():
|
|||||||
output = os.popen(cmd)
|
output = os.popen(cmd)
|
||||||
res = output.read().strip()
|
res = output.read().strip()
|
||||||
output.close()
|
output.close()
|
||||||
|
|
||||||
to_save = ""
|
to_save = ""
|
||||||
if not save :
|
if save if None:
|
||||||
to_save = raw_input("Souhaitez vous sauvegarder la configuration sur Zephir ? (O/N) ")
|
to_save = raw_input("Souhaitez vous sauvegarder la configuration sur Zephir ? (O/N) ")
|
||||||
if to_save == "O":
|
if to_save == "O":
|
||||||
save = True
|
save = True
|
||||||
|
print("Sauvegarde de la configuration sur zephir")
|
||||||
|
else:
|
||||||
|
print("La configuration ne sera pas sauvegardé sur le zephir")
|
||||||
if save:
|
if save:
|
||||||
cmd="""/usr/share/zephir/scripts/zephir_client save_files"""
|
cmd="""/usr/share/zephir/scripts/zephir_client save_files"""
|
||||||
output = os.popen(cmd)
|
output = os.popen(cmd)
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
|
|
||||||
import sys, getpass, socket, cjson, os
|
import sys, getpass, socket, cjson, os
|
||||||
from pyeole.ihm import print_line
|
from pyeole.ihm import print_line, question_ouinon
|
||||||
from pyeole.ansiprint import print_orange, print_red
|
from pyeole.ansiprint import print_orange, print_red
|
||||||
from creole.client import CreoleClient
|
from creole.client import CreoleClient
|
||||||
from collections import OrderedDict
|
from collections import OrderedDict
|
||||||
@ -10,15 +10,17 @@ from collections import OrderedDict
|
|||||||
|
|
||||||
def display_help():
|
def display_help():
|
||||||
print("Modification de la valeur d'une variable d'un serveur")
|
print("Modification de la valeur d'une variable d'un serveur")
|
||||||
print("{} [--var nom_variable --value valeur --save]".format(sys.argv[0]))
|
print("{} [--var nom_variable --value valeur --save --no-save]".format(sys.argv[0]))
|
||||||
|
|
||||||
|
|
||||||
def argparser():
|
def argparser():
|
||||||
# récupère l'ID du groupe
|
# récupère l'ID du groupe
|
||||||
arglen = len(sys.argv)
|
arglen = len(sys.argv)
|
||||||
save = False
|
save = None
|
||||||
if "--save" in sys.argv:
|
if "--save" in sys.argv:
|
||||||
save = True
|
save = True
|
||||||
|
if "--no-save" in sys.argv:
|
||||||
|
save = False
|
||||||
if arglen == 1:
|
if arglen == 1:
|
||||||
return None, None, save
|
return None, None, save
|
||||||
|
|
||||||
@ -64,10 +66,13 @@ def main():
|
|||||||
fh.write(cjson.encode(store))
|
fh.write(cjson.encode(store))
|
||||||
fh.close()
|
fh.close()
|
||||||
|
|
||||||
if not save :
|
if save is None :
|
||||||
to_save = raw_input("Souhaitez vous sauvegarder la configuration sur Zephir ? (O/N) ")
|
if question_ouinon("Souhaitez vous sauvegarder la configuration sur Zephir ?", default='non') == 'oui':
|
||||||
if to_save == "O":
|
print("Sauvegarde de la configuration sur zephir")
|
||||||
save = True
|
save=True
|
||||||
|
else:
|
||||||
|
print("La configuration ne sera pas sauvegardé sur zephir")
|
||||||
|
|
||||||
if save:
|
if save:
|
||||||
cmd="""/usr/share/zephir/scripts/zephir_client save_files"""
|
cmd="""/usr/share/zephir/scripts/zephir_client save_files"""
|
||||||
output = os.popen(cmd)
|
output = os.popen(cmd)
|
||||||
|
@ -85,6 +85,8 @@ def main():
|
|||||||
group_id = None
|
group_id = None
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
liste_serveurs = groups[group_id][1]
|
liste_serveurs = groups[group_id][1]
|
||||||
|
else:
|
||||||
|
liste_serveurs = groups[group_id][1]
|
||||||
|
|
||||||
if user is None:
|
if user is None:
|
||||||
user = flushed_input("Utilisateur : ")
|
user = flushed_input("Utilisateur : ")
|
||||||
@ -92,6 +94,8 @@ def main():
|
|||||||
ret = proxy.serveurs.authorize_user(user,liste_serveurs)
|
ret = proxy.serveurs.authorize_user(user,liste_serveurs)
|
||||||
|
|
||||||
print('Utilisateur {} autorisé à accéder en ssh aux serveurs {}'.format(user, liste_serveurs))
|
print('Utilisateur {} autorisé à accéder en ssh aux serveurs {}'.format(user, liste_serveurs))
|
||||||
|
print("Excecuter le script exec_script_group [id_group] -s call pour pour envoyer la configuration aux serveurs")
|
||||||
|
|
||||||
|
|
||||||
def make_group():
|
def make_group():
|
||||||
cx_pool = CxPool()
|
cx_pool = CxPool()
|
||||||
|
@ -61,7 +61,7 @@ def main():
|
|||||||
print('Liste des groupes :')
|
print('Liste des groupes :')
|
||||||
for grp_id, group_infos in groups.items():
|
for grp_id, group_infos in groups.items():
|
||||||
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
||||||
print( ' - N : Créer un nouveau groupe')
|
print( ' - N : Créer un nouveau groupe')
|
||||||
while group_id is None:
|
while group_id is None:
|
||||||
tmp_group_id = flushed_input("Numéro du groupe : ")
|
tmp_group_id = flushed_input("Numéro du groupe : ")
|
||||||
if tmp_group_id == 'N':
|
if tmp_group_id == 'N':
|
||||||
@ -78,6 +78,8 @@ def main():
|
|||||||
group_id = None
|
group_id = None
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
liste_serveurs = groups[group_id][1]
|
liste_serveurs = groups[group_id][1]
|
||||||
|
else:
|
||||||
|
liste_serveurs = groups[group_id][1]
|
||||||
for id_serv in liste_serveurs :
|
for id_serv in liste_serveurs :
|
||||||
ret = proxy.serveurs.del_serveur(id_serv)
|
ret = proxy.serveurs.del_serveur(id_serv)
|
||||||
if ret[1]:
|
if ret[1]:
|
||||||
|
@ -46,7 +46,7 @@ def argparser():
|
|||||||
script = sys.argv[3]
|
script = sys.argv[3]
|
||||||
return group_id, script, None
|
return group_id, script, None
|
||||||
|
|
||||||
if sys.argv[4] in ['-p', '--params']:
|
if sys.argv[4] in ['-a', '--args']:
|
||||||
varc = sys.argv[5]
|
varc = sys.argv[5]
|
||||||
return group_id, script, params
|
return group_id, script, params
|
||||||
|
|
||||||
@ -74,7 +74,7 @@ def main():
|
|||||||
print('Liste des groupes :')
|
print('Liste des groupes :')
|
||||||
for grp_id, group_infos in groups.items():
|
for grp_id, group_infos in groups.items():
|
||||||
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
||||||
print( ' - N : Créer un nouveau groupe')
|
print( ' - N : Créer un nouveau groupe')
|
||||||
while group_id is None:
|
while group_id is None:
|
||||||
tmp_group_id = flushed_input("Numéro du groupe : ")
|
tmp_group_id = flushed_input("Numéro du groupe : ")
|
||||||
if tmp_group_id == 'N':
|
if tmp_group_id == 'N':
|
||||||
@ -91,13 +91,15 @@ def main():
|
|||||||
group_id = None
|
group_id = None
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
liste_serveurs = groups[group_id][1]
|
liste_serveurs = groups[group_id][1]
|
||||||
|
else:
|
||||||
|
liste_serveurs = groups[group_id][1]
|
||||||
if script is None:
|
if script is None:
|
||||||
script = flushed_input("Script à executer : ")
|
script = flushed_input("Script à executer : ")
|
||||||
if params is None:
|
if params is None:
|
||||||
params = flushed_input("Paramètres : ")
|
params = flushed_input("Paramètres : ")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if params is None: params = ""
|
||||||
ret = proxy.uucp.exec_script(liste_serveurs, script, params)
|
ret = proxy.uucp.exec_script(liste_serveurs, script, params)
|
||||||
|
|
||||||
# on affiche les erreurs si nécessaire
|
# on affiche les erreurs si nécessaire
|
||||||
|
@ -70,7 +70,7 @@ def main():
|
|||||||
print('Liste des groupes :')
|
print('Liste des groupes :')
|
||||||
for grp_id, group_infos in groups.items():
|
for grp_id, group_infos in groups.items():
|
||||||
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
||||||
print( ' - N : Créer un nouveau groupe')
|
print( ' - N : Créer un nouveau groupe')
|
||||||
while group_id is None:
|
while group_id is None:
|
||||||
tmp_group_id = flushed_input("Numéro du groupe : ")
|
tmp_group_id = flushed_input("Numéro du groupe : ")
|
||||||
if tmp_group_id == 'N':
|
if tmp_group_id == 'N':
|
||||||
@ -87,6 +87,8 @@ def main():
|
|||||||
group_id = None
|
group_id = None
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
liste_serveurs = groups[group_id][1]
|
liste_serveurs = groups[group_id][1]
|
||||||
|
else:
|
||||||
|
liste_serveurs = groups[group_id][1]
|
||||||
|
|
||||||
if polling is None :
|
if polling is None :
|
||||||
polling = flushed_input("Durée du polling (en min) : ")
|
polling = flushed_input("Durée du polling (en min) : ")
|
||||||
@ -146,9 +148,9 @@ def make_group():
|
|||||||
filename += '-' + variantes[idx]
|
filename += '-' + variantes[idx]
|
||||||
variantes = [variante_infos[variantes[idx]]]
|
variantes = [variante_infos[variantes[idx]]]
|
||||||
print
|
print
|
||||||
|
print("Liste des serveurs : ")
|
||||||
for variante in variantes:
|
for variante in variantes:
|
||||||
cu.execute('select id,ip_publique,rne,libelle from serveurs where variante=' + str(variante))
|
cu.execute('select id,ip_publique,rne,libelle from serveurs where variante=' + str(variante))
|
||||||
print("Liste des serveurs : ")
|
|
||||||
for server in cu.fetchall():
|
for server in cu.fetchall():
|
||||||
print('{} - {} - {} - {}'.format(server[0], server[1], server[2], server[3]))
|
print('{} - {} - {} - {}'.format(server[0], server[1], server[2], server[3]))
|
||||||
server_infos.append(server[0])
|
server_infos.append(server[0])
|
||||||
|
@ -72,6 +72,7 @@ def main():
|
|||||||
|
|
||||||
if res == "UPDATE 1":
|
if res == "UPDATE 1":
|
||||||
print("OK")
|
print("OK")
|
||||||
|
print("Excecuter le script authorize_user_group pour authoriser l'accès de l'utilisateur aux serveurs")
|
||||||
else:
|
else:
|
||||||
print("Erreur : ", str(res))
|
print("Erreur : ", str(res))
|
||||||
|
|
||||||
|
@ -7,6 +7,7 @@ from pyeole.ihm import print_line
|
|||||||
from pyeole.ansiprint import print_orange, print_red
|
from pyeole.ansiprint import print_orange, print_red
|
||||||
from creole.client import CreoleClient
|
from creole.client import CreoleClient
|
||||||
from collections import OrderedDict
|
from collections import OrderedDict
|
||||||
|
from zephir.backend.lib_backend import CxPool
|
||||||
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
@ -76,7 +77,7 @@ def main():
|
|||||||
print('Liste des groupes :')
|
print('Liste des groupes :')
|
||||||
for grp_id, group_infos in groups.items():
|
for grp_id, group_infos in groups.items():
|
||||||
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
print(' - ' + str(grp_id) + ' : ' + group_infos[0])
|
||||||
print( ' - N : Créer un nouveau groupe')
|
print( ' - N : Créer un nouveau groupe')
|
||||||
while group_id is None:
|
while group_id is None:
|
||||||
tmp_group_id = flushed_input("Numéro du groupe : ")
|
tmp_group_id = flushed_input("Numéro du groupe : ")
|
||||||
if tmp_group_id == 'N':
|
if tmp_group_id == 'N':
|
||||||
@ -93,6 +94,8 @@ def main():
|
|||||||
group_id = None
|
group_id = None
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
liste_serveurs = groups[group_id][1]
|
liste_serveurs = groups[group_id][1]
|
||||||
|
else:
|
||||||
|
liste_serveurs = groups[group_id][1]
|
||||||
# on récupère toutes les master/slaves du groupe de serveurs
|
# on récupère toutes les master/slaves du groupe de serveurs
|
||||||
params = convert(proxy.serveurs.get_groupe_vars(liste_serveurs, True))
|
params = convert(proxy.serveurs.get_groupe_vars(liste_serveurs, True))
|
||||||
|
|
||||||
@ -109,7 +112,7 @@ def main():
|
|||||||
valvar = flushed_input("Valeur de la variable (séparateur |): ")
|
valvar = flushed_input("Valeur de la variable (séparateur |): ")
|
||||||
ret = proxy.serveurs.set_groupe_var(liste_serveurs, varc, valvar, False)
|
ret = proxy.serveurs.set_groupe_var(liste_serveurs, varc, valvar, False)
|
||||||
# on affiche les erreurs si nécessaire
|
# on affiche les erreurs si nécessaire
|
||||||
if ret[1]:
|
if ret[1]:
|
||||||
if ret[1] != "OK":
|
if ret[1] != "OK":
|
||||||
print_orange('Erreur : ' + str(ret[1]))
|
print_orange('Erreur : ' + str(ret[1]))
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
|
Reference in New Issue
Block a user