class AnsiblePlayRecap(models.Model):
    """
    保存ansible最終執(zhí)行結(jié)果的表
    """
    id = models.AutoField('自增id', primary_key=True)
    manager_ip = models.CharField('MHA Manager IP', max_length=100)
    clustername = models.CharField('HA 集群名字', max_length=200, default='')
    playname = models.CharField('Ansible劇本名稱', max_length=360, default='')
    playrecap_serverip = models.CharField('受管節(jié)點(diǎn)', max_length=50, default='')
    playrecap_ok_qty = models.CharField('此節(jié)點(diǎn)成功運(yùn)行的task個(gè)數(shù)', max_length=10, default='')
    playrecap_changed_qty = models.CharField('產(chǎn)生效果的task個(gè)數(shù)', max_length=10, default='')
    playrecap_unreachable = models.CharField('相應(yīng)的遠(yuǎn)程節(jié)點(diǎn)是否不可達(dá)', max_length=10, default='')
    playrecap_failed_qty = models.CharField('執(zhí)行失敗的task個(gè)數(shù)', max_length=10, default='')
    playrecap_skipped_qty = models.CharField('跳過(guò)的task的個(gè)數(shù)', max_length=10, default='')
    playrecap_rescued_qty = models.CharField('搶救的task的個(gè)數(shù)', max_length=10, default='')
    playrecap_ignored_qty = models.CharField('忽略的task的個(gè)數(shù)', max_length=10, default='')
    create_time = models.DateTimeField('插入時(shí)間', auto_now=True)
    create_user = models.CharField('操作人', max_length=50, default='')

    class Meta:
        db_table = 'ansible_play_recap'
        verbose_name = '保存ansible最終執(zhí)行結(jié)果的表'

class AnsibleTaskDetail(models.Model):
    """
    保存各task執(zhí)行詳情的表
    """
    id = models.AutoField('自增id', primary_key=True)
    manager_ip = models.CharField('MHA Manager IP', max_length=100)
    clustername = models.CharField('HA 集群名字', max_length=200, default='')
    playname = models.CharField('Ansible劇本名稱', max_length=360, default='')
    task_serverip = models.CharField('受管節(jié)點(diǎn)', max_length=50, default='')
    taskname = models.CharField('任務(wù)名稱', max_length=360, default='')
    task_status = models.CharField('任務(wù)執(zhí)行結(jié)果', max_length=50, default='')
    task_result_type = models.CharField('執(zhí)行結(jié)果的錯(cuò)誤類型', max_length=10, default='')
    task_messages = models.TextField('Task運(yùn)行返回信息')
    create_time = models.DateTimeField('插入時(shí)間', auto_now=True)
    create_user = models.CharField('操作人', max_length=50, default='')

    class Meta:
        db_table = 'ansible_task_palydetail'
        verbose_name = '保存各執(zhí)行步驟詳情的表'

python manage.py makemigrations XXXX

python manage.py sqlmigrate XXXX 0006

from .ansible import ParamikoHelper
    ##paramiko 是一個(gè)用于在Python中執(zhí)行遠(yuǎn)程操作的模塊，支持SSH協(xié)議。它可以用于連接到遠(yuǎn)程服務(wù)器，執(zhí)行命令、上傳和下載文件，以及在遠(yuǎn)程服務(wù)器上執(zhí)行各種操作。
    ##字符串中關(guān)于IP地址的正則表達(dá)式
    ## ^：匹配字符串的開(kāi)頭。((25[0-5]|2[0-4]\d|[01]?\d\d?)\.)：匹配一個(gè)數(shù)字和一個(gè)點(diǎn)號(hào)，這個(gè)數(shù)字的取值范圍是0到255。
    ## {3}：匹配前面的表達(dá)式三次。(25[0-5]|2[0-4]\d|[01]?\d\d?)：   配一個(gè)數(shù)字，這個(gè)數(shù)字的取值范圍是0到255。$：匹配字符串的結(jié)尾。
    ## 使用正則表達(dá)式匹配IP地址
    # 字符串是IP地址
    ip_pattern = r'^((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}(25[0-5]|2[0-4]\d|[01]?\d\d?)$'
    ##字符串是IP地址開(kāi)頭的
    ipstart_pattern = r'^((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}(25[0-5]|2[0-4]\d|[01]?\d\d?)'
    ##字符串包含IP
    ipcontain_pattern = r'((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}(25[0-5]|2[0-4]\d|[01]?\d\d?)'   
    ##字符串包含IP,并且IP地址是以': ['字符開(kāi)頭，以']'字符結(jié)尾
    ipcontain_pattern_plus = r'(\: \[)((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}((25[0-5]|2[0-4]\d|[01]?\d\d?)\])' 
    ansible_ip = '你的ansible server IP'
    ssh_port = 你的ssh_port
    ssh_username = '免密登錄設(shè)置的賬號(hào)'
    ph = ParamikoHelper(remote_ip=ansible_ip,remote_ssh_port=ssh_port,ssh_username=ssh_username)
    stdin, stdout, stderr = ph.exec_shell(shell_command)
    processor_result = stdout.readlines() #readlines()列表形式返回全文，每行作為一個(gè)字符串作為列表元素

### 先賦值，否則有可能報(bào)錯(cuò):UnboundLocalError: local variable 'XXXXX' referenced before assignment
    rplayname = ''
    rtask_result_type =''
    ###
    for pr_line in processor_result:
      logger.warning(f'{pr_line}')
      ## 判斷這個(gè)字符串是不是以IP地址開(kāi)頭
      ip_result = re.search(ipstart_pattern, pr_line)
      ## 判斷這個(gè)字符串是不是包含IP地址，并且IP以': ['字符開(kāi)頭，以']'字符結(jié)束  
      ip_plus_result = re.search(ipcontain_pattern_plus, pr_line) 
      ##獲取playname start

##獲取playname
      if 'PLAY [' in pr_line:
        ##使用的正則表達(dá)式'\[(.*?)\]'，其中'\'為轉(zhuǎn)移符，用于表示左右中括號(hào)的匹配，'?'表示非貪婪模式，這個(gè)模式會(huì)匹配最短的符合要求的字符串。
        ## [0],因正則匹配后，放回的是數(shù)組，通過(guò)[0],轉(zhuǎn)換為字符串。
        rplayname = re.findall(r'\[(.*?)\]', pr_line)[0]##獲取task 的名稱
      elif 'TASK [' in pr_line:
        rtaskname = re.findall(r'\[(.*?)\]', pr_line)[0]

## 判斷這個(gè)字符串是不是以IP地址開(kāi)頭
      elif ip_result: #字符串是IP地址開(kāi)頭的
        ## 此時(shí)pr_line的字符串格式如下:
        ## pr_line = '172.173.17.18               : ok=5    changed=2    unreachable=1    failed=0    skipped=6    rescued=7    ignored=8'
        rserverip = ip_result.group() ## 匹配的server IP
        ## print(rserverip) ##打印IP地址

        ## 正則表達(dá)式，\s+ ，將一個(gè)以多個(gè)空格或制表符為分隔符的字符串拆分成一個(gè)列表
        pr_line_lst = re.split(r"\s+", pr_line)
        ##分割后為： ['172.173.17.18', ':', 'ok=5', 'changed=2', 'unreachable=1', 'failed=0', 'skipped=6', 'rescued=7', 'ignored=8']
        for pr_arry in pr_line_lst:
          if 'ok=' in pr_arry:
            rplayrecap_ok_qty = pr_arry.split("ok=")[1] ##記得：字符串切割后返回的是數(shù)組，所以取第二個(gè)元素if 'changed=' in pr_arry:
            rplayrecap_changed_qty = pr_arry.split("changed=")[1]if 'unreachable=' in pr_arry:
            rplayrecap_unreachable = pr_arry.split("unreachable=")[1]if 'failed=' in pr_arry:
            rplayrecap_failed_qty = pr_arry.split("failed=")[1]if 'skipped=' in pr_arry:
            rplayrecap_skipped_qty = pr_arry.split("skipped=")[1]if 'rescued=' in pr_arry:
            rplayrecap_rescued_qty = pr_arry.split("rescued=")[1]if 'ignored=' in pr_arry:
            rplayrecap_ignored_qty = pr_arry.split("ignored=")[1]

### 開(kāi)始向表[ansible_play_recap]中插入數(shù)據(jù),保存ansible最終執(zhí)行結(jié)果的表
        AnsiblePlayRecap.objects.create(manager_ip=manager_ip,clustername=cluster_name,playname=rplayname,playrecap_serverip=rserverip,
                                                    playrecap_ok_qty=rplayrecap_ok_qty,playrecap_changed_qty=rplayrecap_changed_qty,
                                                    playrecap_unreachable=rplayrecap_unreachable,playrecap_failed_qty=rplayrecap_failed_qty,
                                                    playrecap_skipped_qty=rplayrecap_skipped_qty,playrecap_rescued_qty=rplayrecap_rescued_qty,
                                                    playrecap_ignored_qty=rplayrecap_ignored_qty, create_user='Archery System'
                                                    )

## 判斷這個(gè)字符串是不是包含IP地址，并且IP以': ['字符開(kāi)頭，以']'字符結(jié)尾
      elif ip_plus_result: ##字符串包含IP,并且IP地址是以': ['字符開(kāi)頭，以']'字符結(jié)尾
        if 'ok: [' in pr_line:
          rtask_status = 'ok'
          rtask_messages = '' ## 賦值空
          ##查找server IP
          result = re.search(ipcontain_pattern, pr_line)
          rserverip = result.group() ## 匹配的server IP  
          ## print(rserverip)
        elif 'changed: [' in pr_line:
          rtask_status = 'changed'
          rtask_messages = '' ## 賦值空##查找server IP
          result = re.search(ipcontain_pattern, pr_line)
          rserverip = result.group() ## 匹配的server IP## 有些 返回的change 中還有其他信息，例如:changed: [192.168.168.192] => (item=perl-Parallel-ForkManager-1.18-2.el7.noarch.rpm)
          ## 此時(shí)判斷下，是否包含 '] =>',如果包含，賦值給  
          if '] => ' in pr_line:
            rtask_messages= pr_line.split("] => ")[1]elif 'skipping: [' in pr_line:
          rtask_status = 'skipping'
          rtask_messages = '' ## 賦值空
          ##查找server IP
          result = re.search(ipcontain_pattern, pr_line)
          rserverip = result.group() ## 匹配的server IPelif 'fatal: [' in pr_line:
          rtask_status = 'fatal'
          rtask_messages = '' ## 賦值空
          rtask_result_type ='FAILED'##查找server IP
          result = re.search(ipcontain_pattern, pr_line)
          rserverip = result.group() ## 匹配的server IPif 'FAILED! =>' in pr_line:
            rtask_messages= pr_line.split("FAILED! =>")[1]else:
          rtask_status = 'NA'
          rtask_messages = '未知狀態(tài)，請(qǐng)DBAcheck......' + pr_line
        ### 開(kāi)始向表中插入數(shù)據(jù)
        AnsibleTaskDetail.objects.create(manager_ip=manager_ip,clustername=cluster_name,playname=rplayname,playrecap_serverip=rserverip,
                                                    taskname=rtaskname,task_status=rtask_status,
                                                    task_result_type=rtask_result_type,task_messages=rtask_messages,
                                                    create_user='Archery System'
                                                    )

elif len(pr_line) == 0 or pr_line == '\n' or ('PLAY RECAP *******' in  pr_line): ###判斷是否空 或只是 簡(jiǎn)單的換行符，再或者包含指定字符
           print("這一行為空行 或 說(shuō)明行，無(wú)需記錄!")

else:
        rtask_status = 'Mostly OK'
        rtask_result_type = 'debug+msg'   ##'經(jīng)常出現(xiàn)在task中有debug：msg：的時(shí)候'
        rtask_messages =  pr_line
        ### 開(kāi)始向表中插入數(shù)據(jù)
        AnsibleTaskDetail.objects.create(manager_ip=manager_ip,clustername=cluster_name,playname=rplayname,playrecap_serverip=rserverip,
                                                    taskname=rtaskname,task_status=rtask_status,
                                                    task_result_type=rtask_result_type,task_messages=rtask_messages,
                                                    create_user='Archery System'
                                                    )

        ###這段處理的情形不好想像，比較難懂，舉個(gè)例子
        ## ok: [192.168.168.192] => 
        ##  {
        ##     "msg": "MySQL Replication Health is OK!"
        ## }
        ##需要注意的時(shí)，相應(yīng)的在表中也會(huì)保留多行數(shù)據(jù)。因?yàn)槲覀儠r(shí)逐行獲取，逐行解析，逐行報(bào)錯(cuò)的。不過(guò)慶幸的時(shí)，順序都是對(duì)的。