使用python3調用wxpy模塊，監控linux日志并定時發送消息給群組或好友，具體代碼如下所示：
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
from __future__ import unicode_literals
from threading import Timer
from wxpy import *
import requests
import subprocess
import time
from PIL import Image, ImageDraw, ImageFont
from apscheduler.schedulers.blocking import BlockingScheduler
#cache_path=true 表示登陸一次之后，進行緩存，下次登陸只需要手機確認
bot = Bot(console_qr=2,cache_path=True)
#獲取topic是否消費延遲
def get_Lag():
text=""
p = subprocess.Popen('kafka-consumer-offset-checker --zookeeper 192.168.1.116 --group t_sync --topic SYNC_DATABASE_UPDATE', shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE,universal_newlines=True) #universal_newlines=True，表示輸出為字符串，默認是byte
while True:
line =p.stdout.readline()
if not line:
break
else:
text+=line + '\n'
return text
def get_news():
text=[]
count=0
t=True
p = subprocess.Popen('tail -F /home/hadoop/da.txt', shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE,universal_newlines=True)
while True:
line =str(p.stdout.readline())
if not line:
break
elif "send data" in line and t:
for item in line.split(','):
count +=1
if count <= 200:
text.append(item)
break
return text
def get_context():
result=""
word=get_news()
for i in range(len(word)):
if(i % 4 ==0):
result= result+word[i]+"\n"
else:
result= result+word[i]+" "
return result
def send_image():
try:
lags=get_Lag()
print(lags)
content=get_context()
#發送消費延遲的數據
lagImage= Image.new('RGB', (1000, 600),(255,255,255))
draw = ImageDraw.Draw(lagImage)
font = ImageFont.truetype("/usr/share/fonts/cjkuni-ukai/ukai.ttc", 18, encoding="unic")
draw.text((10, 10), lags, 'black', font)
lagImage.save('/home/hadoop/lags.jpg')
#發送日志消息
image= Image.new('RGB', (1000, 810),(255,255,255))
draw = ImageDraw.Draw(image)
font = ImageFont.truetype("/usr/share/fonts/cjkuni-ukai/ukai.ttc", 18, encoding="unic") #ukai.ttc 字體
draw.text((10, 10), content, 'black', font)
image.save('/home/hadoop/123.jpg')
#發送群組
group = bot.groups().search("大數據小組")[0]
group.send_image('/home/hadoop/123.jpg')
#發送好友
my_friend = bot.friends().search(u'濤')[0]
my_friend.send_image('/home/hadoop/lags.jpg')
my_friend.send_image('/home/hadoop/123.jpg')
# t = Timer(100, send_image)
#t.start()
except:
my_friend.send(u"今天消息發送失敗了")
if __name__ == "__main__":
#send_image()
scheduler = BlockingScheduler()
scheduler.add_job(send_image, 'cron', hour='15', minute='01')
scheduler.add_job(send_image, 'cron', hour='14', minute='58')
scheduler.start()
總結
以上所述是小編給大家介紹的使用python3調用wxpy模塊監控linux日志并定時發送消息給群組或好友,希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持！
如果你覺得本文對你有幫助，歡迎轉載，煩請注明出處，謝謝！
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
