當前位置：首頁 > 编程语言 > python >内容正文

python

超硬核！11 个非常实用的 Python 和 Shell 拿来就用脚本实例！

發布時間：2024/9/15 python 51 豆豆

生活随笔收集整理的這篇文章主要介紹了超硬核！11 个非常实用的 Python 和 Shell 拿来就用脚本实例！小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

作者：養樂多 ? ? 編輯：JackTian
來源：公眾號「杰哥的IT之旅」
ID：Jake_Internet
轉載請聯系授權（微信ID：Hc220088）

不得不說，腳本在我們的日常工作中可以提高很大的工作效率，的確很香！

這次再來給大家分享一波我工作中用到的幾個腳本，主要分為：Python和Shell兩個部分。

Python 腳本部分實例：企業微信告警、FTP 客戶端、SSH 客戶端、Saltstack 客戶端、vCenter 客戶端、獲取域名 ssl 證書過期時間、發送今天的天氣預報以及未來的天氣趨勢圖；

Shell 腳本部分實例：SVN 完整備份、Zabbix 監控用戶密碼過期、構建本地 YUM 以及上篇文章中有讀者的需求（負載高時，查出占用比較高的進程腳本并存儲或推送通知）；

篇幅有些長，還請大家耐心翻到文末，畢竟有彩蛋。

Python?腳本部分

企業微信告警

此腳本通過企業微信應用，進行微信告警，可用于 Zabbix 監控。

#?-*-?coding:?utf-8?-*-import?requests import?jsonclass?DLF:def?__init__(self,?corpid,?corpsecret):self.url?=?"https://qyapi.weixin.qq.com/cgi-bin"self.corpid?=?corpidself.corpsecret?=?corpsecretself._token?=?self._get_token()def?_get_token(self):'''獲取企業微信API接口的access_token:return:'''token_url?=?self.url?+?"/gettoken?corpid=%s&corpsecret=%s"?%(self.corpid,?self.corpsecret)try:res?=?requests.get(token_url).json()token?=?res['access_token']return?tokenexcept?Exception?as?e:return?str(e)def?_get_media_id(self,?file_obj):get_media_url?=?self.url?+?"/media/upload?access_token={}&type=file".format(self._token)data?=?{"media":?file_obj}try:res?=?requests.post(url=get_media_url,?files=data)media_id?=?res.json()['media_id']return?media_idexcept?Exception?as?e:return?str(e)def?send_text(self,?agentid,?content,?touser=None,?toparty=None):send_msg_url?=?self.url?+?"/message/send?access_token=%s"?%?(self._token)send_data?=?{"touser":?touser,"toparty":?toparty,"msgtype":?"text","agentid":?agentid,"text":?{"content":?content}}try:res?=?requests.post(send_msg_url,?data=json.dumps(send_data))except?Exception?as?e:return?str(e)def?send_image(self,?agentid,?file_obj,?touser=None,?toparty=None):media_id?=?self._get_media_id(file_obj)send_msg_url?=?self.url?+?"/message/send?access_token=%s"?%?(self._token)send_data?=?{"touser":?touser,"toparty":?toparty,"msgtype":?"image","agentid":?agentid,"image":?{"media_id":?media_id}}try:res?=?requests.post(send_msg_url,?data=json.dumps(send_data))except?Exception?as?e:return?str(e)

FTP 客戶端

通過 ftplib 模塊操作 ftp 服務器，進行上傳下載等操作。

#?-*-?coding:?utf-8?-*-from?ftplib?import?FTP from?os?import?path import?copyclass?FTPClient:def?__init__(self,?host,?user,?passwd,?port=21):self.host?=?hostself.user?=?userself.passwd?=?passwdself.port?=?portself.res?=?{'status':?True,?'msg':?None}self._ftp?=?Noneself._login()def?_login(self):'''登錄FTP服務器:return:?連接或登錄出現異常時返回錯誤信息'''try:self._ftp?=?FTP()self._ftp.connect(self.host,?self.port,?timeout=30)self._ftp.login(self.user,?self.passwd)except?Exception?as?e:return?edef?upload(self,?localpath,?remotepath=None):'''上傳ftp文件:param?localpath:?local?file?path:param?remotepath:?remote?file?path:return:'''if?not?localpath:?return?'Please?select?a?local?file.?'#?讀取本地文件#?fp?=?open(localpath,?'rb')#?如果未傳遞遠程文件路徑，則上傳到當前目錄，文件名稱同本地文件if?not?remotepath:remotepath?=?path.basename(localpath)#?上傳文件self._ftp.storbinary('STOR?'?+?remotepath,?localpath)#?fp.close()def?download(self,?remotepath,?localpath=None):'''localpath:param?localpath:?local?file?path:param?remotepath:?remote?file?path:return:'''if?not?remotepath:?return?'Please?select?a?remote?file.?'#?如果未傳遞本地文件路徑，則下載到當前目錄，文件名稱同遠程文件if?not?localpath:localpath?=?path.basename(remotepath)#?如果localpath是目錄的話就和remotepath的basename拼接if?path.isdir(localpath):localpath?=?path.join(localpath,?path.basename(remotepath))#?寫入本地文件fp?=?open(localpath,?'wb')#?下載文件self._ftp.retrbinary('RETR?'?+?remotepath,?fp.write)fp.close()def?nlst(self,?dir='/'):'''查看目錄下的內容:return:?以列表形式返回目錄下的所有內容'''files_list?=?self._ftp.nlst(dir)return?files_listdef?rmd(self,?dir=None):'''刪除目錄:param?dir:?目錄名稱:return:?執行結果'''if?not?dir:?return?'Please?input?dirname'res?=?copy.deepcopy(self.res)try:del_d?=?self._ftp.rmd(dir)res['msg']?=?del_dexcept?Exception?as?e:res['status']?=?Falseres['msg']?=?str(e)return?resdef?mkd(self,?dir=None):'''創建目錄:param?dir:?目錄名稱:return:?執行結果'''if?not?dir:?return?'Please?input?dirname'res?=?copy.deepcopy(self.res)try:mkd_d?=?self._ftp.mkd(dir)res['msg']?=?mkd_dexcept?Exception?as?e:res['status']?=?Falseres['msg']?=?str(e)return?resdef?del_file(self,?filename=None):'''刪除文件:param?filename:?文件名稱:return:?執行結果'''if?not?filename:?return?'Please?input?filename'res?=?copy.deepcopy(self.res)try:del_f?=?self._ftp.delete(filename)res['msg']?=?del_fexcept?Exception?as?e:res['status']?=?Falseres['msg']?=?str(e)return?resdef?get_file_size(self,?filenames=[]):'''獲取文件大小,單位是字節判斷文件類型:param?filename:?文件名稱:return:?執行結果'''if?not?filenames:?return?{'msg':?'This?is?an?empty?directory'}res_l?=?[]for?file?in?filenames:res_d?=?{}#?如果是目錄或者文件不存在就會報錯try:size?=?self._ftp.size(file)type?=?'f'except:#?如果是路徑的話size顯示?-?,?file末尾加/?（/dir/）size?=?'-'type?=?'d'file?=?file?+?'/'res_d['filename']?=?fileres_d['size']?=?sizeres_d['type']?=?typeres_l.append(res_d)return?res_ldef?rename(self,?old_name=None,?new_name=None):'''重命名:param?old_name:?舊的文件或者目錄名稱:param?new_name:?新的文件或者目錄名稱:return:?執行結果'''if?not?old_name?or?not?new_name:?return?'Please?input?old_name?and?new_name'res?=?copy.deepcopy(self.res)try:rename_f?=?self._ftp.rename(old_name,?new_name)res['msg']?=?rename_fexcept?Exception?as?e:res['status']?=?Falseres['msg']?=?str(e)return?resdef?close(self):'''退出ftp連接:return:'''try:#?向服務器發送quit命令self._ftp.quit()except?Exception:return?'No?response?from?server'finally:#?客戶端單方面關閉連接self._ftp.close()

SSH 客戶端

此腳本僅用于通過 key 連接，如需要密碼連接，簡單修改下即可。

#?-*-?coding:?utf-8?-*-import?paramikoclass?SSHClient:def?__init__(self,?host,?port,?user,?pkey):self.ssh_host?=?hostself.ssh_port?=?portself.ssh_user?=?userself.private_key?=?paramiko.RSAKey.from_private_key_file(pkey)self.ssh?=?Noneself._connect()def?_connect(self):self.ssh?=?paramiko.SSHClient()self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())try:self.ssh.connect(hostname=self.ssh_host,?port=self.ssh_port,?username=self.ssh_user,?pkey=self.private_key,?timeout=10)except:return?'ssh?connect?fail'def?execute_command(self,?command):stdin,?stdout,?stderr?=?self.ssh.exec_command(command)out?=?stdout.read()err?=?stderr.read()return?out,?errdef?close(self):self.ssh.close()

Saltstack 客戶端

通過 api 對 Saltstack 服務端進行操作，執行命令。

#!/usr/bin/env?python #?-*-?coding:utf-8?-*-import?requests import?json import?copyclass?SaltApi:"""定義salt?api接口的類初始化獲得token"""def?__init__(self):self.url?=?"http://172.85.10.21:8000/"self.username?=?"saltapi"self.password?=?"saltapi"self.headers?=?{"Content-type":?"application/json"}self.params?=?{'client':?'local',?'fun':?None,?'tgt':?None,?'arg':?None}self.login_url?=?self.url?+?"login"self.login_params?=?{'username':?self.username,?'password':?self.password,?'eauth':?'pam'}self.token?=?self.get_data(self.login_url,?self.login_params)['token']self.headers['X-Auth-Token']?=?self.tokendef?get_data(self,?url,?params):'''請求url獲取數據:param?url:?請求的url地址:param?params:?傳遞給url的參數:return:?請求的結果'''send_data?=?json.dumps(params)request?=?requests.post(url,?data=send_data,?headers=self.headers)response?=?request.json()result?=?dict(response)return?result['return'][0]def?get_auth_keys(self):'''獲取所有已經認證的key:return:'''data?=?copy.deepcopy(self.params)data['client']?=?'wheel'data['fun']?=?'key.list_all'result?=?self.get_data(self.url,?data)try:return?result['data']['return']['minions']except?Exception?as?e:return?str(e)def?get_grains(self,?tgt,?arg='id'):"""獲取系統基礎信息:tgt:?目標主機:return:"""data?=?copy.deepcopy(self.params)if?tgt:data['tgt']?=?tgtelse:data['tgt']?=?'*'data['fun']?=?'grains.item'data['arg']?=?argresult?=?self.get_data(self.url,?data)return?resultdef?execute_command(self,?tgt,?fun='cmd.run',?arg=None,?tgt_type='list',?salt_async=False):"""執行saltstack?模塊命令，類似于salt?'*'?cmd.run?'command':param?tgt:?目標主機:param?fun:?模塊方法?可為空:param?arg:?傳遞參數?可為空:return:?執行結果"""data?=?copy.deepcopy(self.params)if?not?tgt:?return?{'status':?False,?'msg':?'target?host?not?exist'}if?not?arg:data.pop('arg')else:data['arg']?=?argif?tgt?!=?'*':data['tgt_type']?=?tgt_typeif?salt_async:?data['client']?=?'local_async'data['fun']?=?fundata['tgt']?=?tgtresult?=?self.get_data(self.url,?data)return?resultdef?jobs(self,?fun='detail',?jid=None):"""任務:param?fun:?active,?detail:param?jod:?Job?ID:return:?任務執行結果"""data?=?{'client':?'runner'}data['fun']?=?funif?fun?==?'detail':if?not?jid:?return?{'success':?False,?'msg':?'job?id?is?none'}data['fun']?=?'jobs.lookup_jid'data['jid']?=?jidelse:return?{'success':?False,?'msg':?'fun?is?active?or?detail'}result?=?self.get_data(self.url,?data)return?result

更多關于 Saltstack 相關的原創文章可參考：

Saltstack 集中化管理平臺安裝
利用 Saltstack 遠程執行命令
跟我學 Saltstack 常用模塊及 API
如何在 Saltstack 組件下收集被控主機的信息？
如何通過 Saltstack pillar 組件定義與被控主機相關的任何數據？

vCenter 客戶端

通過官方 SDK 對 vCenter 進行日常操作，此腳本是我用于 cmdb 平臺的，自動獲取主機信息，存入數據庫。

from?pyVim.connect?import?SmartConnect,?Disconnect,?SmartConnectNoSSL from?pyVmomi?import?vim from?asset?import?models import?atexitclass?Vmware:def?__init__(self,?ip,?user,?password,?port,?idc,?vcenter_id):self.ip?=?ipself.user?=?userself.password?=?passwordself.port?=?portself.idc_id?=?idcself.vcenter_id?=?vcenter_iddef?get_obj(self,?content,?vimtype,?name=None):'''列表返回,name?可以指定匹配的對象'''container?=?content.viewManager.CreateContainerView(content.rootFolder,?vimtype,?True)obj?=?[?view?for?view?in?container.view?]return?objdef?get_esxi_info(self):#?宿主機信息esxi_host?=?{}res?=?{"connect_status":?True,?"msg":?None}try:#?connect?this?thingsi?=?SmartConnectNoSSL(host=self.ip,?user=self.user,?pwd=self.password,?port=self.port,?connectionPoolTimeout=60)except?Exception?as?e:res['connect_status']?=?Falsetry:res['msg']?=?("%s?Caught?vmodl?fault?:?"?+?e.msg)?%?(self.ip)except?Exception?as?e:res['msg']?=?'%s:?connection?error'?%?(self.ip)return?res#?disconnect?this?thingatexit.register(Disconnect,?si)content?=?si.RetrieveContent()esxi_obj?=?self.get_obj(content,?[vim.HostSystem])for?esxi?in?esxi_obj:esxi_host[esxi.name]?=?{}esxi_host[esxi.name]['idc_id']?=?self.idc_idesxi_host[esxi.name]['vcenter_id']?=?self.vcenter_idesxi_host[esxi.name]['server_ip']?=?esxi.nameesxi_host[esxi.name]['manufacturer']?=?esxi.summary.hardware.vendoresxi_host[esxi.name]['server_model']?=?esxi.summary.hardware.modelfor?i?in?esxi.summary.hardware.otherIdentifyingInfo:if?isinstance(i,?vim.host.SystemIdentificationInfo):esxi_host[esxi.name]['server_sn']?=?i.identifierValue#?系統名稱esxi_host[esxi.name]['system_name']?=?esxi.summary.config.product.fullName#?cpu總核數esxi_cpu_total?=?esxi.summary.hardware.numCpuThreads#?內存總量?GBesxi_memory_total?=?esxi.summary.hardware.memorySize?/?1024?/?1024?/?1024#?獲取硬盤總量?GBesxi_disk_total?=?0for?ds?in?esxi.datastore:esxi_disk_total?+=?ds.summary.capacity?/?1024?/?1024?/?1024#?默認配置4核8G100G，根據這個配置計算剩余可分配虛擬機default_configure?=?{'cpu':?4,'memory':?8,'disk':?100}esxi_host[esxi.name]['vm_host']?=?[]vm_usage_total_cpu?=?0vm_usage_total_memory?=?0vm_usage_total_disk?=?0#?虛擬機信息for?vm?in?esxi.vm:host_info?=?{}host_info['vm_name']?=?vm.namehost_info['power_status']?=?vm.runtime.powerStatehost_info['cpu_total_kernel']?=?str(vm.config.hardware.numCPU)?+?'核'host_info['memory_total']?=?str(vm.config.hardware.memoryMB)?+?'MB'host_info['system_info']?=?vm.config.guestFullNamedisk_info?=?''disk_total?=?0for?d?in?vm.config.hardware.device:if?isinstance(d,?vim.vm.device.VirtualDisk):disk_total?+=?d.capacityInKB?/?1024?/?1024disk_info?+=?d.deviceInfo.label?+?":?"?+??str((d.capacityInKB)?/?1024?/?1024)?+?'?GB'?+?','host_info['disk_info']?=?disk_infoesxi_host[esxi.name]['vm_host'].append(host_info)#?計算當前宿主機可用容量：總量?-?已分配的if?host_info['power_status']?==?'poweredOn':vm_usage_total_cpu?+=?vm.config.hardware.numCPUvm_usage_total_disk?+=?disk_totalvm_usage_total_memory?+=?(vm.config.hardware.memoryMB?/?1024)esxi_cpu_free?=?esxi_cpu_total?-?vm_usage_total_cpuesxi_memory_free?=?esxi_memory_total?-?vm_usage_total_memoryesxi_disk_free?=?esxi_disk_total?-?vm_usage_total_diskesxi_host[esxi.name]['cpu_info']?=?'Total:?%d核,?Free:?%d核'?%?(esxi_cpu_total,?esxi_cpu_free)esxi_host[esxi.name]['memory_info']?=?'Total:?%dGB,?Free:?%dGB'?%?(esxi_memory_total,?esxi_memory_free)esxi_host[esxi.name]['disk_info']?=?'Total:?%dGB,?Free:?%dGB'?%?(esxi_disk_total,?esxi_disk_free)#?計算cpu?內存?磁盤按照默認資源分配的最小值，即為當前可分配資源if?esxi_cpu_free?<?4?or?esxi_memory_free?<?8?or?esxi_disk_free?<?100:free_allocation_vm_host?=?0else:free_allocation_vm_host?=?int(min([esxi_cpu_free?/?default_configure['cpu'],esxi_memory_free?/?default_configure['memory'],esxi_disk_free?/?default_configure['disk']]))esxi_host[esxi.name]['free_allocation_vm_host']?=?free_allocation_vm_hostesxi_host['connect_status']?=?Truereturn?esxi_hostdef?write_to_db(self):esxi_host?=?self.get_esxi_info()#?連接失敗if?not?esxi_host['connect_status']:return?esxi_hostdel?esxi_host['connect_status']for?machine_ip?in?esxi_host:#?物理機信息esxi_host_dict?=?esxi_host[machine_ip]#?虛擬機信息virtual_host?=?esxi_host[machine_ip]['vm_host']del?esxi_host[machine_ip]['vm_host']obj?=?models.EsxiHost.objects.create(**esxi_host_dict)obj.save()for?host_info?in?virtual_host:host_info['management_host_id']?=?obj.idobj2?=?models.virtualHost.objects.create(**host_info)obj2.save()

獲取域名 ssl 證書過期時間

用于 zabbix 告警

import?re import?sys import?time import?subprocess from?datetime?import?datetime from?io?import?StringIOdef?main(domain):f?=?StringIO()comm?=?f"curl?-Ivs?https://{domain}?--connect-timeout?10"result?=?subprocess.getstatusoutput(comm)f.write(result[1])try:m?=?re.search('start?date:?(.*?)\n.*?expire?date:?(.*?)\n.*?common?name:?(.*?)\n.*?issuer:?CN=(.*?)\n',?f.getvalue(),?re.S)start_date?=?m.group(1)expire_date?=?m.group(2)common_name?=?m.group(3)issuer?=?m.group(4)except?Exception?as?e:return?999999999#?time?字符串轉時間數組start_date?=?time.strptime(start_date,?"%b?%d?%H:%M:%S?%Y?GMT")start_date_st?=?time.strftime("%Y-%m-%d?%H:%M:%S",?start_date)#?datetime?字符串轉時間數組expire_date?=?datetime.strptime(expire_date,?"%b?%d?%H:%M:%S?%Y?GMT")expire_date_st?=?datetime.strftime(expire_date,"%Y-%m-%d?%H:%M:%S")#?剩余天數remaining?=?(expire_date-datetime.now()).daysreturn?remaining?if?__name__?==?"__main__":domain?=?sys.argv[1]?remaining_days?=?main(domain)print(remaining_days)

發送今天的天氣預報以及未來的天氣趨勢圖

此腳本用于給老婆大人發送今天的天氣預報以及未來的天氣趨勢圖，現在微信把網頁端禁止了，沒法發送到微信了，我是通過企業微信進行通知的，需要把你老婆大人拉到企業微信，無興趣的小伙伴跳過即可。

????#?-*-?coding:?utf-8?-*-import?requestsimport?jsonimport?datetimedef?weather(city):url?=?"http://wthrcdn.etouch.cn/weather_mini?city=%s"?%?citytry:data?=?requests.get(url).json()['data']city?=?data['city']ganmao?=?data['ganmao']today_weather?=?data['forecast'][0]res?=?"老婆今天是{}\n今天天氣概況\n城市:?{:<10}\n時間:?{:<10}\n高溫:?{:<10}\n低溫:?{:<10}\n風力:?{:<10}\n風向:?{:<10}\n天氣:?{:<10}\n\n稍后會發送近期溫度趨勢圖，請注意查看。\".format(ganmao,city,datetime.datetime.now().strftime('%Y-%m-%d'),today_weather['high'].split()[1],today_weather['low'].split()[1],today_weather['fengli'].split('[')[2].split(']')[0],today_weather['fengxiang'],today_weather['type'],)return?{"source_data":?data,?"res":?res}except?Exception?as?e:return?str(e)```+?獲取天氣預報趨勢圖```python#?-*-?coding:?utf-8?-*-import?matplotlib.pyplot?as?pltimport?reimport?datetimedef?Future_weather_states(forecast,?save_path,?day_num=5):'''展示未來的天氣預報趨勢圖:param?forecast:?天氣預報預測的數據:param?day_num:?未來幾天:return:?趨勢圖'''future_forecast?=?forecastdict={}for?i?in?range(day_num):data?=?[]date?=?future_forecast[i]["date"]date?=?int(re.findall("\d+",date)[0])data.append(int(re.findall("\d+",?future_forecast[i]["high"])[0]))data.append(int(re.findall("\d+",?future_forecast[i]["low"])[0]))data.append(future_forecast[i]["type"])dict[date]?=?datadata_list?=?sorted(dict.items())date=[]high_temperature?=?[]low_temperature?=?[]for?each?in?data_list:date.append(each[0])high_temperature.append(each[1][0])low_temperature.append(each[1][1])fig?=?plt.plot(date,high_temperature,"r",date,low_temperature,"b")current_date?=?datetime.datetime.now().strftime('%Y-%m')plt.rcParams['font.sans-serif']?=?['SimHei']plt.rcParams['axes.unicode_minus']?=?Falseplt.xlabel(current_date)plt.ylabel("℃")plt.legend(["高溫",?"低溫"])plt.xticks(date)plt.title("最近幾天溫度變化趨勢")plt.savefig(save_path)```+?發送到企業微信```python#?-*-?coding:?utf-8?-*-import?requestsimport?jsonclass?DLF:def?__init__(self,?corpid,?corpsecret):self.url?=?"https://qyapi.weixin.qq.com/cgi-bin"self.corpid?=?corpidself.corpsecret?=?corpsecretself._token?=?self._get_token()def?_get_token(self):'''獲取企業微信API接口的access_token:return:'''token_url?=?self.url?+?"/gettoken?corpid=%s&corpsecret=%s"?%(self.corpid,?self.corpsecret)try:res?=?requests.get(token_url).json()token?=?res['access_token']return?tokenexcept?Exception?as?e:return?str(e)def?_get_media_id(self,?file_obj):get_media_url?=?self.url?+?"/media/upload?access_token={}&type=file".format(self._token)data?=?{"media":?file_obj}try:res?=?requests.post(url=get_media_url,?files=data)media_id?=?res.json()['media_id']return?media_idexcept?Exception?as?e:return?str(e)def?send_text(self,?agentid,?content,?touser=None,?toparty=None):send_msg_url?=?self.url?+?"/message/send?access_token=%s"?%?(self._token)send_data?=?{"touser":?touser,"toparty":?toparty,"msgtype":?"text","agentid":?agentid,"text":?{"content":?content}}try:res?=?requests.post(send_msg_url,?data=json.dumps(send_data))except?Exception?as?e:return?str(e)def?send_image(self,?agentid,?file_obj,?touser=None,?toparty=None):media_id?=?self._get_media_id(file_obj)send_msg_url?=?self.url?+?"/message/send?access_token=%s"?%?(self._token)send_data?=?{"touser":?touser,"toparty":?toparty,"msgtype":?"image","agentid":?agentid,"image":?{"media_id":?media_id}}try:res?=?requests.post(send_msg_url,?data=json.dumps(send_data))except?Exception?as?e:return?str(e) +?main腳本#?-*-?coding:?utf-8?-*-from?plugins.weather_forecast?import?weather from?plugins.trend_chart?import?Future_weather_states from?plugins.send_wechat?import?DLF import?os#?企業微信相關信息 corpid?=?"xxx" corpsecret?=?"xxx" agentid?=?"xxx" #?天氣預報趨勢圖保存路徑 _path?=?os.path.dirname(os.path.abspath(__file__)) save_path?=?os.path.join(_path?,'./tmp/weather_forecast.jpg')#?獲取天氣預報信息 content?=?weather("大興")#?發送文字消息 dlf?=?DLF(corpid,?corpsecret) dlf.send_text(agentid=agentid,?content=content['res'],?toparty='1')#?生成天氣預報趨勢圖 Future_weather_states(content['source_data']['forecast'],?save_path) #?發送圖片消息 file_obj?=?open(save_path,?'rb') dlf.send_image(agentid=agentid,?toparty='1',?file_obj=file_obj)

Shell?腳本部分

SVN 完整備份

通過 hotcopy 進行 SVN 完整備份，備份保留 7 天。

#!/bin/bash #?Filename???:??svn_backup_repos.sh #?Date???????:??2020/12/14 #?Author?????:??JakeTian?????? #?Email??????:??JakeTian@***.com #?Crontab????:??59?23?*?*?*?/bin/bash?$BASE_PATH/svn_backup_repos.sh?>/dev/null?2>&1 #?Notes??????:??將腳本加入crontab中，每天定時執行 #?Description:??SVN完全備份set?-eSRC_PATH="/opt/svndata" DST_PATH="/data/svnbackup" LOG_FILE="$DST_PATH/logs/svn_backup.log" SVN_BACKUP_C="/bin/svnadmin?hotcopy" SVN_LOOK_C="/bin/svnlook?youngest" TODAY=$(date?+'%F') cd?$SRC_PATH ALL_REPOS=$(find?./?-maxdepth?1?-type?d?!?-name?'httpd'?-a?!?-name?'bak'?|?tr?-d?'./')#?創建備份目錄，備份腳本日志目錄 test?-d?$DST_PATH?||?mkdir?-p?$DST_PATH test?-d?$DST_PATH/logs?||?mkdir?$DST_PATH/logs test?-d?$DST_PATH/$TODAY?||?mkdir?$DST_PATH/$TODAY#?備份repos文件 for?repo?in?$ALL_REPOS do$SVN_BACKUP_C?$SRC_PATH/$repo?$DST_PATH/$TODAY/$repo#?判斷備份是否完成if?$SVN_LOOK_C?$DST_PATH/$TODAY/$repo;thenecho?"$TODAY:?$repo?Backup?Success"?>>?$LOG_FILE?elseecho?"$TODAY:?$repo?Backup?Fail"?>>?$LOG_FILEfi done#?#?備份用戶密碼文件和權限文件 cp?-p?authz?access.conf?$DST_PATH/$TODAY#?日志文件轉儲 mv?$LOG_FILE?$LOG_FILE-$TODAY#?刪除七天前的備份 seven_days_ago=$(date?-d?"7?days?ago"?+'%F') rm?-rf?$DST_PATH/$seven_days_ago

zabbix 監控用戶密碼過期

用于 Zabbix 監控 Linux 系統用戶（shell 為 /bin/bash 和 /bin/sh）密碼過期，密碼有效期剩余 7 天觸發加自動發現用戶。

#!/bin/bashdiskarray=(`awk?-F':'?'$NF?~?/\/bin\/bash/||/\/bin\/sh/{print?$1}'?/etc/passwd`) length=${#diskarray[@]}printf?"{\n" printf??'\t'"\"data\":[" for?((i=0;i<$length;i++)) doprintf?'\n\t\t{'printf?"\"{#USER_NAME}\":\"${diskarray[$i]}\"}"if?[?$i?-lt?$[$length-1]?];thenprintf?','fi done printf??"\n\t]\n" printf?"}\n"檢查用戶密碼過期#!/bin/bashexport?LANG=en_US.UTF-8SEVEN_DAYS_AGO=$(date?-d?'-7?day'?+'%s') user="$1"#?將Sep?09,?2018格式的時間轉換成unix時間 expires_date=$(sudo?chage?-l?$user?|?awk?-F':'?'/Password?expires/{print?$NF}'?|?sed?-n?'s/^?//p') if?[[?"$expires_date"?!=?"never"?]];thenexpires_date=$(date?-d?"$expires_date"?+'%s')if?[?"$expires_date"?-le?"$SEVEN_DAYS_AGO"?];thenecho?"1"elseecho?"0"fi elseecho?"0" fi

構建本地YUM

通過 rsync 的方式同步 yum，通過 nginx 只做 http yum 站點；

但是 centos6 的鏡像最近都不能用了，國內貌似都禁用了，如果找到合適的自行更換地址。

#!/bin/bash #?更新yum鏡像RsyncCommand="rsync?-rvutH?-P?--delete?--delete-after?--delay-updates?--bwlimit=1000" DIR="/app/yumData" LogDir="$DIR/logs" Centos6Base="$DIR/Centos6/x86_64/Base" Centos7Base="$DIR/Centos7/x86_64/Base" Centos6Epel="$DIR/Centos6/x86_64/Epel" Centos7Epel="$DIR/Centos7/x86_64/Epel" Centos6Salt="$DIR/Centos6/x86_64/Salt" Centos7Salt="$DIR/Centos7/x86_64/Salt" Centos6Update="$DIR/Centos6/x86_64/Update" Centos7Update="$DIR/Centos7/x86_64/Update" Centos6Docker="$DIR/Centos6/x86_64/Docker" Centos7Docker="$DIR/Centos7/x86_64/Docker" Centos6Mysql5_7="$DIR/Centos6/x86_64/Mysql/Mysql5.7" Centos7Mysql5_7="$DIR/Centos7/x86_64/Mysql/Mysql5.7" Centos6Mysql8_0="$DIR/Centos6/x86_64/Mysql/Mysql8.0" Centos7Mysql8_0="$DIR/Centos7/x86_64/Mysql/Mysql8.0" MirrorDomain="rsync://rsync.mirrors.ustc.edu.cn"#?目錄不存在就創建 check_dir(){for?dir?in?$*dotest?-d?$dir?||?mkdir?-p?$dirdone }#?檢查rsync同步結果 check_rsync_status(){if?[?$??-eq?0?];thenecho?"rsync?success"?>>?$1elseecho?"rsync?fail"?>>?$1fi }check_dir?$DIR?$LogDir?$Centos6Base?$Centos7Base?$Centos6Epel?$Centos7Epel?$Centos6Salt?$Centos7Salt?$Centos6Update?$Centos7Update?$Centos6Docker?$Centos7Docker?$Centos6Mysql5_7?$Centos7Mysql5_7?$Centos6Mysql8_0?$Centos7Mysql8_0#?Base?yumrepo #$RsyncCommand?"$MirrorDomain"/repo/centos/6/os/x86_64/?$Centos6Base?>>?"$LogDir/centos6Base.log"?2>&1 #?check_rsync_status?"$LogDir/centos6Base.log" $RsyncCommand?"$MirrorDomain"/repo/centos/7/os/x86_64/?$Centos7Base?>>?"$LogDir/centos7Base.log"?2>&1 check_rsync_status?"$LogDir/centos7Base.log"#?Epel?yumrepo #?$RsyncCommand?"$MirrorDomain"/repo/epel/6/x86_64/?$Centos6Epel?>>?"$LogDir/centos6Epel.log"?2>&1 #?check_rsync_status?"$LogDir/centos6Epel.log" $RsyncCommand?"$MirrorDomain"/repo/epel/7/x86_64/?$Centos7Epel?>>?"$LogDir/centos7Epel.log"?2>&1 check_rsync_status?"$LogDir/centos7Epel.log"#?SaltStack?yumrepo #?$RsyncCommand?"$MirrorDomain"/repo/salt/yum/redhat/6/x86_64/?$Centos6Salt?>>?"$LogDir/centos6Salt.log"?2>&1 #?ln?-s?$Centos6Salt/archive/$(ls?$Centos6Salt/archive?|?tail?-1)?$Centos6Salt/latest #?check_rsync_status?"$LogDir/centos6Salt.log" $RsyncComman?"$MirrorDomain"/repo/salt/yum/redhat/7/x86_64/?$Centos7Salt?>>?"$LogDir/centos7Salt.log"?2>&1 check_rsync_status?"$LogDir/centos7Salt.log" #?ln?-s?$Centos7Salt/archive/$(ls?$Centos7Salt/archive?|?tail?-1)?$Centos7Salt/latest#?Docker?yumrepo $RsyncCommand?"$MirrorDomain"/repo/docker-ce/linux/centos/7/x86_64/stable/?$Centos7Docker?>>?"$LogDir/centos7Docker.log"?2>&1 check_rsync_status?"$LogDir/centos7Docker.log"#?centos?update?yumrepo #?$RsyncCommand?"$MirrorDomain"/repo/centos/6/updates/x86_64/?$Centos6Update?>>?"$LogDir/centos6Update.log"?2>&1 #?check_rsync_status?"$LogDir/centos6Update.log" $RsyncCommand?"$MirrorDomain"/repo/centos/7/updates/x86_64/?$Centos7Update?>>?"$LogDir/centos7Update.log"?2>&1 check_rsync_status?"$LogDir/centos7Update.log"#?mysql?5.7?yumrepo #?$RsyncCommand?"$MirrorDomain"/repo/mysql-repo/yum/mysql-5.7-community/el/6/x86_64/?"$Centos6Mysql5_7"?>>?"$LogDir/centos6Mysql5.7.log"?2>&1 #?check_rsync_status?"$LogDir/centos6Mysql5.7.log" $RsyncCommand?"$MirrorDomain"/repo/mysql-repo/yum/mysql-5.7-community/el/7/x86_64/?"$Centos7Mysql5_7"?>>?"$LogDir/centos7Mysql5.7.log"?2>&1 check_rsync_status?"$LogDir/centos7Mysql5.7.log"#?mysql?8.0?yumrepo #?$RsyncCommand?"$MirrorDomain"/repo/mysql-repo/yum/mysql-8.0-community/el/6/x86_64/?"$Centos6Mysql8_0"?>>?"$LogDir/centos6Mysql8.0.log"?2>&1 #?check_rsync_status?"$LogDir/centos6Mysql8.0.log" $RsyncCommand?"$MirrorDomain"/repo/mysql-repo/yum/mysql-8.0-community/el/7/x86_64/?"$Centos7Mysql8_0"?>>?"$LogDir/centos7Mysql8.0.log"?2>&1 check_rsync_status?"$LogDir/centos7Mysql8.0.log"

讀者需求解答

負載高時，查出占用比較高的進程腳本并存儲或推送通知

這部分內容是上篇 Shell 腳本實例中底部讀者留言的需求，如下：

#!/bin/bash#?物理cpu個數 physical_cpu_count=$(egrep?'physical?id'?/proc/cpuinfo?|?sort?|?uniq?|?wc?-l) #?單個物理cpu核數 physical_cpu_cores=$(egrep?'cpu?cores'?/proc/cpuinfo?|?uniq?|?awk?'{print?$NF}') #?總核數 total_cpu_cores=$((physical_cpu_count*physical_cpu_cores))#?分別是一分鐘、五分鐘、十五分鐘負載的閾值，其中有一項超過閾值才會觸發 one_min_load_threshold="$total_cpu_cores" five_min_load_threshold=$(awk?'BEGIN?{print?'"$total_cpu_cores"'?*?"0.8"}') fifteen_min_load_threshold=$(awk?'BEGIN?{print?'"$total_cpu_cores"'?*?"0.7"}')#?分別是分鐘、五分鐘、十五分鐘負載平均值 one_min_load=$(uptime?|?awk?'{print?$(NF-2)}'?|?tr?-d?',') five_min_load=$(uptime?|?awk?'{print?$(NF-1)}'?|?tr?-d?',') fifteen_min_load=$(uptime?|?awk?'{print?$NF}'?|?tr?-d?',')#?獲取當前cpu?內存?磁盤io信息，并寫入日志文件 #?如果需要發送消息或者調用其他，請自行編寫函數即可 get_info(){log_dir="cpu_high_script_log"test?-d?"$log_dir"?||?mkdir?"$log_dir"ps?-eo?user,pid,%cpu,stat,time,command?--sort?-%cpu?|?head?-10?>?"$log_dir"/cpu_top10.logps?-eo?user,pid,%mem,rss,vsz,stat,time,command?--sort?-%mem?|?head?-10?>?"$log_dir"/mem_top10.logiostat?-dx?1?10?>?"$log_dir"/disk_io_10.log }export?-f?get_infoecho?"$one_min_load?$one_min_load_threshold?$five_min_load?$five_min_load_threshold?$fifteen_min_load?$fifteen_min_load_threshold"?|?\ awk?'{?if?($1>=$2?||?$3>=$4?||?$5>=$6)?system("get_info")?}'

以上，就是今天分享的全部內容了。

希望大家通過這些案例能夠學以致用，結合自身的實際場景進行運用，從而提高自己的工作效率。

如果你有更多腳本實例，也歡迎大家分享或通過本文留言區進行留言說說你具體的腳本實例需求，如果實例過多的話，下次杰哥在整一篇合集腳本文章實例來跟大家分享。

腳本實例文件：

鏈接：https://pan.baidu.com/s/1TxSnQUtk3soKhbivWeYLIg 提取碼：y8pn

總結

以上是生活随笔為你收集整理的超硬核！11 个非常实用的 Python 和 Shell 拿来就用脚本实例！的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇：罕见！百度、微博、拼多多、B站等全国34
下一篇：值得学习练手的22个Python迷你程序