怎么在python3中使用wxpy模块监控linux日志

这篇文章给大家介绍怎么在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日志就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。