python中summary_python summary_study.py
#!/usr/bin/env python
#-*- coding:utf-8 -*-
import os,sys,time,shutil,re
from _ast import Num
from django.db.models.sql.datastructures import Join
'''
---------------------------
此腳本用于之前學習內容的回顧
裝飾器還需要多看，目前還是不是很清楚
類的繼承
property需要學習
抽象方法/私有字段/私有方法/靜態字段/靜態方法
__call__方法
__del__方法
---------------------------
'''
#-------------------遞歸例子---------------------
'''
#函數
def fun2(n):
result = n
for i in range(1,n):
result *= i
return result
print 'fun2',fun2(5)
#遞歸
def fun3(n):
if n == 1:
return 1
else:
return n*fun3(n-1)
print 'fun3',fun3(5)
def fun(n):
if n == 1:
return 1
else:
return n+fun(n-1)
print fun(5)
def fun1(x):
if x == 0 or x ==1:
return 1
else:
return fun1(x-1) + fun1(x-2)
print fun1(5)
如果說兔子在出生兩個月后，就有繁殖能力，在擁有繁殖能力之后，這對兔子每個月能生出
一對小兔子來。假設所有兔子都不會死去，能夠一直干下去，那么一年之后可以繁殖多少對
兔子呢？
def tuzi(x):
if x==1 or x==2:
return 1
else:
return tuzi(x-1)+tuzi(x-2)
print tuzi(5)
'''
#-------------------遞歸 遍歷目錄下所有文件---------------------
'''
#----------列表推導式列出所有文件
path = 'd:/python'
os.chdir(path)
a = [i for i in os.listdir(path) if os.path.isfile(i)]
for x in a:
print x
#等同下面
for i in os.listdir('d:/python'):
a = os.path.join('d:/python',i)
print os.path.isfile(a)
if os.path.isfile(i):
print i
path = 'd:/python'
os.chdir(path)
a = [i for i in os.listdir(path) if os.path.isfile(i) and os.path.splitext(i)[1] =='.zip']
print a
path = 'd:/python'
#----------遞歸方式
#可采用os.path.join拼接路徑的方式，來確認完整路徑，避免使用路徑切換，os.chdir
def scan(path):
for file in os.listdir(path):
file_dir = os.path.join(path,file)
if not os.path.isdir(file_dir):
print file_dir
else:
scan(file_dir)
scan(path)
#----------os.walk方式
g = os.walk('d:/python')
for path,folder,filelist in g:
print filelist
for filename in filelist:
print os.path.join(path,filename)
'''
#------------------文件夾整理-----------------------
'''
def file_summary(path):
for file in os.listdir(path):
file_dir = os.path.join(path,file)
if os.path.isdir(file_dir):
file_summary(file_dir)
else:
file_name = ''.join(re.findall('201\d{5}',file))
Folder_name = os.path.join(path,file_name)
try:
if not os.path.exists(Folder_name):
os.mkdir(Folder_name)
wjy_num += 1
try:
if file_dir not in os.listdir(Folder_name):
print file_dir
shutil.move(file_dir,Folder_name)
except:
print 'error'
file_num += 1
except:
print '沒找到日期'
file_summary(path)
'''
# print '''
# -------------------------------------------------------
# 此腳本用于整理文件，按圖片名日期進行分類，每個日期建
# 一個新的文件夾，將同一天的文件放入文件夾中
# -------------------------------------------------------
# '''
'''
def fodler_time_fengnei(path):
wjy_num = 0
file_num = 0
os.chdir(path)
for i in os.listdir(path):
#print i
Folder_file = ''.join(re.findall('201\d{5}',i))
#print Folder_file
try:
#lock.acquire()
if not os.path.exists(Folder_file):
os.mkdir(Folder_file)
wjy_num += 1
try:
if i not in os.listdir(Folder_file):
shutil.move(i,Folder_file)
except:
print 'error'
#lock.release()
file_num += 1
except:
print '沒找到日期'
print '處理了%d個文件'%file_num
print '創建了%d個文件夾'%wjy_num
print '分類完成'
#print os.getcwd()
def folder_vedio(path):
os.chdir(path)
#os.walk 得到一個三元數組：路徑，路徑下的文件夾，文件
for i,k,v in os.walk(path):
print i,k,v
#迭代文件夾目錄
for folder in k:
#進入每個文件夾
os.chdir(folder)
#迭代當前文件夾下的文件
for img in os.listdir(os.curdir):
print img
try:
ext = img.split('.')[1] #得到擴展名
print ext
except:
print 'error'
if ext != 'jpg': #如果不是圖片文件
shutil.move(img, os.pardir) #移動到上一級目錄
os.chdir(os.pardir)
#此函數用于將文件夾下的所有文件移動到指定的目錄中，
#目前只有一層目錄功能 2016/12/27更新
def file_move(path,dst):
os.chdir(path) #這里一定要先進入到需要整理的目錄中
for i,k,v in os.walk(path):
print i,k
for folder in k:
try:
print os.getcwd()
os.chdir(folder)
for file in os.listdir(os.curdir):
shutil.move(file, dst)
except Exception,e:
print e
os.chdir(os.pardir)
#以下用于移動文件,已成功實現所需功能 2016/12/28
def file_move(path,dst):
os.chdir(path)
n = 1
#dst = 'd:\\pooto\\p'
#這里用os.walk產生一個生成器，再通過迭代，列出目錄下所有的子目錄和文件
#os.walk以遞歸的方式遍歷當前目錄下的所有文件和目錄
for path1,file_dir,fs in os.walk(path):
# print 'PATH 第%d次:'%n,path1
# print 'DIR:第%d次:'%n,file_dir
# print 'FS第%d次:'%n,fs
#確認當前目錄下是否有文件，沒有跳過
if fs==[]:
pass
#print '空的'
else:
file_num = 0
try:
#如果有文件，迭代一下
for file in fs:
#進入目錄
os.chdir(path1)
#print '當前路徑是： '+os.getcwd()+', 當前文件是： '+file
ext = file.split('.')[-1] #取最后一個就是擴展名
#print ext
if ext == 'jpg' or ext =='png':
try:
shutil.move(file,dst) #移動到指定目錄
#print 'move was ok'
file_num += 1 #統計移動文件的個數
except Exception,e: #出錯了，提示原因
#print e
print u'移動文件出錯了，快查一下原因'
#shutil.move(file,del_dir)
except:
print u'迭代序列出錯了'
print u'移動了%d個文件'% file_num
os.chdir(os.pardir) #當前目錄完成了，跳回主目錄，進行下一次迭代目錄
n += 1
if __name__ == '__main__':
-------------------------------------------------
請選擇你需要的功能：
1. 對圖片按名稱分組
2. 對圖片按后綴分組
3. 將文件移動到另一目錄中
-------------------------------------------------
select1 = raw_input(':')
start_time = time.time()
if select1 == '1':
#lock = threading.Lock()
path = raw_input(u'如:g:/software/DIM :').strip()
fodler_time_fengnei(path)
# t1 = threading.Thread(target=fodler_time_fengnei,args=(path,))
# t2 = threading.Thread(target=fodler_time_fengnei,args=(path,))
# t3 = threading.Thread(target=fodler_time_fengnei,args=(path,))
elif select1 =='2':
pass
elif select1 == '3':
print u'源文件夾：'
path = raw_input(u'如:g:/software/DIM :').strip()
dst = raw_input(u'目標文件夾：').strip()
file_move(path, dst)
# 多線程沒什么效果
# t1 = Thread(target=file_move,args=(path,dst))
# t2 = Thread(target=file_move,args=(path,dst))
# t3 = Thread(target=file_move,args=(path,dst))
# p1.start()
# print 't1'
# t2.start()
# print 't2'
# t3.start()
# print 't3'
end_time = time.time()
print u'總共花了%.2f秒'%(end_time-start_time)
# path = raw_input('[eg:g:/software/DIM] :').strip()
# #os.chdir(path)
# file_num = 0
# wjy_num = 0
# # folder_vedio(path)
# fodler_time_fengnei(path)
# print '總共整理了%d個文件'%file_num
# print '總共創建了%d個文件夾'%wjy_num
'''
#------------------局部變量-----------------------
'''
var = 1
def a():
global var
var += 1
var1 = 2
# print var
def b():
print var1
nolocal #這里2.7好像有問題，3.x好像是好的
var1 = 5
#print var1
b()
a()
'''
#------------------------Pexpect練習----------------------
'''
用于登錄Cisco設備并獲取相關信息，每次一個命令，完成后自動退出
適用于Linux
'''
'''
def get(pe,cmd):
login = 'telnet %s' % pe
username = 'pingtest'
password = 'pwdtest'
tn = pexpect.spawn(login,timeout = 300)
index = tn.expect(["Username",pexpect.EOF, pexpect.TIMEOUT])
if index == 0:
tn.expect('Username:')
tn.sendline(username)
tn.expect('Password:')
tn.sendline(password)
tn.expect('#')
tn.sendline(cmd)
tn.sendline(' ')
tn.expect('#')
result = tn.before
tn.sendline('exit')
print result
elif index == 1:
print 'pexpect.EOF'
else:
print 'pexpect.TIMEOUT'
if __name__ == '__main__':
tupe1 = {
'Mon':'星期一',
'Tue':'星期二',
'Wen':'星期三',
'Thu':'星期四',
'Fri':'星期五',
'Sat':'星期六',
'Sun':'星期天'
}
wenday = time.strftime('%a')
xiqi = tupe1[wenday]
while True:
print '\n'
pe = (raw_input('請輸入你需要登錄的PE[退出請用q]:')).strip()
print '\n'
if pe == 'q':
break
else:
cmd = (raw_input('請輸入你需要執行的命令[退出請用q]:')).strip()
if cmd == 'q':
break
print '\n\n'
print '當前查詢時間：%s'%((time.strftime('%Y/%m/%d %H:%M:%S'))+' '+ xiqi)
print '-----------------------------------------------------'
print '\n'
get(pe,cmd)
'''
#------------------------裝飾器實驗1----------------------
# def out(fun):
# def watter():
# print '之前出現'
# fun()
# print '之后出現'
# return watter
#
# @out
# def fun1():
# print '這是Fun1的內容'
#
# fun1()
# ---------帶參數的裝飾器
# def out(fun):
# def watter(args):
# print '之前出現'
# fun(args)
# print '之后出現'
# return watter
#
# @out
# def fun1(args):
# print '這是Fun1的內容',args
#
# fun1(100)
#---------帶返回的裝飾器
# def out(fun):
# def watter(args):
# print '之前出現'
# a =fun(args)
# print '之后出現'
# print a
# return watter
#
# @out
# def fun1(args):
# return u'這是Fun1的內容',args
#
# fun1(100)
#-----下面這個例子很好說明的裝飾器的運行
# def timeslong(func):
# def call():
# start = time.clock()
# print("It's time starting ! ")
# func()
# print("It's time ending ! ")
# end = time.clock()
# return "It's used : %s ." % (end - start)
# return call
#
# @timeslong
# def f():
# y = 0
# for i in range(10):
# y = y + i + 1
# print(y)
# return y
#
# print(f())
#------------------------property---------------------
# class A:
# def __init__(self):
# print '這是A的Self'
#
# def B(self):
# print '這是B的方法'
#
# @property
# def C(self):
# # print '這是C的方法'
# return '這是C的方法'
#
# a = A()
# print a
# print a.B()
# print a.C
#
#
# class C:
# def __init__(self):
# self._x = None
#
# @property
# def x(self):
# """I'm the 'x' property."""
# return self._x
#
# @x.setter
# def x(self, value):
# self._x = value
#
# @x.deleter
# def x(self):
# del self._x
#
#
# c1 = C()
# c1.x = 3
# print c1.x
#########################################################
#------------------------抽象方法---------------------
#抽象類抽象方法＝＝接口
from abc import ABCMeta,abstractmethod
# class Bar:
# __metaclass__ = ABCMeta
#
# @abstractmethod
# def get(self):
# raise 'no define get '
#
# class Car(Bar):
# def __init__(self):
# print '這是一個Car的類'
#
# # def get(self):
# # print 'aaa'
#
# car = Car()
# class Bar:
# __metaclass__ = ABCMeta
#
# @abstractmethod
# def Fun(self):
# pass
#
# class Foo(Bar):
# def __init__(self):
# print '__init__'
#
# # def Fun(self):
# # print '告警'
#
# f = Foo()
# f.Fun()
#########################################################
#------------------------私有字段/方法---------------------
# class Bar:
# def __init__(self):
# self.__x = 10
#
# def __get(self):
# print '這是私有方法'
# #可以通過動態方法調用私有方法
# def show(self):
# print self.__get()
#
# b = Bar()
# print b._Bar__x #強制使用類的方式來訪問私有方法
# print b.show()
#------------------------靜態字段/方法---------------------
# class Bar:
# name = 'liyang'
# @staricmethod
# def hello():
# print 'Hello'
#
# b = Bar()
# print b.name
# print b.hello()
# 靜態字段和靜態方法無需實例化，可通過用類來調用
#########################################################
#------------------------靜態字段/方法---------------------
#__call__ 最后執行
#__del__ 什么時候使用,直接用對象加括號就可以調用了
# class Bar:
# def __init__(self):
# print '這是__init__'
#
# def __call__(self):
# print '這是__call__'
#
# def __del__(self):
# print '我就要被刪除了'
#
# def show(self):
# print '這是一個顯示的函數'
#
# b = Bar()
# print b
# print b() #調用call方法
# print b.show()
#########################################################
#------------------------類的繼承---------------------
#新式類必須加object,同時多重繼承是廣度優先，經典類是深度優先
# class A(object):
# def __init__(self):
# print '這是A的__init__'
#
# def show(self):
# print '這是顯示A的類'
#
# class B(A):
# def __init__(self):
# #A.__init__(self)
# super(B,self).__init__() #這里的super值為當前類，主類必須是新式類
# print '這是B的__init__'
#
# class C(A):
# def __init__(self):
# print '這是C的__init__'
#
# def show(self):
# print '這是顯示C的類'
#
# class D(B,C):
# def __init__(self):
# print '這是D的__init__'
#
#
# # b1 = B()
# # print b1
#
# d1 = D()
# print d1
# print d1.show()
#--------------------使用super也可以在經黃類中避免深度優先的問題------------------
# class A():
# def __init__(self):
# print '這是A的__init__'
#
# def show(self):
# print '這是顯示A的類'
#
# class B(A):
# def __init__(self):
# #A.__init__(self)
# super().__init__() #這里的super，可以避免深度優先的問題
# print '這是B的__init__'
#
# class C(A):
# def __init__(self):
# print '這是C的__init__'
#
# def show(self):
# print '這是顯示C的類'
#
# class D(B,C):
# def __init__(self):
# print '這是D的__init__'
#
# b1 = B()
# print b1
# d1 = D()
# print d1
# print d1.show()
#########################################################
'''
------------------------------
字符編碼：ASCII/Unicode/UTF-8
decode的作用是將其他編碼的字符串轉換成unicode編碼，
encode的作用是將unicode編碼轉換成其他編碼的字符串，
Unicode
Unicode-----encode---->UTF
------------------------------
'''
#------------------------編碼學習---------------------
# name = '李明'
# print '第一次',name
# if not isinstance(name,unicode):
# name = name.decode('utf-8')
# print name
#
#########################################################
# import datetime
# #顯示當前日期
# print datetime.date.today()
# print datetime.date.today() - datetime.timedelta(days = 2)
# #顯示指定日期
# print datetime.date(2015, 4, 2)
#
# print datetime.time(1,2,3)
#------------------------生成器---------------------
# def a():
# for i in range(10):
# yield i
#
# a1 = a()
# print a1.next()
# print a1.next()
#########################################################
#--------------------Excel Into Mysql--------------------
# import pymysql
# import xlrd
#
# def xls_info():
# xls = xlrd.open_workbook('d:/bb.xls') #打開Excel
# sheets = xls.sheet_names() #獲取表
# table = xls.sheet_by_name(sheets[2]) #得到需要的表名
# rows = table.nrows #獲取表的總行數
# return table,rows #返回表名和行數
#
# def mysql_info():
# myconn = pymysql.Connect('127.0.0.1','root','','django') #連接Mysql
# mycur = myconn.cursor() #創建游標
# mycur.execute('set names utf8') #指定為utf8編碼
# #創建表格
# # table_create = 'CREATE TABLE mysql_test(name varchar(20),ip varchar(20));'
# # mycur.execute(table_create)
# mycur.execute('desc mysql_test')
# #插入表格的命令
# insert_sql = 'insert into mysql_test values(%s,%s);'
#
# #調用上個函數的值，得到表名和行數
# table,rows=xls_info()[0],xls_info()[1]
# for i in range(0,rows): #迭代每行
# xls_line = table.row_values(i) #得到每行的信息
# print xls_line
# print mycur.execute(insert_sql,xls_line) #插入每行的數據到數據庫中
# mycur.execute('select * from mysql_test')
# print mycur.fetchall()
# myconn.commit() #事務提交
# mycur.close()
# myconn.close()
#
# mysql_info()
#-------------Mysql得到字典------------------------
#!/usr/bin/env python
# encoding: utf-8
#Created on 2017年1月13日
#@author: Administrator
'''
import pymysql
def main():
try:
conn = pymysql.connect(host = '127.0.0.1', user = 'root', passwd = '', db = 'django')
cur = conn.cursor(cursor=pymysql.cursors.DictCursor)
cur.execute("select * from mysql_test")
qur_result = cur.fetchall()
cur.close()
conn.close()
# for record in qur_result:
# user = record[0]
# passwd = record[1]
except pymysql.Error,e:
print 'Mysql Error Msg:',e
#print type(qur_result)
for k in qur_result:
#print k
for i,j in k.items():
print j
if __name__ == '__main__':
main()
'''
#-------------------線程練習------------------------
import threading
from IPython.utils.io import stdin, stderr
from sys import stdout
import paramiko
'''
def Foo(args):
for i in range(10):
print i
time.sleep(1)
print '開始'
t1 = Thread(target=Foo,args = (1,))
#t1.setDaemon(True)
t1.start()
print t1.getName()
'''
#-------------------自定義線程練習------------------------
'''
class MyThread(Thread):
def run(self):
Thread.run(self)
print 'run'
for i in range(10):
print i
time.sleep(1)
def Foo(args):
print '這是我的新函數'
t1 = MyThread(target=Foo,args =(1,))
t1.start()
print t1.getName()
print t1.isDaemon()
print t1.join(3)
'''
#-------------------生產消費模型------------------------
'''
#兩個類都是一樣的，要用到隊列，有兩個判斷條件，是否為空，是否為滿
import Queue
class ShenChang(Thread):
def __init__(self,name,que):
self.__Name = name
self.__Que = que
Thread.__init__(self)
def run(self):
while True:
if self.__Que.full():
print '做完了，可以休息一下了'
time.sleep(1)
else:
self.__Que.put('xxx')
print self.__Name,'生產包子'
Thread.run(self)
que = Queue.Queue(maxsize=30)
for x in range(10):
name = 'alan%d'%x
s1 = ShenChang(name,que)
s1.start()
class XiaFei(Thread):
def __init__(self,name,que):
self.__Name = name
self.__Que = que
Thread.__init__(self)
def run(self):
while True:
if self.__Que.empty():
print '沒有吃的了，先休息一下吧'
time.sleep(2)
else:
self.__Que.get()
print self.__Name,'吃了一個包子'
Thread.run(self)
for i in range(3):
name = 'name%d'%i
t1 = XiaFei(name,que)
t1.start()
'''
#-------------------paramiko用戶名和密碼------------------------
'''
import paramiko
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect('114.28.37.23', 50022, 'root', '263!@#$%^&*()')
print 'connected..............'
while True:
cmd = raw_input('請輸入你要執行的命令[退出q] : ')
if cmd == 'q':
print '\nbye---------\n------------'
sys.exit()
stdin,stdout,stderr = ssh.exec_command(cmd)
print stdout.read()
ssh.close()
'''
#-------------------paramiko Key-----------------------
'''
#在執行前要手工在目標機器上輸入以下命令：
# ssh-keygen -t rsa 創建密鑰
# ssh-copy-id root@114.28.37.209 將公鑰Copy到服務器
private_key_path = '/root/.ssh/id_rsa'
key = paramiko.RSAKey.from_private_key_file(private_key_path)
paramiko.util.log_to_file('paramiko.log') #加入日志
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect('127.0.0.1', 22, username='root', pkey=key)
stdin,stdout,stderr = ssh.exec_command('ls')
print stdout.read()
ssh.close()
'''
#-------------------paramiko 創建刪除顯示 ssh router-----------------------
'''
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
#IP,Port,Username,Password='114.141.185.5',22, 'opsinfo', 'pwdops'
IP,Port,Username,Password='114.141.185.5',22, 'opsinfo', 'pwdops'
try:
ssh.connect(IP,Port,Username,Password, look_for_keys=False, allow_agent=False)
except Exception,e:
print e
print 'ssh connection established to %s' % IP
remote_conn = ssh.invoke_shell()
#print remote_conn.recv(1000)
remote_conn.send('\n')
remote_conn.send('sh ip int bri\n')
time.sleep(2)
print remote_conn.recv(10000)
#stdin,stdout,stderr = ssh.exec_command('sh ver')
# ssh.connect('1172.16.4.1', 23, 'opsinfo', 'pwdops')
# stdin,stdout,stderr = ssh.exec_command('sh ver')
#print stdout.read()
ssh.close()
'''
#-------------socket登錄路由器測試-----------------
'''
import socket
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
ip_port =('172.16.4.1',23)
sock.connect(ip_port)
sock.send('opsinfo\n')
time.sleep(1)
sock.send('pwdops\n')
time.sleep(1)
sock.send('sh ver')
time.sleep(1)
data1 = sock.recv(1024)
time.sleep(1)
print data1
'''
#-------------------paramiko上傳下載-----------------------
'''
print os.getcwd()
os.chdir('d:/')
print os.getcwd()
t = paramiko.Transport(('114.28.37.23', 50022))
t.connect(username='root', password='263!@#$%^&*()')
sftp = paramiko.SFTPClient.from_transport(t)
local_path = 'd:/lsdksmq-v2.0.0.200.zip'
base_name = os.path.basename(local_path)
remote_path = '/home/'+base_name
sftp.put(local_path,remote_path) #上傳
#sftp.get(remote_path,local_path) #下載
t.close()
'''
'''
t = paramiko.Transport(('114.28.13.143', 22))
t.connect(username='root', password='111111')
sftp = paramiko.SFTPClient.from_transport(t)
print sftp.listdir('/smb')
print sftp.rename('/smb/Flow.rrd.bak','/smb/Flow.rrd.bak1')
print sftp.mkdir('/home/aa1',0755)
print sftp.listdir('/home')
'''
#-------------------paramiko+threading-----------------------
'''
用函數將Paramiko的代碼包起來，再通過我線程來同時操作
def SshCmd(server,username,password,cmd):
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(server,50022,username, password)
stdin,stdout,stderr = ssh.exec_command(cmd)
print server, '\n %s'% cmd,
print stdout.read()
ssh.close()
if __name__ =='__main__':
username = 'root'
password = '263!@#$%^&*()'
cmds = ['ls -lh /']
ips = ['114.28.37.23','114.28.37.24']
for ip in ips:
for cmd in cmds:
temp = Thread(target=SshCmd,args=(ip,username,password,cmd))
temp.start()
'''
#-------------------threading 異步模型-----------------------
'''
import threading
def shengchang():
print u'P:做包子………………'
event.wait()
event.clear()
print u'P:做包子'
time.sleep(3)
print u'P:你的包子做好了'
event.set()
def xiaofei():
print u'C:買包子去………………'
event.set()
time.sleep(2)
print u'C:等做包子……………… '
#print event.wait()
while True:
if event.isSet():
print u'C:太好了'
break
else:
print '做其他事情去了……'
time.sleep(0.08)
event = threading.Event()
p = threading.Thread(target=shengchang)
c = threading.Thread(target=xiaofei)
p.start()
c.start()
'''
#-------------------IP換算----------------------
'''
def ch1(num):
s = []
for i in range(4):
s.append(str(num%256))
print s
num /= 256
return '.'.join(s[::-1])
print ch1(123456789)
#用lambda的方式，整數toIP 地址 一行代碼搞定
ch2 = lambda x: '.'.join([str(x/(256**i)%256) for i in range(3,-1,-1)])
print ch2(123456789)
#用lambda的方式，IP地址轉換到整數
ch3 = lambda x:sum([256**j*int(i) for j,i in enumerate(x.split('.')[::-1])])
print ch3('7.91.205.21')
'''
#-------------------IP敬意計算----------------------
import os
'''
def getip(ip, count):
count = int(count)
ip2 = int(ip.split('.')[-2])
ip1 = int(ip.split('.')[-1])
ip_before = '%s.%s' % (ip.split('.')[0], ip.split('.')[1])
for i in range(0,count,4):
new_ip1 = ip1 + i
if 11 <= new_ip1 <= 254:
print '%s.%s.%s' % (ip_before, str(ip2), str(new_ip1))
else:
new_ip2 = ip2 + int(new_ip1/254)
new_ip1 = new_ip1%254 + 0
print '%s.%s.%s' % (ip_before, str(new_ip2), str(new_ip1))
if __name__ == '__main__':
getip('10.0.1.0', 1000)
'''
'''
def getip(ip, count,step):
count = int(count)
ip1 = int(ip.split('.')[-1])
ip2 = int(ip.split('.')[-2])
ip3 = int(ip.split('.')[-3])
ip4 = int(ip.split('.')[-4])
ip_before = '%s.%s' % (ip.split('.')[0], ip.split('.')[1])
for i in range(0,count,step):
new_ip1 = ip1 + i
#print '%s.%s.%s' % (ip_before, str(ip2), str(new_ip1))
if new_ip1 <= 255:
pass
print '%s.%s.%s' % (ip_before, str(ip2), str(new_ip1))
else :
new_ip2 = ip2 + int(new_ip1/256)
if new_ip2 <= 255:
new_ip1 = new_ip1%256
print '%s.%s.%s' % (ip_before, str(new_ip2), str(new_ip1))
else:
new_ip3 = ip3 + int(new_ip2/256)
new_ip2 = ip1 + int(new_ip1/256)
new_ip1 = new_ip1%256
#print 'ip1------------:',new_ip1
new_ip2 = 0
if new_ip1 >= (256/step-1)*step:
new_ip2 += 1
new_ip1 = new_ip1%256
#print 'ip2-----:',new_ip2
print '%s.%s.%s.%s' % (str(ip4),str(new_ip3), str(new_ip2), str(new_ip1))
if __name__ == '__main__':
getip('10.0.255.192',830,32)
'''
#---------------------pexpect 交互連接------------------------
'''
#!/usr/bin/env python
#coding=utf-8
import pexpect
import time,re
import pymysql
loginprompt = '#'
def get(login_ip):
login = 'telnet %s' % login_ip
tn = pexpect.spawn(login,timeout = 300)
#tn.expect('Username:')
flag = tn.expect(["login","Username:", "(?i)Unknown host", pexpect.EOF, pexpect.TIMEOUT])
username = 'opsinfo'
password = 'pwdops'
if flag == 0 or flag == 1:
tn.sendline(username)
tn.expect('Password:')
tn.sendline(password)
tn.expect(r'[#>]')
print tn.before
#交互開始
tn.interact()
print 'Left interactv mode'
else:
print 'error'
if __name__ == '__main__':
login_ip = raw_input('IP: ')
get(login_ip)
'''
#---------------------ping 主機------------------------
'''
#!/usr/bin/env python
import multiprocessing
import subprocess
import time
start_time = time.time()
host_list = ['192.168.100.254','1.1.1.1','192.168.100.253','114.28.127.2','114.28.127.72','114.28.127.70','114.28.127.12','114.28.127.56','114.28.127.102']
if len(host_list) > 30:
process_number = 30
else:
process_number = len(host_list)
def ping_host(ipaddr):
if subprocess.call('ping -c5 -W 1 %s > /dev/null' % ipaddr, shell=True) == 0:
#if subprocess.call('ping -c1 -W 1 %s ' % ipaddr, shell=True) == 0:
print '%s is OK' % ipaddr
else:
print '%s is DOWN' % ipaddr
pool = multiprocessing.Pool(processes=10)
for ip in host_list:
pool.apply_async(ping_host,(ip,))
#pool.map(ping_host,host_list)
pool.close()
pool.join()
end_time = time.time()
print 'It is take %.2f seconds'%(start_time-end_time)
'''
#---------------------從文件中找出IP地址------------------------
'''
import re
f = file('d:\ip.txt','rb')
set1 = set()
for line in f.xreadlines():
try:
ip = ''.join(re.findall('(?:\d+\.){3}\d{1,3}', line))
#print ip
set1.add(ip)
except:
pass
f.close()
set1 = sorted(set1)
#print set1
for i in set1:
print i
'''
#---------------------用Pexpect登錄設備并測試Ping-----------------------
'''
#!/usr/bin/env python
#-*- coding:utf-8 -*-
import pexpect
import re
import time
問題：
1.迭代查詢和Ping包，第二次總是看不到查詢的結果，導致搜索錯誤，在Python中直接測試正常
2.另一個問題：通過expect如果PIng不到，是否有返回結果，好像看不到
f = file('/smb/python_s8/day8/ip.txt','rb')
username = 'pingtest'
password = 'pwdtest'
tn = pexpect.spawn('telnet 219-mr01')
#index = tn.expect(["Username:",pexpect.EOF, pexpect.TIMEOUT])
try:
#if index == 0:
tn.expect('Username:')
tn.sendline(username)
tn.expect('Password:')
tn.sendline(password)
print 'auth is ok'
x= 1
for line in f.xreadlines():
#print line
tn.expect('#')
#print 'is this running?'
tn.sendline('sh ip vrf interface | inc %s' % line)
tn.expect('#')
result = tn.before
tn.expect('#')
# print len(result)
print '-------------------this is %d result:---------------\n%s\n'%(x,result)
ip = ''.join(re.findall('(?:\d+\.){3}\d{1,3}', result))
vrf = ''.join(re.findall('(\w{3,5}\d{3,6}\w+)',result))
print 'ip: %s , vrf: %s' %(ip,vrf)
#這里更改目標IP地址
ip1= ip.split('.') #分割IP
if ip1[0] == '114':
ip1[3] =str(int(ip.split('.')[-1])+1) #替換最后一個IP數字
else:
ip1[3] =str(int(ip.split('.')[-1])-1) #替換最后一個IP數字
targetIP ='.'.join(ip1)
#組合命令
cmd = 'ping vrf %s %s re 2'%(vrf,targetIP)
print cmd
try:
tn.sendline(cmd)
except:
print 'error'
time.sleep(10)
tn.expect('#')
#tn.expect('#')
result1 = tn.before
print result1
#tn.sendline('\r\r\r')
x += 1
tn.sendline('exit')
# elif index == 1:
# print 'pexpect.EOF'
# else:
# print 'pexpect.TIMEOUT'
except Exception,e:
print e
'''
#---------------------Jump跳板機----------------------
#!/usr/bin/python
# # coding:utf-8
# import sys
# import time
# import re
# import pexpect
# import os
# import struct
# import fcntl
# import termios
# import signal
# import MySQLdb
#
#
# def sigwinch_passthrough (sig, data):
# winsize = getwinsize()
# global child
# child.setwinsize(winsize[0],winsize[1])
#
# def getwinsize():
# if 'TIOCGWINSZ' in dir(termios):
# TIOCGWINSZ = termios.TIOCGWINSZ
# else:
# TIOCGWINSZ = 1074295912L # Assume
# s = struct.pack('HHHH', 0, 0, 0, 0)
# x = fcntl.ioctl(sys.stdout.fileno(), TIOCGWINSZ, s)
# return struct.unpack('HHHH', x)[0:2]
#
# def getServersList():
# sqlStr = ''' select * from sys_info '''
# cursor.execute(sqlStr)
# rows = cursor.fetchall()
# strList = ''
# for index, row in enumerate(rows):
# strList += 'Hostname:%s , IP:\033[1;34;40m%s\033[0m \n' % (row[0],row[1])
# return strList
#
# def sshLogin(choice):
# reip = re.compile(r'(?
# if len ( reip.findall(choice) ) == 0:
# print '\033[1;31;40mIP Error you entered.Please Enter again.\033[0m'
# return
# host = reip.findall(choice)[0]
# sqlStr = ''' select count(*) from sys_info where ip='%s' ''' % host
# cursor.execute(sqlStr)
# rows = cursor.fetchall()
# if rows[0][0] == 0:
# print '\033[1;31;40mThe IP you entered is not in the list.\033[0m'
# return
# sqlStr = ''' select * from sys_info where ip='%s' ''' % host
# cursor.execute(sqlStr)
# rows = cursor.fetchall()
# username =rows[0][2]
# passwd =rows[0][3]
# print 'ssh ' + username + '@' + host + ' ...'
# global child
# child = pexpect.spawn('ssh %s@%s' % (username,host))
# #child = pxssh.pxssh()
# child.logfile = fout
# #child.logfile = sys.stdout
# #child.logfile_send = sys.stdout
# signal.signal(signal.SIGWINCH, sigwinch_passthrough)
#
# winsize = getwinsize();
# child.setwinsize(winsize[0], winsize[1])
# flag = child.expect(['continue', 'password', pexpect.EOF, pexpect.TIMEOUT])
# #child.login (host, username, passwd, original_prompt='[$#>]')
# #child.prompt()
# #print flag
# if flag == 0:
# child.sendline('yes')
# child.expect('.*password:.*')
# child.sendline(passwd)
# elif flag == 1:
# child.sendline(passwd)
# child.interact()
# pass
#
# if __name__ == '__main__':
# DBHOST='127.0.0.1'
# DBNAME='jump'
# DBUSER = 'root'
# DBPWD = 'db03dUNG'
# FILENAME = '/data/build/command_jump.log'
# WELCOME = '''\033[1;34;40m### Welcome use JumpServer to Login. ### \033[0m '''
# CHOICE = """1. Type \033[1;34;40mIP ADDRESS\033[0m To Login.
# 2. Type \033[1;34;40mP/p\033[0m To Print The Servers You Available.
# 3. Type \033[1;34;40mQ/q\033[0m To Quit.
# \033[1;34;40mOpt or IP>:\033[0m """
# try:
# conn = MySQLdb.connect(host='%s' % DBHOST ,user='%s' % DBUSER , passwd='%s' % DBPWD , db='%s' % DBNAME , charset='utf8')
# except Exception, e:
# print e
# sys.exit()
# cursor = conn.cursor()
# fout = open (FILENAME , "ab")
# print WELCOME
# while True:
# choice = raw_input( CHOICE )
# if cmp(choice,"P") == 0 or cmp(choice,"p") == 0 :
# print getServersList()
# elif cmp(choice,"Q") == 0 or cmp(choice,"q") == 0:
# print 'Exit.'
# break
# else:
# sshLogin(choice)
#
# cursor.close()
# conn.close()
# fout.close()
#
# [root@jump1 build]#
總結
以上是生活随笔為你收集整理的python中summary_python summary_study.py的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 康福中国 Camfrog 6.0 中文版
- 下一篇： python提取cad坐标到excel_