使用python3调用wxpy模块监控linux日志并定时发送消息给群组或好友_Python

使用python3调用wxpy模块监控linux日志并定时发送消息给群组或好友

2021-07-02 00:18荣晓 Python

这篇文章主要介绍了使用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()