使用python3调用wxpy模块，监控linux日志并定时发送消息给群组或好友，具体代码如下所示：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
#!/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