使用python3调用wxpy模块监控linux日志并定时发送消息给群组或好友
作者:荣晓 时间:2022-05-12 03:35:29
使用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日志并定时发送消息给群组或好友,网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
来源:https://blog.csdn.net/weixin_43015677/article/details/90411821
标签:python,wxpy,模块,监控,linux
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
python如何写try语句
2022-05-03 07:21:39
Python tkinter 列表框Listbox属性详情
2023-09-16 14:06:26
![](https://img.aspxhome.com/file/2023/7/100947_0s.png)
如何使用共享连接减少空闲的连接数?
2010-05-16 15:15:00
python基础入门学习笔记(Python环境搭建)
2022-01-12 20:27:48
![](https://img.aspxhome.com/file/2023/2/71502_0s.png)
Python实现随机创建电话号码的方法示例
2021-08-31 06:38:03
![](https://img.aspxhome.com/file/2023/5/67415_0s.png)
XML简易教程之一
2008-09-05 17:19:00
完美解决Python2操作中文名文件乱码的问题
2022-12-12 11:29:46
![](https://img.aspxhome.com/file/2023/2/90832_0s.jpg)
Python使用QQ邮箱发送Email的方法实例
2021-03-25 11:33:57
![](https://img.aspxhome.com/file/2023/6/95526_0s.png)
python实现人脸检测的简单实例
2023-02-17 16:08:20
![](https://img.aspxhome.com/file/2023/8/71358_0s.jpg)
浅析Windows 嵌入python解释器的过程
2023-01-26 11:43:28
python之excel文件(.xls文件)处理方式
2021-08-22 15:58:14
![](https://img.aspxhome.com/file/2023/3/75973_0s.png)
python网络爬虫精解之pyquery的使用说明
2021-05-28 13:01:19
Pytorch模型转onnx模型实例
2022-09-06 03:39:24
display:inline问题小结
2008-05-01 13:08:00
Python ini配置文件示例详解
2023-08-24 09:07:36
![](https://img.aspxhome.com/file/2023/1/62861_0s.png)
使用Python文件读写,自定义分隔符(custom delimiter)
2021-12-06 08:17:51
Flash对象在(x)HTML中的格式和参数及安全性
2010-04-01 11:55:00
![](https://img.aspxhome.com/file/UploadPic/20104/1/634042425122417500_1-54s.png)
Django项目搭建之实现简单的API访问
2021-05-20 23:21:33
![](https://img.aspxhome.com/file/2023/2/101572_0s.jpg)
Python实现21点小游戏的示例代码
2022-06-14 06:32:10
使用python scrapy爬取天气并导出csv文件
2023-02-25 16:16:10
![](https://img.aspxhome.com/file/2023/8/90758_0s.png)