Compare commits

...

8 Commits

Author SHA1 Message Date
524aef91f9 set correct args option 2021-09-02 10:55:09 +02:00
84834a228f update question on set_var 2021-09-02 10:09:16 +02:00
f081522e1e correction set_var 2021-07-20 09:18:21 +02:00
441fbd22d2 correction timeout 2021-07-20 09:14:19 +02:00
0f3c332923 correction 2021-07-20 09:11:48 +02:00
4b11e407be ajout messages d'information, ajout option no-save pour batch 2021-07-19 09:32:41 +02:00
32bfaa523f correction batch 2021-07-16 15:43:16 +02:00
244cc1a716 correction bug 2021-07-16 15:07:25 +02:00
8 changed files with 44 additions and 19 deletions

View File

@ -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)

View File

@ -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)

View File

@ -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()

View File

@ -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]:

View File

@ -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

View File

@ -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])

View File

@ -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))

View File

@ -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)