怎么在python3中使用wxpy模块监控linux日志-创新互联
这篇文章给大家介绍怎么在python3中使用wxpy模块监控linux日志,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
成都创新互联-专业网站定制、快速模板网站建设、高性价比夏津网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式夏津网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖夏津地区。费用合理售后完善,十载实体公司更值得信赖。具体代码如下所示:
#!/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日志就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
新闻名称:怎么在python3中使用wxpy模块监控linux日志-创新互联
当前路径:http://myzitong.com/article/coedgg.html