为您推荐:
精华内容
最热下载
问答
  • 5星
    17.55MB qq_31899125 2021-05-22 21:52:40
  • 5星
    4KB weixin_45289454 2021-05-29 08:25:09
  • 5星
    1.34MB dxh_wxx 2021-07-20 09:11:12
  • 5星
    93.95MB qq_21548021 2021-06-28 10:17:26
  • 5星
    294KB weixin_47723732 2021-06-30 18:29:05
  • 5星
    3.43MB weixin_44860200 2021-05-03 18:12:37
  • 5星
    1.2MB u013883025 2021-06-28 16:29:42
  • 5星
    111.52MB qq_28239511 2021-03-17 13:04:53
  • 5星
    1.18MB weixin_45771864 2021-07-19 16:11:07
  • 5星
    157KB qq_41934573 2021-05-21 23:17:41
  • 45KB weixin_38529293 2020-09-20 10:36:56
  • 1.列举当前目录以及所有子目录下的文件,并打印出绝对.../usr/bin/python# coding=utf8import osimport sys if len(sys.argv) ;."else: filepath=sys.argv[1]for root,dirs,files in os.walk(filepath): for fi...

    1.列举当前目录以及所有子目录下的文件,并打印出绝对路径#!/usr/bin/python# coding=utf8import osimport sys if len(sys.argv) < 2: filepath="."else: filepath=sys.argv[1]for root,dirs,files in os.walk(filepath): for filename in files: path=os.path.join(root,filename) print path2.写一个函数,计算字符串中所有数字的和#!/usr/bin/python# coding=utf8import sysnumber="123456"def Numsum(num): sum=0 if len(num) > 0: for i in range(len(num)): if num[i] > "0" and num[i] < "9": sum=sum+int(num[i]) print "sum=%s" % sum else: sys.exit(1)if __name__ == "__main__": Numsum(number)3.每天生成一个文件,并把磁盘的使用情况写到到这个文件中,文件名为日期格式(yyyy-mm-dd),如2018-06-10.log #!/usr/bin/python# coding=utf8import timeimport osimport getoptimport sysdisk_path="/root/disk"memory_path="/root/memory"if not os.path.exists(disk_path): os.makedirs(disk_path)if not os.path.exists(memory_path): os.makedirs(memory_path)def Disk(time): status=os.popen("df -hTP").readlines() a="".join(status) f=open("/root/disk/"+time+".log","w") f.write(a) f.close()def Memory(time): status=os.popen("free -g").readlines() a="".join(status) f=open("/root/memory/"+time+".log","w") f.write(a) f.close()time = time.strftime("%Y-%m-%d-%H:%M:%S")options,args = getopt.getopt(sys.argv[1:],"-d-m",["disk_status","memory_status"])for opt_name,opt_value in options: if opt_name in ("-d","--disk_status"): try: Disk(time) print "Disk_status Complete" exit() except: print "Fail" if opt_name in ("-m","--memory_status"): try: Memory(time) print "Memory_status Complete" exit() except: print "Fail"4.从nginx日志中统计出每个IP的访问量有多少,访问量超过10次的ip,用防火墙禁止使用,并发送邮件,三天后再打开限制,#!/usr/bin/python#coding=utf8import osimport subprocessfrom email.mime.text import MIMETextimport smtplibrefuse_ip = "/etc/nginx/refuse_nginx"sender = "wjq@123"receiver = "wujqc@yonyou.com"password = "123456"subject = "nginx ip refuse"def SendMail(ip): try: print "11111" content = ip+" is refuse" msg = MIMEText(content,"plain","utf-8") msg["From"] = sender msg["To"] = receiver msg["Subject"] = subject server=smtplib.SMTP("localhost") server.sendmail(sender,receiver,msg.as_string()) print "发送成功" except smtplib.SMTPException: print "发送失败" if not os.path.exists(refuse_ip): os.mknod(refuse_ip)def nginx_protect(ip): f=open(refuse_ip,"r+") cmd="iptables -A INPUT -p tcp --dport 80 -s "+ip+" -j DROP" cmd2="at now + 1 minutes << EOF iptables -D INPUT -p tcp --dport 80 -s "+ip+" -j DROP sed -i "s/"+ip+"//" /etc/nginx/refuse_nginx EOF" for i in f: if ip not in i: f.write(ip) os.popen(cmd) os.popen(cmd2) SendMail(ip) print("ip 限制成功") list=[]nginx_file="/var/log/nginx/access.log"f=file(nginx_file).readlines()for i in f: nginx_ip=i.split()[0] list.append(nginx_ip)nginxip=set(list)for j in nginxip: num=list.count(j) if num > 10: nginx_protect(j) print "IP:%s NUM:%s" % (j,num)5.写一个脚本计算出所有进程所占用内存大小#!/usr/bin/python# coding=utf8import oslist=[]cmd="ps aux"sum=0status=os.popen(cmd).readlines()for i in status: a=i.split()[5] list.append(a)for i in list[1:-1]: sum=sum+int(i)print "%s:%sB" % (list[0],sum) 6.MySQL状态监控#!/usr/bin/python#coding=utf8import MySQLdbhost="localhost"user="wjq"passwd="123456"db="test"Com_insert="show global status like "Com_insert";"Com_update="show global status like "Com_update";"Com_select="show global status like "Com_select";"Com_delete="show global status like "Com_delete";"Open_tables="show global status like "Open_tables";"Qcache_hits="show global status like "Qcache_hits";"def getConn(host,user,passwd,db): try: conn = MySQLdb.connect(host,user,passwd,db) return conn except: print("数据库连接失败")def getValue(conn,query): cursor = conn.cursor() getNum = cursor.execute(query) if getNum > 0: data = cursor.fetchone() return int(data[1]) if __name__ == "__main__": conn=getConn(host,user,passwd,db) Com_insert=getValue(conn,Com_insert) Com_update=getValue(conn,Com_update) Com_select=getValue(conn,Com_select) Com_delete=getValue(conn,Com_delete) Open_tables=getValue(conn,Open_tables) Qcache_hits=getValue(conn,Qcache_hits) print " *****MySQL Status*****" print " Com_insert:%s " % Com_insert print " Com_update:%s " % Com_update print " Com_select:%s " % Com_select print " Com_delete:%s " % Com_delete print " Open_tables:%s " % Open_tables print " Qcache_hits:%s " % Qcache_hits7.自定义密码长度,生成随机密码#!/usr/bin/python# coding=utf8import randomlist=[]def Passwd(num): for i in range(int(num)): a=random.randrange(0,int(num)) if i == a: b1=random.randint(0,9) list.append(str(b1)) else: b2=chr(random.randint(65,90)) list.append(b2) b3="".join(list) return b3 if __name__ == "__main__": num=raw_input("生成密码的长度为:") password=Passwd(num) print password8.python实现mysql的zabbix监控脚本#!/usr/bin/python#coding=utf8import MySQLdbimport syshost="localhost"user="wjq"passwd="123456"db="test"Com_insert="show global status like "Com_insert";"Com_update="show global status like "Com_update";"Com_select="show global status like "Com_select";"Com_delete="show global status like "Com_delete";"Open_tables="show global status like "Open_tables";"Qcache_hits="show global status like "Qcache_hits";"def getConn(host,user,passwd,db): try: a = MySQLdb.connect(host,user,passwd,db) return a except: print "数据库连接失败"def getValue(conn,query): try: cursor = conn.cursor() getNum = cursor.execute(query) if getNum > 0: data = cursor.fetchone() return int(data[1]) except: print "查询失败"conn = getConn(host,user,passwd,db)if sys.argv[1] == "insert": Com_insert = getValue(conn,Com_insert) print Com_insert elif sys.argv[1] == "delete": Com_delete = getValue(conn,Com_delete) print Com_deleteelif sys.argv[1] == "select": Com_select = getValue(conn,Com_select) print Com_selectelif sys.argv[1] == "update": Com_update = getValue(conn,Com_update) print Com_updateelif sys.argv[1] == "table_num": Open_tables = getValue(conn,Open_tables) print Open_tableselif sys.argv[1] == "cache_hit": Qcache_hits = getValue(conn,Qcache_hits) print Qcache_hits

    展开全文
    weixin_39786850 2020-11-11 14:39:18
  • 一、用python写一个列举当前目录以及所有子目录下的文件,并打印出绝对路径   #!/usr/bin/env python import os for root,dirs,files in os.walk('/tmp'):  for name in files:  print (os.path.join(root...

    一、用python写一个列举当前目录以及所有子目录下的文件,并打印出绝对路径

     

    #!/usr/bin/env python

    import os

    for root,dirs,files in os.walk('/tmp'):

        for name in files:

            print (os.path.join(root,name))

     

     

    os.walk()

    原型为:os.walk(top, topdown=True, οnerrοr=None, followlinks=False)

     

    我们一般只使用第一个参数。(topdown指明遍历的顺序)

     

    该方法对于每个目录返回一个三元组,(dirpath, dirnames, filenames)。

    第一个是路径,第二个是路径下面的目录,第三个是路径下面的非目录(对于windows来说也就是文件)

     

    os.listdir(path) 

     

    其参数含义如下。path 要获得内容目录的路径

     

     

    二、写程序打印三角形

     

    #!/usr/bin/env python

    input = int(raw_input('input number:'))

    for i in range(input):

        for j in range(i):

            print '*',

        print '\n'

     

    三、猜数器,程序随机生成一个个位数字,然后等待用户输入,输入数字和生成数字相同则视为成功。成功则打印三角形。失败则重新输入(提示:随机数函数:random)

     

    #!/usr/bin/env python

    import random

    while True:

        input = int(raw_input('input number:'))

        random_num = random.randint(1, 10)

        print input,random_num

        if input == random_num:

            for i in range(input):

                for j in range(i):

                    print '*',

                print '\n'

        else:

            print 'please input number again'

     

    四、请按照这样的日期格式(xxxx-xx-xx)每日生成一个文件,例如今天生成的文件为2013-09-23.log, 并且把磁盘的使用情况写到到这个文件中。

     

    #!/usr/bin/env python

    #!coding=utf-8

    import time

    import os

    new_time = time.strftime('%Y-%m-%d')

     

    disk_status = os.popen('df -h').readlines()

     

    str1 = ''.join(disk_status)

     

    f = file(new_time+'.log','w')

     

    f.write('%s' % str1)

    f.flush()

    f.close()

     

    五、统计出每个IP的访问量有多少?(从日志文件中查找)

    #!/usr/bin/env python

    #!coding=utf-8

    list = []

    f = file('/tmp/1.log')

    str1 = f.readlines() 

    f.close() 

    for i in str1:

        ip =  i.split()[0]

     

        list.append(ip) 

     

    list_num = set(list)

     

    for j in list_num: 

        num = list.count(j) 

        print '%s : %s' %(j,num)

     

     

     

     

     

    1. 写个程序,接受用户输入数字,并进行校验,非数字给出错误提示,然后重新等待用户输入。

    2. 根据用户输入数字,输出从0到该数字之间所有的素数。(只能被1和自身整除的数为素数)

     

    #!/usr/bin/env python

    #coding=utf-8

    import tab

    import sys

    while True:

        try:

            n = int(raw_input('请输入数字:').strip())

            for i in range(2, n + 1):

                for x in range(2, i):

                    if i % x == 0:

                        break

                else:

                    print i

        except ValueError:

            print('你输入的不是数字,请重新输入:')

        except KeyboardInterrupt:

            sys.exit('\n')

     

     

     

    python练习 抓取web页面

     

    from urllib import urlretrieve

    def firstNonBlank(lines): 

        for eachLine in lines: 

            if not eachLine.strip(): 

                continue 

        else: 

            return eachLine 

    def firstLast(webpage): 

        f=open(webpage) 

        lines=f.readlines() 

        f.close 

        print firstNonBlank(lines), #调用函数

        lines.reverse() 

        print firstNonBlank(lines), 

    def download(url= 'http://search.51job.com/jobsearch/advance_search.php',process=firstLast): 

        try: 

            retval = urlretrieve(url) [0] 

        except IOError: 

            retval = None 

        if retval: 

            process(retval) 

    if __name__ == '__main__': 

        download()

     

     

     

    Python中的sys.argv[]用法练习

     

    #!/usr/bin/python

    # -*- coding:utf-8 -*-

    import sys

    def readFile(filename):

        f = file(filename)

        while True:

            fileContext = f.readline()

            if len(fileContext) ==0:

                break;

            print fileContext

        f.close()

    if len(sys.argv) < 2:

        print "No function be setted."

        sys.exit()

     

    if sys.argv[1].startswith("-"):

     

        option = sys.argv[1][1:]

     

        if option == 'version':

            print "Version1.2"

        elif option == 'help':

            print "enter an filename to see the context of it!"

        else:

            print "Unknown function!"

            sys.exit()

    else:

        for filename in sys.argv[1:]:

            readFile(filename)

     

     

    python迭代查找目录下文件

     

    #两种方法

    #!/usr/bin/env python

    import os

     

    dir='/root/sh'

    '''

    def fr(dir):

      filelist=os.listdir(dir)

      for i in filelist:

        fullfile=os.path.join(dir,i)

        if not os.path.isdir(fullfile):

          if i == "1.txt":

            #print fullfile

        os.remove(fullfile)

        else:

          fr(fullfile)

     

    '''

    '''

    def fw()dir:

      for root,dirs,files in os.walk(dir):

        for f in files:

          if f == "1.txt":

            #os.remove(os.path.join(root,f))

            print os.path.join(root,f)

    '''

     

    一、ps 可以查看进程的内存占用大小,写一个脚本计算一下所有进程所占用内存大小的和。

    (提示,使用ps aux 列出所有进程,过滤出RSS那列,然后求和)

     

    #!/usr/bin/env python

    #!coding=utf-8

    import os

    list = []

    sum = 0   

    str1 = os.popen('ps aux','r').readlines()

    for i in str1:

        str2 = i.split()

        new_rss = str2[5]

        list.append(new_rss)

    for i in  list[1:-1]: 

        num = int(i)

        sum = sum + num 

    print '%s:%s' %(list[0],sum)

     

     

     

     

     

    写一个脚本,判断本机的80端口是否开启着,如果开启着什么都不做,如果发现端口不存在,那么重启一下httpd服务,并发邮件通知你自己。脚本写好后,可以每一分钟执行一次,也可以写一个死循环的脚本,30s检测一次。

     

    #!/usr/bin/env python

    #!coding=utf-8

    import os

    import time

    import sys

    import smtplib

    from email.mime.text import MIMEText

    from email.MIMEMultipart import MIMEMultipart

     

    def sendsimplemail (warning):

        msg = MIMEText(warning)

        msg['Subject'] = 'python first mail'

        msg['From'] = 'root@localhost'

        try:

            smtp = smtplib.SMTP()

            smtp.connect(r'smtp.126.com')

            smtp.login('要发送的邮箱名', '密码')

            smtp.sendmail('要发送的邮箱名', ['要发送的邮箱名'], msg.as_string())

            smtp.close()

        except Exception, e:

            print e

     

    while True:

        http_status = os.popen('netstat -tulnp | grep httpd','r').readlines()

        try:

            if http_status == []:

                os.system('service httpd start')

                new_http_status = os.popen('netstat -tulnp | grep httpd','r').readlines()

                str1 = ''.join(new_http_status)

                is_80 = str1.split()[3].split(':')[-1]

                if is_80 != '80':

                    print 'httpd 启动失败'

                else:

                    print 'httpd 启动成功'

                    sendsimplemail(warning = "This is a warning!!!")#调用函数

            else:

                print 'httpd正常'

            time.sleep(5)

        except KeyboardInterrupt:

            sys.exit('\n') 

     

     

     

    #!/usr/bin/python

    #-*- coding:utf-8 -*- 

    #输入这一条就可以在Python脚本里面使用汉语注释!此脚本可以直接复制使用;

     

    while True:            #进入死循环

            input = raw_input('Please input your username:')    

    #交互式输入用户信息,输入input信息;

            if input == "wenlong":        

    #如果input等于wenlong则进入此循环(如果用户输入wenlong)

                    password = raw_input('Please input your pass:')    

    #交互式信息输入,输入password信息;

                    p = '123'                  

    #设置变量P赋值为123

                    while password != p:         

    #如果输入的password 不等于p(123), 则进此入循环

                            password = raw_input('Please input your pass again:') 

    #交互式信息输入,输入password信息;

                    if password == p:        

    #如果password等于p(123),则进入此循环

                            print 'welcome to select system!'              #输出提示信息;

                            while True:           

    #进入循环;

                                    match = 0     

    #设置变量match等于0;

                                    input = raw_input("Please input the name whom you want to search :")   

    #交互式信息输入,输入input信息;

                                    while not input.strip():   

    #判断input值是否为空,如果input输出为空,则进入循环;

                                            input = raw_input("Please input the name whom you want to search :")        

    #交互式信息输入,输入input信息;

                                    name_file = file('search_name.txt')     

    #设置变量name_file,file('search_name.txt')是调用名为search_name.txt的文档

                                    while True:               

    #进入循环;

                                            line = name_file.readline()           #以行的形式,读取search_name.txt文档信息;

                                            if len(line) == 0:      #当len(name_file.readline() )为0时,表示读完了文件,len(name_file.readline() )为每一行的字符长度,空行的内容为\n也是有两个字符。len为0时进入循环;

                                                     break       #执行到这里跳出循环;

                                            if input in line:    #如果输入的input信息可以匹配到文件的某一行,进入循环;

                                                    print 'Match item: %s'  %line     #输出匹配到的行信息;

                                                    match = 1    #给变量match赋值为1

                                    if match == 0 :              #如果match等于0,则进入   ;

                                            print 'No match item found!'         #输出提示信息;

            else: print "Sorry ,user  %s not found " %input      #如果输入的用户不是wenlong,则输出信息没有这个用户;

     

     

     

    #!/usr/bin/python

    while True:

            input = raw_input('Please input your username:')

            if input == "wenlong":

                    password = raw_input('Please input your pass:')

                    p = '123'

                    while password != p:

                            password = raw_input('Please input your pass again:')

                    if password == p:

                            print 'welcome to select system!'

                            while True:

                                    match = 0

                                    input = raw_input("Please input the name whom you want to search :")

                                    while not input.strip():

                                            print 'No match item found!'

                                            input = raw_input("Please input the name whom you want to search :")

                                    name_file = file('search_name.txt')

                                    while True:

                                            line = name_file.readline()

                                            if len(line) == 0:

                                                     break

                                            if input in line:

                                                    print 'Match item: '  , line

                                                    match = 1

                                    if match == 0 :

                                            print 'No match item found!'

            else: print "Sorry ,user  %s not found " %input

     

    Python监控CPU情况

     

    1、实现原理:通过SNMP协议获取系统信息,再进行相应的计算和格式化,最后输出结果

    2、特别注意:被监控的机器上需要支持snmp。yum install -y net-snmp*安装

    """

     

    #!/usr/bin/python

    import os

    def getAllitems(host, oid):

            sn1 = os.popen('snmpwalk -v 2c -c public ' + host + ' ' + oid + '|grep Raw|grep Cpu|grep -v Kernel').read().split('\n')[:-1]

            return sn1

                                                                    

    def getDate(host):

            items = getAllitems(host, '.1.3.6.1.4.1.2021.11')

                                                                    

            date = []

            rate = []

            cpu_total = 0

            #us = us+ni, sy = sy + irq + sirq

            for item in items:

                    float_item = float(item.split(' ')[3])

                    cpu_total += float_item

                    if item == items[0]:

                            date.append(float(item.split(' ')[3]) + float(items[1].split(' ')[3]))

                    elif item == item[2]:

                            date.append(float(item.split(' ')[3] + items[5].split(' ')[3] + items[6].split(' ')[3]))

                    else:

                            date.append(float_item)

                                                                    

            #calculate cpu usage percentage

            for item in date:

                    rate.append((item/cpu_total)*100)

                                                                    

            mean = ['%us','%ni','%sy','%id','%wa','%cpu_irq','%cpu_sIRQ']

                                                                    

            #calculate cpu usage percentage

            result = map(None,rate,mean)

            return result

                                                                    

    if __name__ == '__main__':

            hosts = ['192.168.10.1','192.168.10.2']

            for host in hosts:

                    print '==========' + host + '=========='

                    result = getDate(host)

                    print 'Cpu(s)',

                    #print result

                    for i in range(5):

                            print ' %.2f%s' % (result[i][0],result[i][1]),

                    print

                    print

     

    Python监控系统负载

    1、实现原理:通过SNMP协议获取系统信息,再进行相应的计算和格式化,最后输出结果

    2、特别注意:被监控的机器上需要支持snmp。yum install -y net-snmp*安装

    """

     

    #!/usr/bin/python

    import os

    def getAllitems(host, oid):

            sn1 = os.popen('snmpwalk -v 2c -c public ' + host + ' ' + oid).read().split('\n')

            return sn1

                                                                         

    def getload(host,loid):

            load_oids = '1.3.6.1.4.1.2021.10.1.3.' + str(loid)

            return getAllitems(host,load_oids)[0].split(':')[3]

                                                                         

    if __name__ == '__main__':

            hosts = ['192.168.10.1','192.168.10.2']

            #check_system_load

            print '==============System Load=============='

            for host in hosts:

                    load1 = getload(host, 1)

                    load10 = getload(host, 2)

                    load15 = getload(host, 3)

                    print '%s load(1min): %s ,load(10min): %s ,load(15min): %s' % (host,load1,load10,load15)

     

    Python监控网卡流量

    1、实现原理:通过SNMP协议获取系统信息,再进行相应的计算和格式化,最后输出结果

    2、特别注意:被监控的机器上需要支持snmp。yum install -y net-snmp*安装

    """

    #!/usr/bin/python

    import re

    import os

    #get SNMP-MIB2 of the devices

    def getAllitems(host,oid):

            sn1 = os.popen('snmpwalk -v 2c -c public ' + host + ' ' + oid).read().split('\n')[:-1]

            return sn1

                                                                                          

    #get network device

    def getDevices(host):

            device_mib = getAllitems(host,'RFC1213-MIB::ifDescr')

            device_list = []

            for item in device_mib:

                    if re.search('eth',item):

                            device_list.append(item.split(':')[3].strip())

            return device_list

                                                                                          

    #get network date

    def getDate(host,oid):

            date_mib = getAllitems(host,oid)[1:]

            date = []

            for item in date_mib:

                    byte = float(item.split(':')[3].strip())

                    date.append(str(round(byte/1024,2)) + ' KB')

            return date

                                                                                          

    if __name__ == '__main__':

            hosts = ['192.168.10.1','192.168.10.2']

            for host in hosts:

                    device_list = getDevices(host)

                                                                                          

                    inside = getDate(host,'IF-MIB::ifInOctets')

                    outside = getDate(host,'IF-MIB::ifOutOctets')

                                                                                          

                    print '==========' + host + '=========='

                    for i in range(len(inside)):

                            print '%s : RX: %-15s   TX: %s ' % (device_list[i], inside[i], outside[i])

                    print

     

     

    Python监控磁盘

     

    1、实现原理:通过SNMP协议获取系统信息,再进行相应的计算和格式化,最后输出结果

    2、特别注意:被监控的机器上需要支持snmp。yum install -y net-snmp*安装

    """

    #!/usr/bin/python

    import re

    import os

    def getAllitems(host,oid):

            sn1 = os.popen('snmpwalk -v 2c -c public ' + host + ' ' + oid).read().split('\n')[:-1]

            return sn1

                                                                 

    def getDate(source,newitem):

            for item in source[5:]:

                    newitem.append(item.split(':')[3].strip())

            return newitem

                                                                 

    def getRealDate(item1,item2,listname):

            for i in range(len(item1)):

                    listname.append(int(item1[i])*int(item2[i])/1024)

            return listname

                                                                 

    def caculateDiskUsedRate(host):

            hrStorageDescr = getAllitems(host, 'HOST-RESOURCES-MIB::hrStorageDescr')

            hrStorageUsed = getAllitems(host, 'HOST-RESOURCES-MIB::hrStorageUsed')

            hrStorageSize = getAllitems(host, 'HOST-RESOURCES-MIB::hrStorageSize')

            hrStorageAllocationUnits = getAllitems(host, 'HOST-RESOURCES-MIB::hrStorageAllocationUnits')

                                                                 

            disk_list = []

            hrsused = []

            hrsize = []

            hrsaunits = []

                                                                 

            #get disk_list

            for item in hrStorageDescr:

                    if re.search('/',item):

                            disk_list.append(item.split(':')[3])

            #print disk_list      

                                                                 

            getDate(hrStorageUsed,hrsused)

            getDate(hrStorageSize,hrsize)

            #print getDate(hrStorageAllocationUnits,hrsaunits)

                                                                 

            #get hrstorageAllocationUnits

            for item in hrStorageAllocationUnits[5:]:

                    hrsaunits.append(item.split(':')[3].strip().split(' ')[0])

            #caculate the result

            #disk_used = hrStorageUsed * hrStorageAllocationUnits /1024 (KB)

            disk_used = []

            total_size = []

            disk_used = getRealDate(hrsused,hrsaunits,disk_used)

            total_size = getRealDate(hrsize,hrsaunits,total_size)

                                                                 

            diskused_rate = []

            for i in range(len(disk_used)):

                    diskused_rate.append(str(round((float(disk_used[i])/float(total_size[i])*100), 2)) + '%')

                                                                 

            return diskused_rate,disk_list

                                                                 

    if __name__ == '__main__':

            hosts = ['192.168.10.1','192.168.10.2']

            for host in hosts:

                    result = caculateDiskUsedRate(host)

                    diskused_rate = result[0]

                    partition = result[1]

                    print "==========",host,'=========='

                    for i in range(len(diskused_rate)):

                            print '%-20s used: %s' % (partition[i],diskused_rate[i])

                    print

     

     

    Python监控内存(swap)的使用率

     

     

    1、实现原理:通过SNMP协议获取系统信息,再进行相应的计算和格式化,最后输出结果

    2、特别注意:被监控的机器上需要支持snmp。yum install -y net-snmp*安装

    '''

    #!/usr/bin/python

    import os

    def getAllitems(host, oid):

            sn1 = os.popen('snmpwalk -v 2c -c public ' + host + ' ' + oid).read().split('\n')[:-1]

            return sn1

                                                                                

    def getSwapTotal(host):

            swap_total = getAllitems(host, 'UCD-SNMP-MIB::memTotalSwap.0')[0].split(' ')[3]

            return swap_total

                                                                                

    def getSwapUsed(host):

            swap_avail = getAllitems(host, 'UCD-SNMP-MIB::memAvailSwap.0')[0].split(' ')[3]

            swap_total = getSwapTotal(host)

            swap_used = str(round(((float(swap_total)-float(swap_avail))/float(swap_total))*100 ,2)) + '%'

            return swap_used

                                                                                

    def getMemTotal(host):

            mem_total = getAllitems(host, 'UCD-SNMP-MIB::memTotalReal.0')[0].split(' ')[3]

            return mem_total

                                                                                

    def getMemUsed(host):

            mem_total = getMemTotal(host)

            mem_avail = getAllitems(host, 'UCD-SNMP-MIB::memAvailReal.0')[0].split(' ')[3]

            mem_used = str(round(((float(mem_total)-float(mem_avail))/float(mem_total))*100 ,2)) + '%'

            return mem_used

                                                                                

    if __name__ == '__main__':

            hosts = ['192.168.10.1','192.168.10.2']

            print "Monitoring Memory Usage"

            for host in hosts:

                    mem_used = getMemUsed(host)

                    swap_used = getSwapUsed(host)

                    print '==========' + host + '=========='

                    print 'Mem_Used = %-15s   Swap_Used = %-15s' % (mem_used, swap_used)

                    print

     

    Python运维脚本 生成随机密码

     

    #!/usr/bin/env python

    # -*- coding=utf-8 -*-

    #Using GPL v2.7

    #Author: leexide@126.com

     

    import random, string        #导入random和string模块

     

    def GenPassword(length):

        #随机出数字的个数

        numOfNum = random.randint(1,length-1)

        numOfLetter = length - numOfNum

        #选中numOfNum个数字

        slcNum = [random.choice(string.digits) for i in range(numOfNum)]

        #选中numOfLetter个字母

        slcLetter = [random.choice(string.ascii_letters) for i in range(numOfLetter)]

        #打乱组合

        slcChar = slcNum + slcLetter

        random.shuffle(slcChar)

        #生成随机密码

        getPwd = ''.join([i for i in slcChar])

        return getPwd

     

    if __name__ == '__main__':

        print GenPassword(6)

     

     

    利用random生成6位数字加字母随机验证码

     

    import random

    li = []

    for i in range(6):

        r = random.randrange(0, 5)

        if r == 2 or r == 4:

            num = random.randrange(0, 9)

            li.append(str(num))

        else:

            temp = random.randrange(65, 91)

            c = chr(temp)

            li.append(c)

    result = "".join(li)  # 使用join时元素必须是字符串

    print(result)

    输出

    335HQS

    VS6RN5

    ...

     

    random.random()用于生成一个指定范围内的随机符点数,两个参数其中一个是上限,一个是下限。如果a > b,则生成随机数

     

    n: a <= n <= b。如果 a <b, 则 b <= n <= a。

     

    print random.uniform(10, 20)  

    print random.uniform(20, 10)  

    #---- 

    #18.7356606526  

    #12.5798298022  

     

    random.randint 用于生成一个指定范围内的整数。其中参数a是下限,参数b是上限,Python生成随机数

    print random.randint(12, 20) #生成的随机数n: 12 <= n <= 20 

    print random.randint(20, 20) #结果永远是20 

    #print random.randint(20, 10) #该语句是错误的。 

    下限必须小于上限。

     

    random.randrange 从指定范围内,按指定基数递增的集合中 

     

    random.randrange的函数原型为:random.randrange([start], stop[, step]),从指定范围内,按指定基数递增的集合中 获取一个随机数。

    如:

    random.randrange(10, 100, 2),结果相当于从[10, 12, 14, 16, ... 96, 98]序列中获取一个随机数。

    random.randrange(10, 100, 2)在结果上与 random.choice(range(10, 100, 2) 等效

     

    随机整数:

    >>> import random

    >>> random.randint(0,99)

    21

     

    随机选取0到100间的偶数:

    >>> import random

    >>> random.randrange(0, 101, 2)

    42

     

    随机浮点数:

    >>> import random

    >>> random.random() 

    0.85415370477785668

    >>> random.uniform(1, 10)

    5.4221167969800881

     

    随机字符:

     

    random.choice从序列中获取一个随机元素

    其函数原型为:random.choice(sequence)。参数sequence表示一个有序类型

     

    这里要说明 一下:sequence在python不是一种特定的类型,而是泛指一系列的类型。

     

    list, tuple, 字符串都属于sequence。

     

    print random.choice("学习Python")   

    print random.choice(["JGood", "is", "a", "handsome", "boy"])  

    print random.choice(("Tuple", "List", "Dict"))  

     

    >>> import random

    >>> random.choice('abcdefg&#%^*f')

    'd'

     

    多个字符中选取特定数量的字符:

     

    random.sample的函数原型为:random.sample(sequence, k),从指定序列中随机获取指定长度的片断

     

    sample函数不会修改原有序列。

     

    >>> import random

    random.sample('abcdefghij',3) 

    ['a', 'd', 'b']

     

    多个字符中选取特定数量的字符组成新字符串:

    >>> import random

    >>> import string

    >>> string.join(random.sample(['a','b','c','d','e','f','g','h','i','j'], 3)).r

    eplace(" ","")

    'fih'

     

    随机选取字符串:

    >>> import random

    >>> random.choice ( ['apple', 'pear', 'peach', 'orange', 'lemon'] )

    'lemon'

     

    洗牌:

    random.shuffle的函数原型为:random.shuffle(x[, random]),用于将一个列表中的元素打乱 .

    >>> import random

    >>> items = [1, 2, 3, 4, 5, 6]

    >>> random.shuffle(items)

    >>> items

    [3, 2, 5, 6, 4, 1]

     

     

    1、random.random

     

     random.random()用于生成一个0到1的随机符点数: 0 <= n < 1.0

     

    2、random.uniform

      random.uniform(a, b),用于生成一个指定范围内的随机符点数

    两个参数其中一个是上限,一个是下限。

     

      如果a < b,则生成的随机数n: b>= n >= a。

     

      如果 a >b,则生成的随机数n: a>= n >= b。

     

      print random.uniform(10, 20)

      print random.uniform(20, 10)

      # 14.73

      # 18.579 

     

    3、random.randint

      random.randint(a, b),用于生成一个指定范围内的整数。其中参数a是下限,参数b是上限,生成的随机数n: a <= n <= b

     

      print random.randint(1, 10)

     

    4、random.randrange

      random.randrange([start], stop[, step]),从指定范围内,按指定基数递增的集合中 获取一个随机数。

     

      如:random.randrange(10, 100, 2),结果相当于从[10, 12, 14, 16, ... 96, 98]序列中获取一个随机数。

     

    5、random.choice

      random.choice从序列中获取一个随机元素。其函数原型为:random.choice(sequence)。参数sequence表示一个有序类型。

     

      这里要说明 一下:sequence在python不是一种特定的类型,而是泛指一系列的类型。list, tuple, 字符串都属于sequence。

     

      print random.choice("Python")

      print random.choice(["JGood", "is", "a", "handsome", "boy"])

      print random.choice(("Tuple", "List", "Dict")) 

     

    6、random.shuffle

      random.shuffle(x[, random]),用于将一个列表中的元素打乱

     

      如:

     

        p = ["Python", "is", "powerful", "simple", "and so on..."]

        random.shuffle(p)

        print p

        # ['powerful', 'simple', 'is', 'Python', 'and so on...'] 

     

    7、random.sample

      random.sample(sequence, k),从指定序列中随机获取指定长度的片断。sample函数不会修改原有序列。

     

      例如:

     

      list = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10,11,12]

      slice = random.sample(list, 6)  # 从list中随机获取6个元素,作为一个片断返回

      print slice

      print list  # 原有序列并没有改变

     

     

    1.生成随机整数:

    random.randint(a,b)


    random.randint(a,b) #返回一个随机整数,范围是a <=x <= b
    >>> random.randint(888,999)
    897
    >>> random.randint(888,999)
    989
    >>> random.randint(888,999)
    995


    random.randrange(start, stop[, step]) #返回指定范围的整数
    >>> random.randrange(2,20,2)
    6
    >>> random.randrange(2,20,2)
    4
    >>> random.randrange(2,20,2)
    14
    2.浮点数


    random.random() #返回一个浮点数,范围是0.0 到1.0
    >>> random.random()
    0.22197993728352594
    >>> random.random()
    0.8683996624230081
    >>> random.random()
    0.29398514954873434


    random.uniform(a,b)#返回一个指定范围的浮点数
    >>> random.uniform(1, 10)
    3.0691737651343636
    >>> random.uniform(1, 10)
    9.142357395475619
    >>> random.uniform(1, 10)
    6.927435868405478


    3.随机序列


    random.choice()#从非空序列中返回一个随机元素
    >>> name
    ['du', 'diao', 'han', 'jiang', 'xue']
    >>> random.choice(name)
    'xue'
    >>> random.choice(name)
    'xue'
    >>> random.choice(name)
    'du'
    >>> random.choice(name)
    'du'
    >>> random.choice(name)
    'du'
    >>> random.choice(name)
    'jiang'


    #随机返回指定长度的子序列
    >>> random.sample(name,2)
    ['xue', 'du']
    >>> random.sample(name,2)
    ['diao', 'jiang']
    >>> random.sample(name,2)
    ['xue', 'du']


    生成指定长度的随机密码:


    [root@zhu ~]# python jiang.py
    GrDUytJE
    [root@zhu ~]# python jiang.py
    8XaCoUTz
    [root@zhu ~]# cat jiang.py

    import random,string

    chars=string.ascii_letters+string.digits

    print ''.join([random.choice(chars) for i in range(8)])

     

     

     

    #!/usr/bin/env python

    import random

    import string

    import sys

     

    similar_char = '0OoiI1LpP'

    upper = ''.join(set(string.uppercase) - set(similar_char))

    lower = ''.join(set(string.lowercase) - set(similar_char))

     

    symbols = '!#$%&\*+,-./:;=?@^_`~'

     

    numbers = '123456789'

     

    group = (upper, lower, symbols, numbers)

     

    def getpass(lenth=8):

        pw = [random.choice(i) for i in group]

        con = ''.join(group)

     

        for i in range(lenth-len(pw)):

     

            pw.append(random.choice(con))

     

            random.shuffle(pw)

        return ''.join(pw)

     

    genpass = getpass(int(sys.argv[1]))

    print genpass

     

     

     

    #!/usr/bin/env python

    import random

    import string

    def GenPassword(length):

     

        chars=string.ascii_letters+string.digits

     

        return ''.join([random.choice(chars) for i in range(length)])

     

    if __name__=="__main__":

        for i in range(10):

            print GenPassword(15) 

     

     

     

    #-*- coding:utf-8 -*-

    '''

    简短地生成随机密码,包括大小写字母、数字,可以指定密码长度

    '''

    #生成随机密码

    from random import choice

    import string

    #python3中为string.ascii_letters,而python2下则可以使用string.letters和string.ascii_letters

     

    def GenPassword(length=8,chars=string.ascii_letters+string.digits):

     

        return ''.join([choice(chars) for i in range(length)])

    if __name__=="__main__":

        #生成10个随机密码    

        for i in range(10):

            #密码的长度为8

            print(GenPassword(8))

     

     

     

    #!/usr/bin/env python

    # -*- coding:utf-8 -*-

    #导入random和string模块

    import random, string

    def GenPassword(length):

     

        #随机出数字的个数

        numOfNum = random.randint(1,length-1)

        numOfLetter = length - numOfNum

     

        #选中numOfNum个数字

        slcNum = [random.choice(string.digits) for i in range(numOfNum)]

     

        #选中numOfLetter个字母

        slcLetter = [random.choice(string.ascii_letters) for i in range(numOfLetter)]

     

        #打乱这个组合

        slcChar = slcNum + slcLetter

        random.shuffle(slcChar)

        #生成密码

        genPwd = ''.join([i for i in slcChar])

        return genPwd

    if __name__ == '__main__':

        print GenPassword(6)

     

     

     

     

     

     

     

     

     

    round取相邻整数

     

    print(round(1.4))

    print(round(1.8))

    输出:

    1

    2

     

    查看各个进程读写的磁盘IO

    #!/usr/bin/env python

    # -*- coding=utf-8 -*-

     

     

    import sys

    import os

    import time

    import signal

    import re

     

    class DiskIO:

       def __init__(self, pname=None, pid=None, reads=0, writes=0):

           self.pname = pname

           self.pid = pid

           self.reads = 0

           self.writes = 0

     

    def main():

       argc = len(sys.argv)

       if argc != 1:

           print "usage: please run this script like [./diskio.py]"

           sys.exit(0)

       if os.getuid() != 0:

           print "Error: This script must be run as root"

           sys.exit(0)

       signal.signal(signal.SIGINT, signal_handler)

       os.system('echo 1 > /proc/sys/vm/block_dump')

       print "TASK              PID       READ      WRITE"

       while True:

           os.system('dmesg -c > /tmp/diskio.log')

           l = []

           f = open('/tmp/diskio.log', 'r')

           line = f.readline()

           while line:

               m = re.match(\

                   '^(\S+)(\d+)(\d+): (READ|WRITE) block (\d+) on (\S+)', line)

               if m != None:

                   if not l:

                       l.append(DiskIO(m.group(1), m.group(2)))

                       line = f.readline()

                       continue

                   found = False

                   for item in l:

                       if item.pid == m.group(2):

                           found = True

                           if m.group(3) == "READ":

                               item.reads = item.reads + 1

                           elif m.group(3) == "WRITE":

                               item.writes = item.writes + 1

                   if not found:

                       l.append(DiskIO(m.group(1), m.group(2)))

               line = f.readline()

           time.sleep(1)

           for item in l:

               print "%-10s %10s %10d %10d" % \

                   (item.pname, item.pid, item.reads, item.writes)

    def signal_handler(signal, frame):

       os.system('echo 0 > /proc/sys/vm/block_dump')

       sys.exit(0)

    if __name__=="__main__":

       main()

     

     

    Python自动化运维之简易ssh自动登录

     

     

    #!/usr/bin/env python

    # -*- coding: utf-8 -*-

     

    import pexpect

    import sys

     

    ssh = pexpect.spawn('ssh root@192.168.20.103 ')

    fout = file('sshlog.txt', 'w')

    ssh.logfile = fout

     

     

    ssh.expect("root@192.168.20.103's password:")

     

    ssh.sendline("yzg1314520")

     

    ssh.expect('#')

    ssh.sendline('ls /home')

    ssh.expect('#')

     

     

     

    Python运维-获取当前操作系统的各种信息

     

     

    #通过Python的psutil模块,获取当前系统的各种信息(比如内存,cpu,磁盘,登录用户等),并将信息进行备份

    # coding=utf-8

     

    # 获取系统基本信息

    import sys

    import psutil

    import time

    import os 

     

    #获取当前时间

    time_str =  time.strftime( "%Y-%m-%d", time.localtime( ) )

    file_name = "./" + time_str + ".log"

     

    if os.path.exists ( file_name ) == False :

       os.mknod( file_name )

       handle = open ( file_name , "w" )

    else :

       handle = open ( file_name , "a" )

     

     

    #获取命令行参数的个数

    if len( sys.argv ) == 1 :

       print_type = 1

    else :

       print_type = 2

     

    def isset ( list_arr , name ) :

        if name in list_arr :

           return True

        else :

           return False

     

    print_str = "";

     

    #获取系统内存使用情况

    if ( print_type == 1 ) or isset( sys.argv,"mem" )  :

     memory_convent = 1024 * 1024

     mem = psutil.virtual_memory()

     print_str +=  " 内存状态如下:\n" 

     print_str = print_str + "   系统的内存容量为: "+str( mem.total/( memory_convent ) ) + " MB\n" 

     print_str = print_str + "   系统的内存以使用容量为: "+str( mem.used/( memory_convent ) ) + " MB\n" 

     print_str = print_str + "   系统可用的内存容量为: "+str( mem.total/( memory_convent ) - mem.used/( 1024*1024 )) + "MB\n"

     print_str = print_str + "   内存的buffer容量为: "+str( mem.buffers/( memory_convent ) ) + " MB\n" 

     print_str = print_str + "   内存的cache容量为:" +str( mem.cached/( memory_convent ) ) + " MB\n"

     

     

    #获取cpu的相关信息

    if ( print_type == 1 ) or isset( sys.argv,"cpu" ) :

     print_str += " CPU状态如下:\n"

     cpu_status = psutil.cpu_times()

     print_str = print_str + "   user = " + str( cpu_status.user ) + "\n" 

     print_str = print_str + "   nice = " + str( cpu_status.nice ) + "\n"

     print_str = print_str + "   system = " + str( cpu_status.system ) + "\n"

     print_str = print_str + "   idle = " + str ( cpu_status.idle ) + "\n"

     print_str = print_str + "   iowait = " + str ( cpu_status.iowait ) + "\n"

     print_str = print_str + "   irq = " + str( cpu_status.irq ) + "\n"

     print_str = print_str + "   softirq = " + str ( cpu_status.softirq ) + "\n" 

     print_str = print_str + "   steal = " + str ( cpu_status.steal ) + "\n"

     print_str = print_str + "   guest = " + str ( cpu_status.guest ) + "\n"

     

     

    #查看硬盘基本信息

    if ( print_type == 1 ) or isset ( sys.argv,"disk" ) :

     print_str +=  " 硬盘信息如下:\n" 

     disk_status = psutil.disk_partitions()

     for item in disk_status :

         print_str = print_str + "   "+ str( item ) + "\n"

     

    #查看当前登录的用户信息

    if ( print_type == 1 ) or isset ( sys.argv,"user" ) :

     print_str +=  " 登录用户信息如下:\n " 

     user_status = psutil.users()

     for item in  user_status :

         print_str = print_str + "   "+ str( item ) + "\n"

     

    print_str += "---------------------------------------------------------------\n"

    print ( print_str )

    handle.write( print_str )

    handle.close()

     

     

     

    Python自动化运维学习笔记

     

    psutil  跨平台的PS查看工具

    执行pip install psutil 即可,或者编译安装都行。

     

    # 输出内存使用情况(以字节为单位)

     

    import psutil

     

    mem = psutil.virtual_memory()

    print mem.total,mem.used,mem

    print psutil.swap_memory()  # 输出获取SWAP分区信息

     

    # 输出CPU使用情况

     

    cpu = psutil.cpu_stats()

    printcpu.interrupts,cpu.ctx_switches

      

    psutil.cpu_times(percpu=True)      # 输出每个核心的详细CPU信息

    psutil.cpu_times().user              # 获取CPU的单项数据 [用户态CPU的数据]

    psutil.cpu_count()                   # 获取CPU逻辑核心数,默认logical=True

    psutil.cpu_count(logical=False) # 获取CPU物理核心数

     

    # 输出磁盘信息

     

    psutil.disk_partitions()         # 列出全部的分区信息

    psutil.disk_usage('/')               # 显示出指定的挂载点情况【字节为单位】

    psutil.disk_io_counters()       # 磁盘总的IO个数

    psutil.disk_io_counters(perdisk=True)  # 获取单个分区IO个数

     

     

    # 输出网卡信息

    psutil.net_io_counter() 获取网络总的IO,默认参数pernic=False

    psutil.net_io_counter(pernic=Ture)获取网络各个网卡的IO

     

    # 获取进程信息

    psutil.pids()     # 列出所有进程的pid号

    p = psutil.Process(2047)

    p.name()   列出进程名称

    p.exe()    列出进程bin路径

    p.cwd()    列出进程工作目录的绝对路径

    p.status()进程当前状态[sleep等状态]

    p.create_time()   进程创建的时间 [时间戳格式]

    p.uids()

    p.gids()

    p.cputimes()  【进程的CPU时间,包括用户态、内核态】

    p.cpu_affinity()  # 显示CPU亲缘关系

    p.memory_percent()   进程内存利用率

    p.meminfo()   进程的RSS、VMS信息

    p.io_counters()   进程IO信息,包括读写IO数及字节数

    p.connections()   返回打开进程socket的namedutples列表

    p.num_threads()   进程打开的线程数

     

    #下面的例子中,Popen类的作用是获取用户启动的应用程序进程信息,以便跟踪程序进程的执行情况

     

    import psutil

    from subprocess import PIPE

    p =psutil.Popen(["/usr/bin/python" ,"-c","print 'helloworld'"],stdout=PIPE)

    p.name()

    p.username()

    p.communicate()

    p.cpu_times()

     

    # 其它

    psutil.users()    # 显示当前登录的用户,和Linux的who命令差不多

      

    # 获取开机时间

    psutil.boot_time() 结果是个UNIX时间戳,下面我们来转换它为标准时间格式,如下:

    datetime.datetime.fromtimestamp(psutil.boot_time())  # 得出的结果不是str格式,继续进行转换 datetime.datetime.fromtimestamp(psutil.boot_time()).strftime('%Y-%m-%d%H:%M:%S')

    展开全文
    qq_42677001 2018-12-23 17:28:47
  • 这篇文章主要为大家详细介绍了Python 自动化运维脚本示例(并行发送sh命令),具有一定的参考价值,可以用来参考一下。感兴趣Python 自动化运维脚本示例的小伙伴,下面一起跟随512笔记的小编罗X来看看吧。# 512笔记...

    这篇文章主要为大家详细介绍了Python 自动化运维脚本示例(并行发送sh命令),具有一定的参考价值,可以用来参考一下。

    感兴趣Python 自动化运维脚本示例的小伙伴,下面一起跟随512笔记的小编罗X来看看吧。

    # 512笔记网 (www.512pic.com)

    #!/usr/bin/python

    # -*- coding: UTF-8 -*-

    import paramiko

    import sys

    import threading

    #Copy local file to remote server.

    def sshclient_scp(hostname, port, username, password, local_path, remote_path):

    t = paramiko.Transport((hostname, port))

    t.connect(username=username, password=password) # 登录远程服务器

    sftp = paramiko.SFTPClient.from_transport(t) # sftp传输协议

    sftp.put(local_path, remote_path)

    t.close()

    def sshclient_scp_get(hostname, port, username, password, remote_path, local_path):

    t = paramiko.Transport((hostname, port))

    t.connect(username=username, password=password) # 登录远程服务器

    sftp = paramiko.SFTPClient.from_transport(t) # sftp传输协议

    sftp.get(remote_path, local_path)

    t.close()

    def sshclient_execmd(hostname, port, username, password, execmd):

    paramiko.util.log_to_file("paramiko.log")

    s = paramiko.SSHClient()

    s.set_missing_host_key_policy(paramiko.AutoAddPolicy())

    s.connect(hostname=hostname, port=port, username=username, password=password)

    stdin, stdout, stderr = s.exec_command(execmd)

    stdin.write("Y") # Generally speaking, the first connection, need a simple interaction.

    line=stdout.read()

    s.close()

    print (hostname+":")

    print line

    try:

    file_name = sys.argv[1]

    cmd= sys.argv[2]

    except IndexError:

    print 'Wrong params!'

    print 'Usage :'

    print ' batch.py "$OS_LIST_FILE" "$BATCH_EXECUTE_CMD"'

    print 'cat oslist.txt:'

    print '192.168.0.1,22,oracle,passwd1'

    print '192.168.0.2,22,oracle,passwd1'

    print '192.168.0.3,24,oracle,passwd1'

    print 'Format is :'

    print 'IPADDR,SSHPORT,USERNAME,PASSWORD'

    print 'Examples of usage:'

    print './batch.py "/root/workspace/oslist.txt" "df -h"'

    sys.exit()

    #file_name = sys.argv[1]

    #cmd= sys.argv[2]

    #maintenance_osinfo

    with open(file_name) as file_object:

    for line in file_object:

    splits_str = line.rstrip().split(',')

    a=threading.Thread(target=sshclient_execmd,args=(splits_str[0],int(splits_str[1]),splits_str[2],splits_str[3],cmd))

    a.start()

    #print sshclient_execmd(splits_str[0],int(splits_str[1]),splits_str[2],splits_str[3],cmd)

    # print sshclient_scp(splits_str[0], int(splits_str[1]), splits_str[2], splits_str[3], file_name, splits_str[4]+file_name)

    # End 5.1.2笔记-www.512pic.com

    注:关于Python 自动化运维脚本示例(并行发送sh命令)的内容就先介绍到这里,更多相关文章的可以留意512笔记的其他信息。

    关键词:自动化

    您可能感兴趣的文章

    展开全文
    weixin_39883374 2020-11-23 19:36:38
  • 4.3MB ht9999i 2020-09-10 22:11:37
  • 1.生成磁盘使用情况的日志文件 .../usr/bin/env python #!coding=utf-8 import time import os new_time = time.strftime('%Y-%m-%d') disk_status = os.popen('df -h').readlines() str1 = ''.join(...

    1.生成磁盘使用情况的日志文件

      #!/usr/bin/env python
        #!coding=utf-8
    
        import time
        import os
    
        new_time = time.strftime('%Y-%m-%d')
        disk_status = os.popen('df -h').readlines()
        str1 = ''.join(disk_status)
        f = file(new_time+'.log','w')
        f.write('%s' % str1)
        f.flush()
        f.close()
    

    2.探测Web服务质量

        #!/usr/bin/python
        # -*- coding: UTF-8 -*-
        # 该脚本可以定位访问web页面的服务质量
        # 通过Python下的pycurl模块来实现定位
        # 它可以通过调用pycurl提供的方法,来探测Web服务质量
        # 比如了解相应的HTTP状态码、请求延时、HTTP头信息、下载速度等
    
        import os
        import time
        import sys
        import pycurl
    
        # 探测目标URL
        URL = "http://www.baidu.com" 
    
        # 创建一个Curl对象
        c = pycurl.Curl()
        # 定义请求的URL变量
        c.setopt(pycurl.URL, URL)
        # 定义请求连接的等待时间
        c.setopt(pycurl.CONNECTTIMEOUT, 5)
        # 定义请求超时时间
        c.setopt(pycurl.TIMEOUT, 5)
        # 屏蔽下载进度条
        c.setopt(pycurl.FORBID_REUSE, 1)
        # 指定HTTP重定向的最大数为1
        c.setopt(pycurl.MAXREDIRS, 1)
        # 完成交互后强制断开连接,不重用
        c.setopt(pycurl.NOPROGRESS, 1)
        # 设置保存DNS信息的时间为30秒
        c.setopt(pycurl.DNS_CACHE_TIMEOUT,30)
    
        # 创建一个文件对象,以“wb”方式打开,用来存储返回的http头部及页面的内容
        indexfile = open(os.path.dirname(os.path.realpath(__file__))+"/content.txt", "wb")
        # 将返回的HTTP HEADER定向到indexfile文件
        c.setopt(pycurl.WRITEHEADER, indexfile)
        # 将返回的HTML内容定向到indexfile文件
        c.setopt(pycurl.WRITEDATA, indexfile)
    
        # 捕捉Curl.perform请求的提交,如果错误直接报错退出
        try:
            c.perform()
        except Exception,e:
            print "连接错误"
            indexfile.close()
            c.close()
            sys.exit()
    
        # DNS解析所消耗的时间
        NAMELOOKUP_TIME = c.getinfo(c.NAMELOOKUP_TIME)
        # 建立连接所消耗的时间
        CONNECT_TIME = c.getinfo(c.CONNECT_TIME)
        # 从建立连接到准备传输所消耗的时间
        PRETRANSFER_TIME = c.getinfo(c.PRETRANSFER_TIME)
        # 从建立连接到传输开始消耗的时间
        STARTTRANSFER_TIME = c.getinfo(c.STARTTRANSFER_TIME)
        # 传输结束所消耗的总时间
        TOTAL_TIME = c.getinfo(c.TOTAL_TIME)
        # 返回HTTP状态码
        HTTP_CODE = c.getinfo(c.HTTP_CODE)
        # 下载数据包的大小
        SIZE_DOWNLOAD = c.getinfo(c.SIZE_DOWNLOAD)
        # HTTP头部大小
        HEADER_SIZE = c.getinfo(c.HEADER_SIZE)
        # 平均下载速度
        SPEED_DOWNLOAD = c.getinfo(c.SPEED_DOWNLOAD)
    
    
        print "HTTP状态码:%d" %HTTP_CODE
        print "DNS解析时间:%.2f ms"%(NAMELOOKUP_TIME*1000)
        print "建立连接时间:%.2f ms" %(CONNECT_TIME*1000)
        print "准备传输时间:%.2f ms" %(PRETRANSFER_TIME*1000)
        print "传输开始时间:%.2f ms" %(STARTTRANSFER_TIME*1000)
        print "传输结束总时间:%.2f ms" %(TOTAL_TIME*1000)
        print "下载数据包大小:%d bytes/s" %(SIZE_DOWNLOAD)
        print "HTTP头部大小:%d byte" %(HEADER_SIZE)
        print "平均下载速度:%d bytes/s" %(SPEED_DOWNLOAD)
        indexfile.close()
        c.close()
    
    
        """
        HTTP状态码:%d 
        DNS解析时间:%.2f ms 
        建立连接时间:%.2f ms 
        准备传输时间:%.2f ms 
        传输开始时间:%.2f ms 
        传输结束总时间:%.2f ms 
        下载数据包大小:%d bytes/s 
        HTTP头部大小:%d byte 
        平均下载速度:%d bytes/s 
        """ %(HTTP_CODE, NAMELOOKUP_TIME*1000, CONNECT_TIME*1000, PRETRANSFER_TIME*1000, STARTTRANSFER_TIME*1000, TOTAL_TIME*1000, SIZE_DOWNLOAD, HEADER_SIZE, SPEED_DOWNLOAD)

    3.发送邮件告警

     import smtplib
        from email.mime.text import MIMEText
        '''
        发送邮件函数,默认使用163smtp
        :param mail_host: 邮箱服务器,16邮箱host: smtp.163.com
        :param port: 端口号,163邮箱的默认端口是 25
        :param username: 邮箱账号 xx@163.com
        :param passwd: 邮箱密码(不是邮箱的登录密码,是邮箱的授权码)
        :param recv: 邮箱接收人地址,多个账号以逗号隔开
        :param title: 邮件标题
        :param content: 邮件内容
        :return:
        '''
    
        def send_mail(username, passwd, recv, title, content, mail_host='smtp.163.com', port=25):
          msg = MIMEText(content)  # 邮件内容
          msg['Subject'] = title   # 邮件主题
          msg['From'] = username   # 发送者账号
          msg['To'] = recv      # 接收者账号列表
          smtp = smtplib.SMTP(mail_host, port=port)   # 连接邮箱,传入邮箱地址,和端口号,smtp的端口号是25
          smtp.login(username, passwd)          # 登录发送者的邮箱账号,密码
          # 参数分别是 发送者,接收者,第三个是把上面的发送邮件的 内容变成字符串
          smtp.sendmail(username, recv, msg.as_string())
          smtp.quit() # 发送完毕后退出smtp
          print('email send success.')
    
        if __name__ == '__main__':
          email_user = 'xxxx@163.com' # 发送者账号
          email_pwd = 'xxxxx' # 发送者密码,授权码
          maillist = 'xxxx@qq.com'
          title = '测试邮件标题'
          content = '这里是邮件内容'
          send_mail(email_user, email_pwd, maillist, title, content)

    4.收集系统信息

    采集系统信息包括了CPU,内存,磁盘,网络等。结合自身情况。

    psutil模块是一个跨平台的获取进程和系统应用情况(CPU,内存,磁盘,网络,传感器)的库。该模块用于系统监控、限制进程资源和运行进程的管理等方面。

    (1) CPU信息
    psutil.cpu_count() # CPU逻辑数量
    psutil.cpu_count(logical=False) # CPU物理核心
    psutil.cpu_percent() # CPU当前使用率
    
    (2) 内存信息
    mem = psutil.virtual_memory() # 实例化内存对象
    mem.total  # 系统总计内存
    mem.used  # 系统已经使用内存
    mem.free # 系统空闲内存
    psutil.swap_memory() # swap内存信息
    
    (3) 硬盘信息
    psutil.disk_usage('/')
    
    (4) 网络信息
    psutil.net_io_counters(pernic=True)
    

    4.1 CPU利用率采集脚本

     #!/bin/python
        #coding:utf-8
    
        import psutil
        import time
    
        while True:
            time.sleep(1)
            cpu_liyonglv = psutil.cpu_percent()
            print "当前cpu利用率:\033[1;31;42m%s%%\033[0m"%cpu_liyonglv

    4.2 内存使用率和用户采集脚本

     #!/bin/python
        #coding:utf-8
    
        import psutil
        import datetime
    
        free = str(round(psutil.virtual_memory().free / (1024.0 * 1024.0 * 1024.0), 2))
        total = str(round(psutil.virtual_memory().total / (1024.0 * 1024.0 * 1024.0), 2))
        memory = int(psutil.virtual_memory().total - psutil.virtual_memory().free) / float(psutil.virtual_memory().total)
        print(u"物理内存: %s G" % total)
        print(u"剩余物理内存: %s G" % free)
        print(u"物理内存使用率: %s %%" % int(memory * 100))
        # 系统启动时间
        print(u"系统启动时间: %s" % datetime.datetime.fromtimestamp(psutil.boot_time()).strftime("%Y-%m-%d %H:%M:%S"))
    
        users_count = len(psutil.users())
    
        users_list = ",".join([u.name for u in psutil.users()])
        print(u"当前有%s个用户,分别是 %s" % (users_count, users_list))

    4.3 硬盘使用率采集脚本

        #!/bin/python
        #coding:utf-8
    
        import psutil
    
        disk = psutil.disk_partitions()
        for i in disk:
            print "磁盘:%s   分区格式:%s"%(i.device,i.fstype)
            disk_use = psutil.disk_usage(i.mountpoint)
            print "使用了:%sM,空闲:%sM,总共:%sM,使用率\033[1;31;42m%s%%\033[0m,"%(disk_use.used/1024/1024,disk_use.free/1024/1024,disk_use.total/1024/1024,disk_use.percent)

    4.4 网络流量采集脚本

        #!/bin/python
        #coding:utf-8
    
        import psutil
        import time
    
        #网卡,可以得到网卡属性,连接数,当前流量等信息
        net = psutil.net_io_counters()
        bytes_sent = '{0:.2f} Mb'.format(net.bytes_recv / 1024 / 1024)
        bytes_rcvd = '{0:.2f} Mb'.format(net.bytes_sent / 1024 / 1024)
        print(u"网卡接收流量 %s 网卡发送流量 %s" % (bytes_rcvd, bytes_sent))

    5.系统批量运维管理

    paramiko是用python语言写的一个模块,遵循SSH2协议,支持以加密和认证的方式,进行远程服务器的连接。

    5.1 用户名和密码连接脚本

    5.1.1 未封装脚本

        #!/bin/python
        #coding:utf-8
    
        import paramiko
    
        # 创建SSH对象
        ssh = paramiko.SSHClient()
        # 允许连接不在know_hosts文件中的主机
        ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        # 连接服务器
        ssh.connect(hostname='192.168.1.22', port=22, username='root', password='admin123')
        # 执行命令
        stdin, stdout, stderr = ssh.exec_command('ls')
        # 获取命令结果
        result = stdout.read()
    
        # 关闭连接
        ssh.close()

    5.1.2 SSHClient 封装 Transport脚本

        #!/bin/python
        #coding:utf-8
    
        import paramiko
    
        transport = paramiko.Transport(('192.168.1.22', 22))
        transport.connect(username='root', password='admin123')
        ssh = paramiko.SSHClient()
        ssh._transport = transport
        stdin, stdout, stderr = ssh.exec_command('ifconfig')
        print stdout.read()
        transport.close()

    5.2 公钥和私钥连接脚本

    5.2.1 未封装脚本

        #!/bin/python
        #coding:utf-8
    
        import paramiko
    
        private_key = paramiko.RSAKey.from_private_key_file('/home/auto/.ssh/id_rsa')  
        # 创建SSH对象
        ssh = paramiko.SSHClient()
        # 允许连接不在know_hosts文件中的主机
        ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        # 连接服务器
        ssh.connect(hostname='c1.salt.com', port=22, username='wupeiqi', key=private_key)
    
        # 执行命令
        stdin, stdout, stderr = ssh.exec_command('df')
        # 获取命令结果
        result = stdout.read()
    
        # 关闭连接
        ssh.close()

    5.2.2 SSHClient 封装 Transport脚本

        #!/bin/python
        #coding:utf-8
    
        import paramiko
    
        private_key = paramiko.RSAKey.from_private_key_file('/root/.ssh/id_rsa')
        transport = paramiko.Transport(('192.168.1.22', 22))
        transport.connect(username='root', pkey=private_key)
        ssh = paramiko.SSHClient()
        ssh._transport = transport
        stdin, stdout, stderr = ssh.exec_command('df')
        print stdout.read()
        transport.close()

    5.3 sftp上传和下载脚本

        #!/bin/python
        import os,sys
        import paramiko
    
        t = paramiko.Transport(('192.168.1.22',22))
        t.connect(username='root',password='admin123')
        sftp = paramiko.SFTPClient.from_transport(t)
        sftp.put('C:\Users\yunwei\Desktop\error.jpg','/home/yunwei/error.jpg')
        #将error.jpg上传到服务器/home/yangmv目录
        sftp.get('/home/yunwei/sftp.txt','C:\Users\yunwei\Desktop\sftp.txt')
        #将sftp.txt下载到本机桌面
        t.close()

    5.4 批量主机命令执行脚本

    #!/bin/python
    #coding:utf-8
    
    import paramiko
    port=22
    username="root"
    file=open("ip.list")
    for line in file:
        hostname=str(line.split("\t")[0])
        password=str(line.split("\t")[4]).strip()
        print "##########################",hostname,"########################"
        s=paramiko.SSHClient()
        s.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        s.connect(hostname,port,username,password)
        stdin,stdout,sterr=s.exec_command("df -Th")
        print stdout.read()
        s.close()
    file.close()
    
    
    # ip.list
    test1   192.168.1.22    22      root    admin123
    test2   192.168.1.23    22      root    Aa123456
    展开全文
    qq_43057091 2018-08-29 10:30:09
  • SU_Devops 2019-01-25 23:29:07
  • p6620582 2021-03-15 14:18:15
  • weixin_39983427 2020-12-21 01:13:59
  • weixin_39641334 2020-12-06 13:55:59
  • weixin_39620278 2020-12-05 17:58:50
  • weixin_37988176 2020-10-29 22:46:27
  • weixin_37988176 2020-10-31 16:50:03
  • renfengjun 2017-11-29 09:01:46
  • chengqiuming 2019-01-07 21:19:37

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 25,134
精华内容 10,053
关键字:

python自动化运维脚本

python 订阅