真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

基于paramiko的文件批量分發(fā)和命令批量執(zhí)行

    在實(shí)際工作環(huán)境中，有可能需要去運(yùn)維百臺(tái)服務(wù)器，甚至更多。以應(yīng)用升級(jí)為例，對(duì)應(yīng)用做升級(jí)操作，首先得停止應(yīng)用服務(wù)，防止新的應(yīng)用數(shù)據(jù)寫(xiě)入，并備份應(yīng)用部署目錄，然后替換成新的代碼文件、配置文件等。替換完成后，啟動(dòng)應(yīng)用服務(wù)。但是由于應(yīng)用服務(wù)器數(shù)量過(guò)多，如果一臺(tái)一臺(tái)服務(wù)器去做升級(jí)，這會(huì)花費(fèi)很多時(shí)間。這時(shí)，便可使用paramiko編寫(xiě)python腳本，讓這些重復(fù)性的操作批量執(zhí)行，去實(shí)現(xiàn)應(yīng)用升級(jí)的自動(dòng)化。這個(gè)小工具實(shí)現(xiàn)了在堡壘機(jī)模式和非堡機(jī)模式的運(yùn)用。

1.maintool.py（控制整個(gè)腳本的執(zhí)行），代碼如下：

點(diǎn)擊(此處)折疊或打開(kāi)

創(chuàng)新互聯(lián)建站服務(wù)項(xiàng)目包括大通網(wǎng)站建設(shè)、大通網(wǎng)站制作、大通網(wǎng)頁(yè)制作以及大通網(wǎng)絡(luò)營(yíng)銷(xiāo)策劃等。多年來(lái)，我們專(zhuān)注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，大通網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶(hù)以成都為中心已經(jīng)輻射到大通省份的部分城市，未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶(hù)的支持與信任！

  1. #!/usr/bin/python
  2. #coding:utf-8
  3. import sys
  4. ######腳本執(zhí)行操作提示
  5. def login():
  6.     print """\033[1;34m
  7.     1:批量分發(fā)文件(非堡壘機(jī)模式)
  8.     2:批量執(zhí)行命令(非堡壘機(jī)模式)
  9.     3:批量下載文件(非堡壘機(jī)模式)
  10.     4:單臺(tái)執(zhí)行命令(非堡壘機(jī)模式)
  11.     5:批量分發(fā)文件(堡壘機(jī)模式)
  12.     6:批量執(zhí)行命令(堡壘機(jī)模式)
  13.     7:增加需要服務(wù)器(非堡壘機(jī)模式)
  14.     8:刪除不需要服務(wù)器(非堡壘機(jī)模式)
  15.     9:查看當(dāng)前服務(wù)器列表(非堡壘機(jī)模式)
  16.     10:退出\033[0m
  17.     """
  18. #######定義用戶(hù)選擇函數(shù)
  19. def choice():
  20.     import operation,blhost_operation
  21.     while True:
  22.         choice = raw_input("\033[1;32minput your choice:\033[0m").strip()
  23.         choice_list = ['1','2','3','4','5','6','7','8','9','10','help','exit']
  24.         if choice not in choice_list:
  25.             print "\033[1;33mtry again!\033[0m"
  26.             continue
  27.         if choice == '1':
  28.             operation.SendFile()###非堡機(jī)模式下文件分發(fā)
  29.      login()
  30.         if choice == '2':
  31.             operation.ExecuteCmd()###非堡機(jī)模式下命令執(zhí)行
  32.             login()
  33.         if choice == '3':
  34.             operation.DownloadFile()###非堡機(jī)模式下文件下載
  35.             login()
  36.         if choice == '4':
  37.             operation.SingleServer()###單臺(tái)服務(wù)器操作
  38.             login()
  39.         if choice == '5':
  40.             blhost_operation.SendFile()###堡壘機(jī)模式下文件分發(fā)
  41.             login()
  42.         if choice == '6':
  43.             blhost_operation.ExecuteCmd()###堡壘機(jī)模式下命令執(zhí)行
  44.             login()
  45.         if choice == '7':
  46.             operation.AddServerList()###增加服務(wù)器名單
  47.         if choice == '8':
  48.             operation.DeleteServerList()###刪除服務(wù)器名單
  49.         if choice == '9':
  50.             operation.ShowServerList()###展示服務(wù)器名單
  51.             login()
  52.         if choice == '10' or choice == 'exit':###退出腳本操作
  53.             print "\033[1;31mThank you for your use!\033[0m"
  54.             sys.exit(0)
  55.         if choice == 'help':
  56.             login()
  57. if __name__ == '__main__':
  58.     login()
  59.     choice()

maintool.py執(zhí)行效果如下：
基于paramiko的文件批量分發(fā)和命令批量執(zhí)行
2.operation.py（定義非堡壘機(jī)模式下的相關(guān)操作），代碼如下：

點(diǎn)擊(此處)折疊或打開(kāi)

  1. #!/usr/bin/python
  2. #coding:utf-8
  3. import sys,time,threading
  4. import getpass,commands
  5. import paramiko,fabric
  6. server_list=[]        #HOSTNAME IP PWDROOT PWDWEBLOGIC PWDORACLE
  7. result_dict={}
  8. ######讀取文件內(nèi)容，讀取完成后關(guān)閉文件
  9. f = open ('serverlist.txt')
  10. for i in f.readlines():
  11.     server_list.append(i.split())
  12. f.close()
  13. ######非堡壘機(jī)下文件的傳送
  14. def transfer(localpath,remotepath,hostname,username,password):
  15.     port = 22
  16.     try:
  17.         t = paramiko.Transport((hostname,port))
  18.         t.connect(username=username,password=password)
  19.         sftp = paramiko.SFTPClient.from_transport(t)
  20.         sftp.put(localpath,remotepath)
  21.         t.close()
  22.         result_dict[hostname] = hostname+"服務(wù)器文件傳送完成"
  23.         print result_dict[hostname]
  24.     except Exception,e:
  25.         print str(e)
  26. ######定義文件下載函數(shù)
  27. def download(remotepath,localpath,hostname,username,password):
  28.     port = 22
  29.     try:
  30.         t = paramiko.Transport((hostname,port))
  31.         t.connect(username=username,password=password)
  32.         sftp = paramiko.SFTPClient.from_transport(t)
  33.         sftp.get(remotepath,localpath)
  34.         t.close()
  35.         result_dict[hostname] = hostname+"服務(wù)器文件下載完成"
  36.         print result_dict[hostname]
  37.     except Exception,e:
  38.         print str(e)
  39. ######定義命令執(zhí)行函數(shù)
  40. def execmd(hostname,username,password,CMD):
  41.     paramiko.util.log_to_file('syslogin.log')###將用戶(hù)登錄服務(wù)器日志輸出到syslogin.log
  42.     ssh = paramiko.SSHClient()###ssh登錄服務(wù)器
  43.     ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())###自動(dòng)添加主機(jī)名及主機(jī)密鑰到本地HostKeys對(duì)象,并將其保存,不依賴(lài)load_system_host_keys()的配置，即使~/.ssh/known_hosts不存在也不產(chǎn)生影響
  44.     ssh.connect(hostname=hostname,username=username,password=password)
  45.     stdin,stdout,stderr = ssh.exec_command(CMD)
  46.     result = stdout.read()
  47.     ssh.close()
  48.     result_dict[hostname] = hostname+"服務(wù)器命令執(zhí)行結(jié)果如下："+"\n"+result
  49.     print result_dict[hostname]
  50. ######執(zhí)行結(jié)果打印
  51. def result_dict_print():
  52.     global result_dict
  53.     while True:
  54.         if len(result_dict) == len(server_list):
  55.             break
  56.     print "\033[1;36m%s臺(tái)服務(wù)器完成\033[0m" %(len(result_dict))
  57.     result_dict = {}
  58. ######非保壘機(jī)模式下文件的分發(fā)
  59. def SendFile():
  60.     while True:
  61.         username = raw_input("\033[1;32m請(qǐng)輸入你選擇要用于發(fā)送文件的用戶(hù)[root/weblogic/oracle]:\033[0m").strip()
  62.         username_list = ['root','weblogic','oracle','\n','exit']
  63.         if username not in username_list:
  64.             print "\033[0;32minput error!Please try again!If you need exit,please input exit!\033[0m"
  65.             continue
  66.         if username == 'exit':
  67.             sys.exit()
  68.         localpath = raw_input("\033[1;32m本地文件(絕對(duì)路徑):\033[0m").strip()
  69.         remotepath = raw_input("\033[1;32m服務(wù)器目的地址(絕對(duì)路徑):\033[0m").strip()
  70.         if username == 'root':
  71.             for list in server_list:
  72.         p = threading.Thread(target=transfer,args=(localpath,remotepath,list[1],username,list[2],))
  73.         p.start()
  74.             for list in server_list:
  75.             p.join(timeout=1)
  76.         if username == 'weblogic' or username == '':
  77.             username = 'weblogic'
  78.             for list in server_list:
  79.                 p = threading.Thread(target=transfer,args=(localpath,remotepath,list[1],username,list[3],))
  80.                 p.start()
  81.         if username == 'oracle':
  82.             username = 'oracle'
  83.             for list in server_list:
  84.                 p = threading.Thread(target=transfer,args=(localpath,remotepath,list[1],username,list[4],))
  85.                 p.start()
  86.         result_dict_print()
  87.         break
  88. ######非堡壘機(jī)模式下文件的下載
  89. def DownloadFile():
  90.     while True:
  91.         username = raw_input("\033[1;32m請(qǐng)輸入你選擇要用于下載文件的用戶(hù)[root/weblogic/oracle]:\033[0m").strip()
  92.         username_list = ['root','weblogic','oracle','\n','exit']
  93.         if username not in username_list:
  94.             print "\033[1;32minput error!Please try again!If you need exit,please input exit!\033[0m"
  95.             continue
  96.         if username == 'exit':
  97.             sys.exit()
  98.         remotepath = raw_input("\033[1;32m遠(yuǎn)程文件(絕對(duì)路徑):\033[0m").strip()
  99.         localpath = raw_input("\033[1;32m服務(wù)器目的地址(目錄名,默認(rèn)為/opt/zzx/python/bin):\033[0m").strip()
  100.         if localpath == '':
  101.             localpath = '/opt/zzx/python/bin'
  102.         localpath = localpath+"/"
  103.         print localpath
  104.         count = remotepath.count('/')
  105.         basename = remotepath.split('/')[count]
  106.         if username == 'root':
  107.             for list in server_list:
  108.                 p = threading.Thread(target=download,args=(remotepath,localpath+list[1]+"_"+basename,list[1],username,list[2],))
  109.                 p.start()
  110.             for list in server_list:
  111.                 p.join(timeout=1)
  112.         if username == 'weblogic' or username == '':
  113.             username = 'weblogic'
  114.             for list in server_list:
  115.                 localpath = result1+list[1]+"_"+result2
  116.                 p = threading.Thread(target=download,args=(remotepath,localpath,list[1],username,list[3],))
  117.                 p.start()
  118.         if username == 'oracle':
  119.             for list in server_list:
  120.                 localpath = result1+list[1]+"_"+result2
  121.                 p = threading.Thread(target=download,args=(remotepath,localpath,list[1],username,list[4],))
  122.                 p.start()
  123.         result_dict_print()
  124.         break
  125. ######非堡壘機(jī)模式下命令的執(zhí)行
  126. def ExecuteCmd():
  127.     while True:
  128.         username = raw_input("\033[1;32m請(qǐng)輸入你選擇要用于執(zhí)行命令的用戶(hù)[root/weblogic/oracle]:\033[0m").strip()
  129.         username_list = ['root','weblogic','oracle','\n','exit']
  130.         if username not in username_list:
  131.             print "\033[1;32minput error!Please try again!If you need exit,please input exit!\033[0m"
  132.             continue
  133.         if username == 'exit':
  134.             sys.exit()
  135.         CMD = raw_input("\033[1;37m請(qǐng)輸入要執(zhí)行的命令(不能帶引號(hào)):\033[0m").strip()
  136.         if CMD == 'exit':
  137.             return
  138.         if username == 'root':
  139.             for list in server_list:
  140.                 p = threading.Thread(target=execmd,args=(list[1],username,list[2],CMD,))
  141.                 p.start()
  142.         if username == 'weblogic' or username == '':
  143.             username = 'weblogic'
  144.             for list in server_list:
  145.                 p = threading.Thread(target=execmd,args=(list[1],username,list[3],CMD))
  146.                 p.start()
  147.         if username == 'oracle':
  148.             for list in server_list:
  149.                 p = threading.Thread(target=execmd,args=(list[1],username,list[4],CMD))
  150.                 p.start()
  151.         result_dict_print()
  152.         break
  153. ######單臺(tái)服務(wù)器操作
  154. def SingleServer():
  155.     IP = raw_input("\033[1;32m請(qǐng)輸入要執(zhí)行命令的服務(wù)器IP地址:\033[0m").strip()
  156.     username = raw_input("\033[1;32m請(qǐng)輸入要執(zhí)行命令的服務(wù)器用戶(hù)名:\033[0m").strip()
  157.     password = getpass.getpass()
  158.     CMD = raw_input("\033[1;32m請(qǐng)輸入要執(zhí)行的命令(不能帶引號(hào)):\033[0m").strip()
  159.     execmd(IP,username,password,CMD)
  160. ######服務(wù)器名單添加
  161. def AddServerList():
  162.     hostname = raw_input("\033[1;32m請(qǐng)輸入服務(wù)器名稱(chēng)(如localhost):\033[0m").strip()
  163.     if hostname == 'quit' or hostname == 'exit':
  164.         return
  165.     ip = raw_input("\033[1;32m請(qǐng)輸入服務(wù)器IP:\033[0m").strip()
  166.     root_passwd = raw_input("\033[1;32m請(qǐng)輸入服務(wù)器root用戶(hù)密碼:\033[0m").strip()
  167.     weblogic_passwd = raw_input("\033[1;32m請(qǐng)輸入服務(wù)器weblogic用戶(hù)密碼:\033[0m").strip()
  168.     oracle_passwd = raw_input("\033[1;32m請(qǐng)輸入服務(wù)器oracle用戶(hù)密碼:\033[0m").strip()    
  169.     f = file('serverlist.txt','a')
  170.     f.write("%s %s %s %s %s\n"%(hostname,ip,root_passwd,weblogic_passwd,oracle_passwd))
  171.     f.close()
  172.     raw_input("\033[1;32m重新執(zhí)行程序后生效(敲任意鍵退出)...\033[0m")
  173.     time.sleep(0.2)
  174.     sys.exit()
  175. ######服務(wù)器名單刪除
  176. def DeleteServerList():
  177.     IP = raw_input("\033[1;32m請(qǐng)輸入要?jiǎng)h除服務(wù)器IP:\033[0m").strip()
  178.     if IP == 'quit' or IP == 'exit':
  179.         return
  180.     status,result = commands.getstatusoutput("sed -i '/\<%s\>/'d ./serverlist.txt" % IP)
  181.     raw_input("\033[1;32m重新執(zhí)行程序后生效(敲任意鍵退出)...\033[0m")
  182.     time.sleep(0.2)
  183.     sys.exit()
  184. ######服務(wù)器名單顯示
  185. def ShowServerList():
  186.     i = 0
  187.     f = open('serverlist.txt','rb')
  188.     for line in f.readlines():
  189.         print line.strip()
  190.         i = i+1
  191.     f.close
  192.     print "\n總共%s臺(tái)服務(wù)器" % i
3.blhost_operation.py（定義堡壘機(jī)模式下的相關(guān)操作），代碼如下：

點(diǎn)擊(此處)折疊或打開(kāi)

  1. #!/usr/bin/python
  2. #coding:utf-8
  3. import sys,time,threading
  4. import getpass,commands,os
  5. import paramiko,fabric
  6. server_list=[]        #HOSTNAME IP PWDROOT PWDWEBLOGIC PWDORACLE
  7. result_dict={}
  8. ######讀取文件內(nèi)容，讀取完成后關(guān)閉文件
  9. f = open ('serverlist.txt')
  10. for i in f.readlines():
  11.     server_list.append(i.split())
  12. f.close()
  13. ######堡壘機(jī)下文件的傳送
  14. def transfer(bllocalpath,remotepath,blhostname,blusername,blpassword,hostname,username,password):
  15.     passinfo='\'s password: '
  16.     paramiko.util.log_to_file('blhost_upload.log')

  18.     ssh=paramiko.SSHClient()
  19.     ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())###自動(dòng)添加主機(jī)名及主機(jī)密鑰到本地HostKeys對(duì)象,并將其保存,不依賴(lài)load_system_host_keys()的配置，即使~/.ssh/known_hosts不存在也不產(chǎn)生影響
  20.     ssh.connect(hostname=blhostname,username=blusername,password=blpassword)

  22.     channel=ssh.invoke_shell()
  23.     channel.settimeout(100)
  24.     buff=''
  25.     resp=''
  26.     channel.send('scp '+bllocalpath+' '+username+'@'+hostname+':'+remotepath+'\n')
  27.     while not buff.endswith(passinfo):
  28.         try:
  29.             resp=channel.recv(9999)
  30.         except Exception,e:
  31.             print "Error info:receive nothing"
  32.             print str(e)
  33.             channel.close()
  34.             ssh.close()
  35.             sys.exit()
  36.         buff += resp
  37.         if not buff.find('yes/no')==-1:
  38.             channel.send('yes\n')
  39.             buff=''
  40.     buff=''
  41.     channel.send(password+'\n')
  42.     while not buff.endswith('# '):
  43.         resp=channel.recv(9999)
  44.         if not resp.find(passinfo)==-1:
  45.             print "Error info:Authentication failed."
  46.             print "Please confirm if your password is true!"
  47.             channel.close()
  48.             ssh.close()
  49.             sys.exit()
  50.         buff += resp
  51.     channel.close()
  52.     ssh.close()
  53.     result_dict[hostname] = hostname+"服務(wù)器文件傳送完成"
  54.     print result_dict[hostname]
  55. ######堡壘機(jī)模式下命令執(zhí)行
  56. def execmd(blhostname,blusername,blpassword,hostname,username,password,CMD):
  57.     passinfo='\'s password: '
  58.     paramiko.util.log_to_file('blhost_syslogin.log')

  60.     ssh=paramiko.SSHClient()
  61.     ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  62.     ssh.connect(hostname=blhostname,username=blusername,password=blpassword)

  64.     channel=ssh.invoke_shell()
  65.     channel.settimeout(100)

  67.     buff=''
  68.     resp=''
  69.     channel.send('ssh '+username+'@'+hostname+'\n')
  70.     while not buff.endswith(passinfo):
  71.         try:
  72.             resp=channel.recv(9999)
  73.         except Exception,e:
  74.             print "fail to connect"
  75.             print "Error info: "+str(e)
  76.             channel.close()
  77.             ssh.close()
  78.             sys.exit()
  79.         buff += resp
  80.         if not buff.find('yes/no')==-1:
  81.             channel.send('yes\n')
  82.             buff=''
  83.     buff=''
  84.     channel.send(password+'\n')
  85.     while not buff.endswith('# '):
  86.         resp=channel.recv(9999)
  87.         if not resp.find(passinfo)==-1:
  88.             print "Error info:Authentication failed"
  89.             channel.close()
  90.             ssh.close()
  91.             sys.exit()
  92.         buff += resp
  93.     buff=''
  94.     channel.send('%s\n' % CMD)
  95.     try:
  96.         while not buff.endswith('# '):
  97.             resp=channel.recv(9999)
  98.             buff += resp
  99.     except Exception,e:
  100.         print "Error info:"+str(e)

  102.     result = buff
  103.     channel.close()
  104.     ssh.close()
  105.     result_dict[hostname] = hostname+"服務(wù)器命令執(zhí)行結(jié)果如下："+"\n"+result
  106.     print result_dict[hostname]
  107. ######執(zhí)行結(jié)果打印
  108. def result_dict_print():
  109.     global result_dict
  110.     while True:
  111.         if len(result_dict) == len(server_list):
  112.             break
  113.     print "\033[1;36m%s臺(tái)服務(wù)器完成\033[0m" %(len(result_dict))
  114.     result_dict={}
  115. ######堡壘機(jī)模式下文件的批量分發(fā)
  116. def SendFile():
  117.     while True:
  118.         blusername = raw_input("\033[1;32m請(qǐng)輸入你選擇要用于發(fā)送文件的堡壘機(jī)用戶(hù)[root/weblogic/oracle]:\033[0m").strip()
  119.         blusername_list = ['root','weblogic','oracle','','exit']
  120.         if blusername not in blusername_list:
  121.             print "\033[0;32minput error!Please try again!If you need exit,please input exit!\033[0m"
  122.             continue
  123.         if blusername == 'exit':
  124.             return
  125.         blhostname=raw_input("\033[1;32m請(qǐng)輸入你選擇要用于發(fā)送文件的堡壘機(jī)IP:\033[0m").strip()
  126.         print "\033[1;32m請(qǐng)輸入你選擇要用于發(fā)送文件的堡壘機(jī)密碼:\033[0m"
  127.         blpassword=getpass.getpass()
  128.         username=raw_input("\033[1;32m請(qǐng)輸入你選擇要用于接收文件的用戶(hù)[root/weblogic/oracle]:\033[0m").strip()
  129.         bllocalpath=raw_input("\033[1;32m堡壘機(jī)本地文件(絕對(duì)路徑):\033[0m").strip()
  130.         remotepath=raw_input("\033[1;32m服務(wù)器目的地址(絕對(duì)路徑):\033[0m").strip()
  131.         if blusername == 'root':
  132.             for list in server_list:
  133.         p = threading.Thread(target=transfer,args=(bllocalpath,remotepath,blhostname,blusername,blpassword,list[1],username,list[2],))
  134.         p.start()
  135.             for list in server_list:
  136.             p.join(timeout=1)
  137.         if blusername == 'weblogic' or blusername == '':
  138.             blusername = 'weblogic'
  139.             for list in server_list:
  140.                 p = threading.Thread(target=transfer,args=(bllocalpath,remotepath,blhostname,blusername,blpassword,list[1],username,list[3],))
  141.                 p.start()
  142.         if blusername == 'oracle':
  143.             for list in server_list:
  144.                 p = threading.Thread(target=transfer,args=(bllocalpath,remotepath,blhostname,blusername,blpassword,list[1],username,list[4],))
  145.                 p.start()
  146.         result_dict_print()
  147.         break
  148. ######堡壘機(jī)模式下命令的批量執(zhí)行
  149. def ExecuteCmd():

  150. 本文名稱(chēng)：基于paramiko的文件批量分發(fā)和命令批量執(zhí)行
    網(wǎng)頁(yè)鏈接：http://weahome.cn/article/isgphh.html

在線咨詢(xún)

微信咨詢(xún)

電話(huà)咨詢(xún)

028-86922220（工作日）

18980820575（7×24）

提交需求

返回頂部