ansible的动态传入hosts
import ansible.runnerimport ansible.inventory
import loggingMod.init_logger
import json
import sys
>
def __init__(self, ipAddress, userName, remoteUser):
self.ipAddress = [ ipAddress ]
self.userName = userName
self.remoteUser = remoteUser
'''init base info'''
self.webInventory = ansible.inventory.Inventory(self.ipAddress)
self.remotePort = 22
self.timeOut = 10
self.priKeyFile = '/home/%s/.ssh/id_rsa'
def printLog(self, output):
for (hostname, result) in output["contacted"].items():
if 'failed' in result:
logging.error('there is a error[%s]' % result['msg'])
sys.exit(1)
elif 'stderr' in result:
if result['stderr']:
logging.error('there is a error [%s]' % result['stderr'])
sys.exit(1)
def checkUserExist(self):
checkrunner = ansible.runner.Runner(
module_name='shell',
module_args='id -u %s' % self.userName,
timeout=self.timeOut,
remote_port=self.remotePort,
remote_user=self.remoteUser,
# private_key_file=self.priKeyFile,
become=True,
become_user='root',
inventory = self.webInventory
)
self.output = checkrunner.run()
self.printLog(self.output)
def addRoot(self):
self.checkUserExist()
runner = ansible.runner.Runner(
module_name='user',
module_args='name=%s groups=root append=no' % self.userName,
timeout=self.timeOut,
remote_port=self.remotePort,
remote_user=self.remoteUser,
private_key_file=self.priKeyFile,
become=True,
become_user='root',
inventory = self.webInventory
)
self.result = runner.run()
self.printLog(self.result)
self.info('success')
def removeRoot(self):
rmRunner = ansible.runner.Runner(
module_name='shell',
module_args='gpasswd -d %s root' % self.userName,
timeout=self.timeOut,
remote_port=self.remotePort,
remote_user=self.remoteUser,
private_key_file=self.priKeyFile,
become=True,
become_user='root',
inventory = self.webInventory
)
self.rmOutput = rmRunner.run()
self.printLog(self.rmOutput)
self.info('success remove root privilege')
theUser = rootUser('192.168.35.125', 'mr.right', 'raingolee')
theUser.removeRoot()
页:
[1]