使用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日志并定时发送消息给群组或好友,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对w3xue网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!