pip3 install pyinotify
pyinotify提供的事件:python
事件标志 | 事件含义 |
IN_ACCESS | 被监控项目或者被监控目录中的文件被访问,好比一个文件被读取 |
IN_MODIFY | 被监控项目或者被监控目录中的文件被修改 |
IN_ATTRIB | 被监控项目或者被监控目录中的文件的元数据被修改 |
IN_CLOSE_WRITE | 一个打开切等待写入的文件或者目录被关闭 |
IN_CLOSE_NOWRITE | 一个以只读方式打开的文件或者目录被关闭 |
IN_OPEN | 文件或者目录被打开 |
IN_MOVED_FROM | 被监控项目或者目录中的文件被移除监控区域 |
IN_MOVED_TO | 文件或目录被移入监控区域 |
IN_CREATE | 在所监控的目录中建立子目录或文件 |
IN_DELETE | 在所监控的目录中删除目录或文件 |
IN_CLOSE* | 文件被关闭,等同于IN_CLOSE_WRITE* |
IN_MOVE | 文件被移动,等同于IN_CLOSE_NOWRITE |
在具体实现时,时间仅仅是一个标志位,所以,咱们可使用“与”操做来合并多个时间,下面来看一个实例mysql
import pyinotify #建立一个监控实例 wm = pyinotify.WatchManager() #定义要监控的内容 mask = pyinotify.IN_DELETE | pyinotify.IN_CREATE #这里pyinotify.ALL_EVENTS表示监控全部事件 #在实例中添加动做 wm.add_watch('/tmp', mask) #加载监控实例对象 notifier = pyinotify.Notifier(wm) #循环处理时间 notifier.loop()
python标准库中发送电子邮件的模块比较复杂,所以,有许多开原的库提供了更加易用的接口来发送电子邮件,其中yagmail是一个使用比较普遍的开原项目,yagmail底层依然使用了smtplib和email模块,可是yagmail提供了更好的接口,并具备更好的易读性linux
yagmail是开原项目,所以,在使用前须要安装sql
pip install yagmail
#链接邮箱服务器 yag = yagmail.SMTP(user='xxx@163.com', password='xxxx', host='smtp.163.com') #发送邮件 yag.send(to='xxx@126.com', cc='xxx@163.com',subject='这是测试邮件', contents='这是测试邮件的内容') #断开链接 yag.close()
#pymysql操做数据库 import pymysql # 打开数据库链接 db = pymysql.connect(host="192.168.254.24", user="root", password="root", db="mysql", port=3306) # 使用cursor()方法获取操做游标 cur = db.cursor() # 1.查询操做 # 编写sql 查询语句 user 对应个人表名 sql = "select host,user,password from user" try: cur.execute(sql) # 执行sql语句 results = cur.fetchall() # 获取查询的全部记录 for i in results:#遍历结果 print(i) except Exception as e: raise e finally: db.close() # 关闭链接
1、ConfigParser简介 ConfigParser 是用来读取配置文件的包。配置文件的格式以下:中括号“[ ]”内包含的为section。section 下面为相似于key-value 的配置内容。 [db] db_host = 127.0.0.1 db_port = 69 db_user = root db_pass = root host_port = 69 [concurrent] thread = 10 processor = 20 括号“[ ]”内包含的为section。紧接着section 为相似于key-value 的options 的配置内容。 2、ConfigParser 初始化对象 使用ConfigParser 首选须要初始化实例,并读取配置文件: import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") 3、ConfigParser 经常使用方法 1、获取所用的section节点 # 获取所用的section节点 import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") print(config.sections()) #运行结果 # ['db', 'concurrent'] 2、获取指定section 的options。即将配置文件某个section 内key 读取到列表中: import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") r = config.options("db") print(r) #运行结果 # ['db_host', 'db_port', 'db_user', 'db_pass', 'host_port'] 3、获取指点section下指点option的值 import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") r = config.get("db", "db_host") # r1 = config.getint("db", "k1") #将获取到值转换为int型 # r2 = config.getboolean("db", "k2" ) #将获取到值转换为bool型 # r3 = config.getfloat("db", "k3" ) #将获取到值转换为浮点型 print(r) #运行结果 # 127.0.0.1 4、获取指点section的所用配置信息 import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") r = config.items("db") print(r) #运行结果 #[('db_host', '127.0.0.1'), ('db_port', '69'), ('db_user', 'root'), ('db_pass', 'root'), ('host_port', '69')] 5、修改某个option的值,若是不存在则会出建立 # 修改某个option的值,若是不存在该option 则会建立 import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") config.set("db", "db_port", "69") #修改db_port的值为69 config.write(open("ini", "w")) 运行结果 6、检查section或option是否存在,bool值 import configparser config = configparser.ConfigParser() config.has_section("section") #是否存在该section config.has_option("section", "option") #是否存在该option 7、添加section 和 option import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") if not config.has_section("default"): # 检查是否存在section config.add_section("default") if not config.has_option("default", "db_host"): # 检查是否存在该option config.set("default", "db_host", "1.1.1.1") config.write(open("ini", "w")) 运行结果 8、删除section 和 option import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") config.remove_section("default") #整个section下的全部内容都将删除 config.write(open("ini", "w")) 运行结果 9、写入文件 如下的几行代码只是将文件内容读取到内存中,进过一系列操做以后必须写回文件,才能生效。 import configparser config = configparser.ConfigParser() config.read("ini", encoding="utf-8") 写回文件的方式以下:(使用configparser的write方法) config.write(open("ini", "w"))
import pexpect host = '192.168.254.24' password = 'root' username = 'root' child = pexpect.spawn('ssh root@192.168.254.24') child.expect('password:') child.sendline(password) child.expect('#') child.sendline('mysql -uroot -proot') child.expect('none') child.sendline('show variables like "%log%";') child.sendline('exit') child.sendline('exit') child.interact() child.close()
import pexpect ssh = pexpect.spawn('ssh 192.168.254.12',timeout=10) i = ssh.expect(['password:','continue connecting'],timeout=10) print(i) if i == 0: ssh.sendline('root') elif i == 1: ssh.sendline('yes\n') ssh.expect('password:') ssh.sendline('root\n') index = ssh.expect(['#',pexpect.EOF,pexpect.TIMEOUT],timeout=15) if index == 0: ssh.sendline('ip a') ssh.sendline('exit') ssh.interact() ssh.close() elif index == 1: print('logging process exit') elif index == 2: print('logging in time out')
#经过paramiko模块链接主机运行bash命令 import paramiko hostname = '192.168.254.24' port = 22 username = 'root' password = 'root' ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(hostname=hostname,port=port,username=username,password=password) stdin, stdout, stderr = ssh.exec_command("ls -ltr") print(stdout.read().decode('utf-8')) #经过paramiko模块链接主机上传 import paramiko hostname = '192.168.254.24' port = 22 username = 'root' password = 'root' t=paramiko.Transport((hostname,port)) t.connect(username=username,password=password) sftp = paramiko.SFTPClient.from_transport(t) sftp.put(r'C:\Users\fengzi\Desktop\Linux.xmind', '/root/aaa.xmind') sftp.close() #经过paramiko模块链接主机下载 import paramiko hostname = '192.168.254.24' port = 22 username = 'root' password = 'root' t=paramiko.Transport((hostname,port)) t.connect(username=username,password=password) sftp = paramiko.SFTPClient.from_transport(t) sftp.get('/root/test3.yml', r'C:\Users\fengzi\Desktop\test3.yml') sftp.close()
#linux服务器(半双工) import socket import subprocess import threading server = socket.socket() server.bind(('', 8888)) server.listen(5) print('等待电话.....') conn, addr = server.accept() print('电话来了......') while True: data = conn.recv(10240) cmd = subprocess.Popen(data.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) stdout = cmd.stdout.read() stderr = cmd.stdout.read() conn.send(stdout + stderr) #客户端 import socket import threading client = socket.socket() client.connect(('192.168.254.24', 8888)) while True: info = input('===>:') if not info:continue client.send(info.encode('utf-8')) data = client.recv(10240) print(data.decode('utf-8'))
#全双工电话 #服务器端 import socket import subprocess import threading server = socket.socket() server.bind(('', 8888)) server.listen(5) print('等待电话.....') conn, addr = server.accept() print('电话来了......') def recv(): while True: data = conn.recv(10240) print(data.decode('utf-8')) def send(): while True: data = input('===>:') conn.send(data.encode('utf-8')) t1 = threading.Thread(target=recv) t2 = threading.Thread(target=send) t1.start() t2.start() #客户端 import socket import threading client = socket.socket() client.connect(('localhost', 8888)) def send(): while True: info = input('===>:') client.send(info.encode('utf-8')) def recv(): while True: data = client.recv(1024) print(data.decode('utf-8')) t1 = threading.Thread(target=send) t2 = threading.Thread(target=recv) t1.start() t2.start()
import socket socket.setdefaulttimeout(1) host_list = ['192.168.4.145:5555','192.168.4.146:555','192.168.4.147:5555','192.168.31.199:445'] for info in host_list: server = socket.socket() ip = re.compile('(.*?):(.*)').search(info).group(1) port = re.compile('(.*?):(.*)').search(info).group(2) res = server.connect_ex((ip, int(port))) if res == 0: print('%s--%s端口正常' % (ip, port)) else: print('%s--%s端口异常' % (ip, port))
\w | 匹配字母数字 |
\W | 匹配非字母数字 |
\s | 匹配任意空白字符,等价于 [\t\n\r\f]. |
\S | 匹配任意非空字符 |
\d | 匹配任意数字,等价于 [0-9]. |
\D | 匹配任意非数字 |
\A | 匹配字符串开始 |
\Z | 匹配字符串结束,若是是存在换行,只匹配到换行前的结束字符串。c |
\z | 匹配字符串结束 |
\G | 匹配最后匹配完成的位置。 |
\b | 匹配一个单词边界,也就是指单词和空格间的位置。例如, 'er\b' 能够匹配"never" 中的 'er',但不能匹配 "verb" 中的 'er'。 |
\B | 匹配非单词边界。'er\B' 能匹配 "verb" 中的 'er',但不能匹配 "never" 中的 'er'。 |
\n, \t, 等. | 匹配一个换行符。匹配一个制表符。等 |
\1...\9 | 匹配第n个分组的子表达式。 |
\10 | 匹配第n个分组的子表达式,若是它经匹配。不然指的是八进制字符码的表达式。 |
一、getcwd()shell
获取当前工做路径数据库
import os print(os.getcwd()) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py D:\pyproject\day21模块
二、chdir() 改变当前工做路径bash
import os print(os.getcwd()) os.chdir("test1") print(os.getcwd()) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py D:\pyproject\day21模块 D:\pyproject\day21模块\test1
三、返回上级目录用..服务器
import os print(os.getcwd()) os.chdir("..") print(os.getcwd()) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py D:\pyproject\day21模块 D:\pyproject
四、makedirs(能够建递归的目录)less
新建文件夹dom
import os os.makedirs("gouguoqi/gouguoqi1") os.chdir("gouguoqi/gouguoqi1") print(os.getcwd()) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py D:\pyproject\day21模块\gouguoqi\gouguoqi
五、mkdir 新建目录,只能建一层
import os os.mkdir("gouguoqi") os.chdir("gouguoqi") print(os.getcwd()) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py D:\pyproject\day21模块\gouguoqi
六、rmdir 只能删除单级目录为空的文件夹
import os os.rmdir("gouguoqi") OSError: [WinError 145] 目录不是空的。: 'gouguoqi'
七、listdir 列出指定文件夹下面全部的文件夹和文件包括隐藏文件,以列表方式打印出来
import os print(os.listdir("D:\pyproject\day21模块")) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py ['module-lesson.py', '文件修改功能.py', 'day21_lesson', 'time模块.py', 'random随机模块.py', 'basedir.py', 'os模块.py', 'test1', 'gouguoqi', '查询功能.py', '三级菜单.py', 'test.py', 'sed.py', 'haproxy.cfg']
八、remove 删除指定的一个文件
import os os.remove("gouguoqi/test.py")
九、rename 修改文件夹名字或者是文件名字均可以
import os os.rename("gouguoqi","gouguoqinew")
十、stat 查看一个文件的详细信息
import os print(os.stat("gouguoqinew/testnew")) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py os.stat_result(st_mode=33206, st_ino=15085150720, st_dev=75373296, st_nlink=1, st_uid=0, st_gid=0, st_size=28, st_atime=1528473600, st_mtime=1528552906, st_ctime=1528552713) st_size=28 文件大小,单位是字节 st_atime=1528473600 用户上一次的访问时间 st_mtime=1528552906 用户上一次修改的时间(经常使用) st_ctime=1528552713 用户的建立文件的时间 这个时间是时间戳,想要转换成咱们能看懂的那种格式,还得转换下,好比用户建立文件时间是1528552713 转换为字符串时间
十一、system 运行shell命令,直接显示结果
[root@localhost python]# cat os.system.py #!/usr/bin/env python # _*_ coding:utf8 _*_ import os os.system("cd /home && ls") [root@localhost python]# python os.system.py python src
十二、os.path.exists 判断路径是否存在,存在为True,不存在为False
import os print(os.path.exists("D:\pyproject\day21模块\gouguoqinew")) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py True
1三、os.path.isfile 判断一个文件是否存在,存在为True,不然为False
import os print(os.path.isfile(r"D:\pyproject\day21模块\gouguoqinew\test.py")) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py True
1四、os.path.isdir 判断一个目录是否存在,存在为True,不然为False
import os print(os.path.isdir(r"D:\pyproject\day21模块\gouguoqinew")) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py True
1五、os.path.join 路径拼接(重要经常使用)
import os a="D:\pyproject" b="day21模块\gouguoqinew" print(os.path.join(a,b)) C:\python35\python3.exe D:/pyproject/day21模块/os模块.py D:\pyproject\day21模块\gouguoqinew