import click
@click.command()
@click.option('--count',default=1,help='Number of greetings.')
@click.option('--name',prompt='Your name',help='The person to greet')
def hellp(count,name):'''simple program thar greets NAME for total of COUNT times...'''for x in range(count):click.echo('Hello %s!!!' % name)
if __name__ == '__main__':hellp()

import click
@click.command()
@click.option('--pos',nargs=2,type=float)
def findme(pos):click.echo('%s / %s' % pos)

#!/usr/bin/python
from __future__ import unicode_literals
from prompt_toolkit import prompt
while True:user_input = prompt('>')print(user_input)

from prompt_toolkit import prompt
from __future__ import unicode_literals
from prompt_toolkit.history import FileHistorywhile True:user_input = prompt('>',history=FileHistory('history.txt'),)print(user_input)

from __future__ import unicode_literals
from prompt_toolkit import prompt
from prompt_toolkit.history import FileHistory
from prompt_toolkit.auto_suggest import AutoSuggestFromHistorywhile True:user_input = prompt('>',history=FileHistory('history.txt'),auto_suggest=AutoSuggestFromHistory(),)print(user_input)

from prompt_toolkit import prompt
from __future__ import unicode_literals
from prompt_toolkit.history import FileHistory
from prompt_toolkit.auto_suggest import AutoSuggestFromHistory
from prompt_toolkit.contrib.completers import WordCompleterSQLCompleter = WordCompleter(['select','update','drop','insert','delete'],ignore_case=True)
while True:user_input = prompt('>',history=FileHistory('history.txt'),auto_suggest=AutoSuggestFromHistory(),completer=SQLCompleter,)print(user_input)

#!/usr/bin/python
import os
import fnmatchdef is_file_match(filenames,patterns):if fnmatch.fnmatch(filenames,patterns):return Truereturn False
def find_specific_files(dir,patterns=['*'],exclude_dirs=[]):for root,dirnames,filenames in os.walk(dir):for filename in filenames:for pattern in patterns:if is_file_match(filename,pattern):yield os.path.join(root,filename)for d in exclude_dirs:if d in dirnames:dirnames.remove(d)if __name__ == '__main__':patterns=['*.jpg','*.png','*.jbg']exclude_dirs  =  ['2']for item in find_specific_files(r"D:\python_test",patterns,exclude_dirs):print(item)

import hashlib
import sys
import os
import fnmatchCHUCK_SIZE = 8192def is_file_match(filenames,patterns):if fnmatch.fnmatch(filenames,patterns):return Truereturn Falsedef find_specific_files(dir,patterns=['*'],exclude_dirs=[]):for root,dirnames,filenames in os.walk(dir):for filename in filenames:for pattern in patterns:if is_file_match(filename,pattern):yield os.path.join(root,filename)for d in exclude_dirs:if d in dirnames:dirnames.remove(d)
def get_chunk(filename):with open(filename,encoding="utf-8") as f:while True:chunk = f.read(CHUCK_SIZE)if not chunk:breakelse:yield chunk
def get_file_checksum(filename):h = hashlib.md5()for chunk in get_chunk(filename):h.update(chunk.encode("utf-8"))return h.hexdigest()
def main():sys.argv.append("")directory = sys.argv[1]if not os.path.isdir(directory):raise SystemExit("{0} is not a directory".format(directory))record = {}for item in find_specific_files(directory):checksum = get_file_checksum(item)if checksum in record:print("找到相同文件: {0}   VS   {1}".format(record[checksum],item))print(checksum)else:record[checksum] = item
if __name__ == '__main__':main()

#-*- conding:utf-8 -*-
import os
import fnmatch
import tarfile
import datetimedef find_specific_files(dir,patterns=['*'],exclude_dirs=[]):for root,dirnames,filenames in os.walk(dir):for filename in filenames:if is_file_match(filename,patterns):yield os.path.join(root,filename)for d in exclude_dirs:if d in dirnames:dirnames.remove(d)
def main():patterns = ['*.txt','*.py']now = datetime.datetime.now().strftime('%Y-%m-%d_%H_%M_%S')filename = "all_file_{0}".format(now)with tarfile.open(filename,mode='w:gz') as f:for item in find_specific_files(".",patterns):f.add(item)
if __name__ == '__main__':main()

with open('password.txt') as f:for line in f:try:f.extractall(pwd=line.strip())print("password is {0}".format(line.strip())except:pass

from collections import namedtupleDisk = namedtuple('Disk','major_number minor_number device_name'' read_count read_merged_count read_sections'' time_spent_reading write_count write_merged_count'' write_sections time_spent_write io_requests'' time_spent_doing_io weighted_time_spent_doing_io')def get_disk_info(device):"""from /proc/diskstats read IO message:param device::return:"""with open("/proc/diskstats") as f:for line in f:if line.split()[2] == device:return Disk(*(line.split()))raise RuntimeError("device ({0}) not found !".format(device))def main():disk_info = get_disk_info('sda1')print(disk_info)print("磁盘写次数：{0}".format(disk_info.write_count))print("磁盘写字节数：{0}".format(disk_info.write_sections))print("磁盘写延时：{0}".format(disk_info.time_spent_write))if __name__ == '__main__':main()

from __future__ import unicode_literals
import os
import jinja2
import socket
from datetime import datetime
import yagmail
import psutilEMAILL_USER = 'xxx'
EMALL_PASSWORD = 'xxx'
RECIPIENTS = ['me@xxx.com']def render(tpl_path,**kwargs):path,filename = os.path.split(tpl_path)return jinja2.Environment(loader=jinja2.FileSystemLoader(path or './')).get_template(filename).render(**kwargs)def bytes2human(n):symbols = ('B','K', 'M', 'G', 'T', 'P', 'E', 'Z', 'Y')prefix = {'B': 1,'K': 1024, 'M': 1048576, 'G': 1073741824, 'T': 1099511627776, 'P': 1125899906842624, 'E': 1152921504606846976,'Z': 1180591620717411303424, 'Y': 1208925819614629174706176}while True:for p in reversed(symbols):if data > prefix[p]:value = float(data) / prefix[p]return '%.1f%s' % (value, p)elif data >= 1 and data <1024:return "%sB" % dataelse:continuedef get_cpu_info():cpu_count = psutil.cpu_count()cpu_percent = psutil.cpu_percent(interval=1)return dict(cpu_count=cpu_count,cpu_percent=cpu_percent)def get_memory_info():virtual_mem = psutil.virtual_memory()mem_total = bytes2human(virtual_mem.total)mem_percent = virtual_mem.percentmem_free = bytes2human(virtual_mem.free + virtual_mem.buffers + virtual_mem.cached)mem_used = bytes2human(virtual_mem.total * virtual_mem.percent)return dict(mem_total=mem_total,mem_percent=mem_percent,mem_free=mem_free,mem_used=mem_used)def get_disk_info():disk_usage = psutil.disk_usage('/')disk_total = bytes2human(disk_usage.total)disk_percent = disk_usage.percentdisk_free = bytes2human(disk_usage.free)disk_used = bytes2human(disk_usage.used)return dict(disk_total=disk_total,disk_percent=disk_percent,disk_free=disk_free,disk_used=disk_used)def get_boot_info():boot_time = datetime.fromtimestamp(psutil.boot_time()).strftime("%Y-%m-%d %H:%M:%S")return dict(boot_time=boot_time)def collect_monitor_data():data = {}data.update(get_boot_info())data.update(get_cpu_info())data.update(get_memory_info())data.update(get_disk_info())return datadef main():hostname = socket.gethostname()data = collect_monitor_data()data.update(dict(hostname=hostname))content = render('monitor.html',**data)# with yagmail.SMTP(user=EMAILL_USER,password=EMALL_PASSWORD,host='smtp.163.com',port=25) as yag:#     for recipient in RECIPIENTS:#         yag.send(recipient,"监控信息".encode('utf-8').content.encode('utf-8'))print(data)
if __name__ == '__main__':main()

<html><header><title>监控信息</title><body><table border="1"><tr><td>服务器名称</td><td>{{hostname}}</td></tr><tr><td>开机时间</td><td>{{boot_time}}</td></tr><tr><td>cpu个数</td><td>{{cpu_count}}</td></tr><tr><td>cpu利用率</td><td>{{cpu_percent}}</td></tr><tr><td>内存总量</td><td>{{mem_total}}</td></tr><tr><td>内存利用率</td><td>{{mem_percent}}</td></tr><tr><td>内存已用空间</td><td>{{mem_used}}</td></tr><tr><td>内存可用空间</td><td>{{mem_free}}</td></tr><tr><td>磁盘空间总量</td><td>{{disk_total}}</td></tr><tr><td>磁盘空间利用率</td><td>{{disk_percent}}</td></tr><tr><td>磁盘已用空间</td><td>{{disk_used}}</td></tr><tr><td>磁盘可用空间</td><td>{{disk_free}}</td></tr></table></body>
</html>

import openpyxlwb = openpyxl.load_workbook('1.xlsx')
ws = wb.get_sheet_by_name('Sheet1')for row in ws.row:print(*[cell.value for cell in row])# 或者也可以写成
for i in ws.values:print(*i)# 再或者
for  row in ws.iter_rows:print(*[cell.value for cell in row])

from PIL import Image
import glob
import ossize = 128,128for infile in glob.glob("*.jpg"):file,ext = os.path.splitext(infile)im = Image.open(infile)im.thumbnail(size)im.save(file + ".thumbnail","JPEG")

import sys
import osfrom PIL.ExifTags import TAGS
from PIL.ExifTags import GPSTAGSdef get_iamge_meta_info(filename):exif_data = {}with Image.open(filename) as img:data = img._getexif()for tag,value in data.iteritems():decode = TAGS.get(tag)exif_data[decode] = valueif exif_data['GPSInfo']:gps_data = {}for tag,value in exif_data['GPSInfo'].iteritems():decode = GPSTAGS.get(tag)gps_data['GPSInfo'] = gps_datareturn exif_datadef main():sys.argv.append("")filename = sys.argv[1]if not os.path.isfile(filename):raise SystemExit("{0} is not exists".format(filename))exif_data = get_iamge_meta_info(filename)for key,value in exif_data.items():print(key,value,sep=':')if __name__ == "__main__":main()

import smtplib
from email.mime.text import MIMEText
SMTP_SERVER = "smtp.163.com"
SMTP_PORT = 25def send_mail(user,pwd,to,subject,text):msg = MIMEText(text)msg['From'] = usermsg['To'] = tomsg['subject'] = subjectsmtp_server = smtplib.SMTP(SMTP_SERVER,SMTP_PORT)print('Connecting To Mail Server.')try:smtp_server.ehlo()print('Starting Encrypted Section.')smtp_server.starttls()smtp_server.ehlo()print('Logging Info Mail Server')smtp_server.login(user,pwd)print('Sending Mail')smtp_server.sendmail(user,to,msg.as_string())except Exception as err:print('Sending Mail faild:{0}'.format(err))finally:smtp_server.quit()def main():send_mail(发件人邮箱,密码,收件人邮箱,邮件主题,邮件内容)if __name__ == '__main__':main()

import urllib
import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from email.mime.application import MIMEApplicationusername = 'xxx@163.com'
password = 'xxx'
sender = username
receivers = ','.join(['xxx@qq.com'])# 如名字所示： Multipart就是多个部分
msg = MIMEMultipart()
msg['Subject'] = 'Python mail Test'
msg['From'] = sender
msg['To'] = receivers# 下面是文字部分，也就是纯文本
puretext = MIMEText('我是纯文本部分，')
msg.attach(puretext)# 下面是附件部分 ，这里分为了好几个类型# 首先是xlsx类型的附件
xlsxpart = MIMEApplication(open(r'C:\Users\qinghesh\Desktop\1.xlsx', 'rb').read())
xlsxpart.add_header('Content-Disposition', 'attachment', filename='绩1.xlsx')
msg.attach(xlsxpart)# jpg类型的附件
jpgpart = MIMEApplication(open(r'D:\1.jpg', 'rb').read())
jpgpart.add_header('Content-Disposition', 'attachment', filename='1.jpg')
msg.attach(jpgpart)# mp3类型的附件
mp3part = MIMEApplication(open(r'C:\Users\Public\Music\Sample Music\Kalimba.mp3', 'rb').read())
mp3part.add_header('Content-Disposition', 'attachment', filename='Kalimba.mp3')
msg.attach(mp3part)##  下面开始真正的发送邮件了
try:client = smtplib.SMTP()client.connect('smtp.163.com')client.login(username, password)client.sendmail(sender, receivers, msg.as_string())client.quit()print('带有各种附件的邮件发送成功！')
except smtplib.SMTPRecipientsRefused:print('Recipient refused')
except smtplib.SMTPAuthenticationError:print('Auth error')
except smtplib.SMTPSenderRefused:print('Sender refused')
except smtplib.SMTPException as e:print(e)

import yagmailwith yagmail.SMTP(user=user_mail,password=password,host=smtp_host,port=port) as yag:yag.send(recipients,subject,content)

 1 import os
 2 import sys
 3 try:
 4     import ConfigParser
 5 except ImportError:
 6     import configparser as ConfigParser
 7 import argparse
 8 import yagmail
 9
10 from storage import Storage
11 from logger import get_logger
12
13 logger = get_logger()
14
15
16 def get_argparse():
17     parser = argparse.ArgumentParser(description='A email client in terminal')
18     parser.add_argument('-s', action='store', dest='subject', required=True, help='specify a subject (must be in quotes if it has spaces)')
19     parser.add_argument('-a', action='store', nargs='*', dest='attaches', required=False, help='attach file(s) to the message')
20     parser.add_argument('-f', action='store', dest='conf', required=False, help='specify an alternate .emcli.cnf file')
21     parser.add_argument('-r', action='store', nargs='*', dest='recipients', required=True, help='recipient who you are sending the email to')
22     parser.add_argument('-v', action='version', version='%(prog)s 0.2')
23     return parser.parse_args()
24
25
26 def get_config_file(config_file):
27     if config_file is None:
28         config_file = os.path.expanduser('~/.emcli.cnf')
29     return config_file
30
31
32 def get_meta_from_config(config_file):
33     config = ConfigParser.SafeConfigParser()
34
35     with open(config_file) as fp:
36         config.readfp(fp)
37
38     meta = Storage()
39     for key in ['smtp_server', 'smtp_port', 'username', 'password']:
40         try:
41             val = config.get('DEFAULT', key)
42         except (ConfigParser.NoSectionError, ConfigParser.NoOptionError) as err:
43             logger.error(err)
44             raise SystemExit(err)
45         else:
46             meta[key] = val
47
48     return meta
49
50
51 def get_email_content():
52     return sys.stdin.read()
53
54
55 def send_email(meta):
56     content = get_email_content()
57     body = [content]
58     if meta.attaches:
59         body.extend(meta.attaches)
60
61     with yagmail.SMTP(user=meta.username, password=meta.password,
62                       host=meta.smtp_server, port=int(meta.smtp_port)) as yag:
63         logger.info('ready to send email "{0}" to {1}'.format(meta.subject, meta.recipients))
64         ret = yag.send(meta.recipients, meta.subject, body)
65
66
67 def main():
68     parser = get_argparse()
69
70     config_file = get_config_file(parser.conf)
71
72     if not os.path.exists(config_file):
73         logger.error('{0} is not exists'.format(config_file))
74         raise SystemExit()
75     else:
76         meta = get_meta_from_config(config_file)
77
78     meta.subject = parser.subject
79     meta.recipients = parser.recipients
80     meta.attaches = parser.attaches
81
82     for attach in meta.attaches:
83         if not os.path.exists(attach):
84             logger.error('{0} is not exists'.format(attach))
85             raise SystemExit()
86
87     send_email(meta)
88
89
90 if __name__ == '__main__':
91     main()

 1 import logging
 2
 3
 4 def get_logger(log_level=logging.INFO):
 5     logger = logging.getLogger(__name__)
 6     logger.setLevel(log_level)
 7
 8     formatter = logging.Formatter("%(asctime)s [emcli] [%(levelname)s] : %(message)s", "%Y-%m-%d %H:%M:%S")
 9
10     handler = logging.StreamHandler()
11     handler.setFormatter(formatter)
12
13     logger.handlers = [handler]
14
15     return logger

 1 class Storage(dict):
 2     """
 3     A Storage object is like a dictionary except `obj.foo` can be used
 4     in addition to `obj['foo']`.
 5     """
 6     def __getattr__(self, key):
 7         try:
 8             return self[key]
 9         except KeyError as k:
10             raise AttributeError(k)
11
12     def __setattr__(self, key, value):
13         self[key] = value
14
15     def __delattr__(self, key):
16         try:
17             del self[key]
18         except KeyError as k:
19             raise AttributeError(k)
20
21     def __repr__(self):
22         return '<Storage ' + dict.__repr__(self) + '>'

1 from emcli import main

[DEFAULT]
smtp_server = smtp.163.com
smtp_port = 25
username = xxx@163.com
password = 123456

import subprocess
import threadingdef is_reacheable(ip):if subprocess.call(["ping","-c","2",ip]):print("{0} is alived".format(ip))else:print("{0} is unreacheable".format(ip))def main():with open('ip.txt') as f:lines = f.readlines()threads = []for line in lines:thr = threading.Thread(target=is_reacheable,args=(line,))thr.start()threads.append(thr)for thr in threads:thr.join()if __name__ == '__main__':main()

import subprocess
import threading
import queuedef call_ping(ip):if subprocess.call(["ping","-c","1",ip])print("{0} is alive".format(ip))else:print("{0} is unreacheable".format(ip))def is_reacheable(q):try:while True:ip = q.get()call_ping(ip)except:passdef main():q = queue.Queue()with open('ip.txt') as f:for line in f:q.put(line)threads = []for i in range(10):thr = threading.Thread(target=is_reacheable,args=(q,))thr.start()threads.append(thr)for ths in threads:ths.join()if __name__ == '__main__':main()

from fabric.api import run,sudo
from fabric.api import envenv.hosts = ["ip1","ip2"]
env.port = 22
env.user = 'root'
env.password = 'password'def hostname():run('hostname')
def ipaddr():run('ifconfig')

with cd('/path/to/app/'):with prefix('workon myvenv'):run('./manage.py syncdb')run('./manage.py loaddata')

cd /path/to/app && workon myvenv && ./manage.py syncdb
cd /path/to/app && workon myvenv && ./manage.py loaddata

from fabric.api import execute,env,runs_once,taskenv.roledefs = {'db':['db01','db02'],'wb':['wb01','wb02']
}
@roles('db')
def migrate():pass
@roles('web')
def update():passdef deploy():execute(migrate)execute(update)

---
- host: testbecome: yesbecome_method: sudotask:- name: copy filecopy: src=/tmp/data.txt dest=/tmp/data.txt- name: change modefile: dest=/tmp/data.txt mode=500 owner=root group=root- name: ensure packages installed apt: pkg={{ item }} state=present with_items:- tmux- git

import argparse
import json
from collections import defaultdict
from contextlib import contextmanager
import pymysqldef to_json(in_dict):return json.dumps(in_dict,sort_keys=True,indent=2)@contextmanager
def get_conn(**kwargs):conn = pymysql.connect(**kwargs)try:yield connfinally:conn.close()def parse_args():parser = argparse.ArgumentParser(description='Openstack Inventory Module')group = parser.add_mutually_exclusive_group(required=True)group.add_argument('--list',action='store_true',help='List active servers')group.add_argument('--host',help='List details about the specific host')return parser.parse_args()def list_all_hosts(conn):hosts = defaultdict(list)with conn as cur:cur.execute('select * from hosts')rows = cur.fetchall()# print(rows)for row in rows:no,host,group,user,port = rowhosts[group].append(host)return hostsdef get_host_detail(conn,host):details = {}with conn as cur:cur.execute("select * from hosts where host='{0}'".format((host)))rows = cur.fetchall()if rows:no,host,group,user,port = rows[0]details.update(ansible_user=user,ansible_port=port)return detailsdef main():parser = parse_args()with get_conn(host='x.x.x.x',user='root',passwd='123456',db='db_ansible') as conn:if parser.list:hosts = list_all_hosts(conn)print(to_json(hosts))else:details = get_host_detail(conn,parser.host)print(to_json(details))if __name__ == '__main__':main()

CREATE TABLE `hosts` (`id` int(11) NOT NULL AUTO_INCREMENT,`host` varchar(15) DEFAULT NULL,`groupname` varchar(15) DEFAULT NULL,`username` varchar(15) DEFAULT NULL,`port` int(11) DEFAULT '22',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 |

---
- hosts: dbserverbecome: yesbecome_method: sudotasks:- name: install mongodbapt: name=mongodb-server state=present - hosts: webserverstasks:- name: copy filecopy: src=/tmp/data.txt dest=/tmp/data.txt- name: change modefile: dest=/tmp/data.txt mode=655 owner=root group=root

---
- hosts: dbserverbecome: yesbecome_method: sudotasks:- name: install mongodbapt: name=mongodb-server state=present state=present- hosts: webservertasks:- name: copy filecopy: src=/tmp/data.txt dest=/data.txt - name: change modefile: dest=/data.txt mode=755 ower=lmx group=lmx

---
- hosts: testbecome: yesbecome_method: sudovars:worker_connections: 768worker_processes: automax_open_files: 65535tasks:- name: install nginx serveryum: name=nginx state=latest- name: copy nginx config filetemplate: src=/etc/ansible/playbook/nginx.conf.j2 dest=/etc/nginx/nginx.confnotify: restart nginx server- name: copy indextemplate:src=/etc/ansible/playbook/index.html.j2dest=/usr/share/nginx/html/index.htmlmode=0644handlers:- name: restart nginx serverservice: name=nginx state=restarted

# For more information on configuration, see:
#   * Official English Documentation: http://nginx.org/en/docs/
#   * Official Russian Documentation: http://nginx.org/ru/docs/user root;
worker_processes {{ worker_processes }};
work_rlimit_nofile {{ max_open_files }};
error_log /var/log/nginx/error.log;
pid /run/nginx.pid;# Load dynamic modules. See /usr/share/nginx/README.dynamic.
include /usr/share/nginx/modules/*.conf;events {worker_connections {{ worker_connections }};
}http {log_format  main  '$remote_addr - $remote_user [$time_local] "$request" ''$status $body_bytes_sent "$http_referer" ''"$http_user_agent" "$http_x_forwarded_for"';access_log  /var/log/nginx/access.log  main;sendfile            on;tcp_nopush          on;tcp_nodelay         on;keepalive_timeout   65;types_hash_max_size 2048;include             /etc/nginx/mime.types;default_type        application/octet-stream;# Load modular configuration files from the /etc/nginx/conf.d directory.# See http://nginx.org/en/docs/ngx_core_module.html#include# for more information.include /etc/nginx/conf.d/*.conf;server {listen       80 default_server;listen       [::]:80 default_server;server_name  172.26.186.194;root         /usr/share/nginx/html;# Load configuration files for the default server block.include /etc/nginx/default.d/*.conf;location / {root /opt/piwik;index index.php index.html;}location ~ \.php$ {include /etc/nginx/fastcgi_params;fastcgi_pass 127.0.0.1:9000;fastcgi_index index.php;fastcgi_param SCRIPT_FILENAME /usr/share/nginx/html/html$fastcgi_script_name;}error_page 404 /404.html;location = /40x.html {}error_page 500 502 503 504 /50x.html;location = /50x.html {}}# Settings for a TLS enabled server.
#
#    server {
#        listen       443 ssl http2 default_server;
#        listen       [::]:443 ssl http2 default_server;
#        server_name  _;
#        root         /usr/share/nginx/html;
#
#        ssl_certificate "/etc/pki/nginx/server.crt";
#        ssl_certificate_key "/etc/pki/nginx/private/server.key";
#        ssl_session_cache shared:SSL:1m;
#        ssl_session_timeout  10m;
#        ssl_ciphers HIGH:!aNULL:!MD5;
#        ssl_prefer_server_ciphers on;
#
#        # Load configuration files for the default server block.
#        include /etc/nginx/default.d/*.conf;
#
#        location / {
#        }
#
#        error_page 404 /404.html;
#            location = /40x.html {
#        }
#
#        error_page 500 502 503 504 /50x.html;
#            location = /50x.html {
#        }
#    }}

<html><head><title>Wecome to ansible</title></head><body><h1>nginx,configured by ansible</h1><p>If you can see this,ansible successful installed nginx.</p><p>{{ ansible_hostname }}</p></body>
</html>