Ansible的runner源碼剖析第一部分

版本ansible1.9.1

（1）這部分只講簡(jiǎn)單使用例子
test.py

#!/usr/bin/env python
# -*- coding=utf-8 -*-
##################
import ansible.runner
##########################
runner = ansible.runner.Runner(
            host_list = 'ip.txt',                           #指定主機(jī)文件
            remote_user = 'root',                          #指定遠(yuǎn)程執(zhí)行用戶
            module_name = 'shell',                          #使用ansible的shell
            module_args = 'echo 111',               #模塊參數(shù)
            pattern = 'test',                               #主機(jī)文件中生效的組
            forks = 5,                                      #多進(jìn)程并發(fā)數(shù)量
            remote_pass = '123456',                         #遠(yuǎn)程執(zhí)行的密碼
            #is_playbook= True,
        )
datastructure = runner.run()
print anyalize_result(datastructure)

ip.txt

[test]
192.168.1.1
192.168.1.2

對(duì)遠(yuǎn)程主機(jī)執(zhí)行shell命令echo 111，datastructure呢是ansible結(jié)果處理后的結(jié)果

（2）ansible跑完的結(jié)果處理nyalize_result函數(shù)
#處理連接失敗，認(rèn)證失敗及執(zhí)行失敗的多種不同情況的數(shù)據(jù)分類匯總

import json
def anyalize_result(datastructure):
                #傳遞進(jìn)來任務(wù)ID，以及ansible執(zhí)行結(jié)果進(jìn)行處理
                ret = dict()
                ret['task_id'] = 66666
                ret['AuthenticationFailed'] = list()
                ret['ConnectedFailed'] = list()
                ret['failed'] = list()
                fail_temp = datastructure.get('dark',None)
                if fail_temp:
                        for ip,value in fail_temp.items():
                                msg = str(value.get('msg',None)).replace('\n','|')
                                if 'Authentication failure' in msg:
                                        ret['AuthenticationFailed'].append({ip:msg})
                                elif 'timed out' in msg:
                                        ret['ConnectedFailed'].append({ip:msg})
                                elif 'Connection refused' in msg:
                                        ret['ConnectedFailed'].append({ip:msg})
                                elif 'Connection closed' in msg:
                                        ret['ConnectedFailed'].append({ip:msg})
                                else:
                                        ret['failed'].append({ip:msg})
                ret['success'] = list()
                succ_temp = datastructure.get('contacted',None)
                if succ_temp:
                        for ip,result in succ_temp.items():
                                result_temp = result.get('stderr',None)
                                if not result_temp:
                                        ret['success'].append({ip:str(result.get('stdout',None)).replace('\n','|')})
                                else:
                                        ret['failed'].append({ip:str(result_temp).replace('\n','|')})
                return json.dumps(ret,indent=4)

結(jié)果么，自然優(yōu)雅的很，像如下內(nèi)容；自己試試吧，加油
# 第二部分會(huì)源碼剖析runner類，盡請(qǐng)期待

執(zhí)行結(jié)果部分內(nèi)容