个人中心
gpt4 book ai didi

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

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 28 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章使用python3调用wxpy模块监控linux日志并定时发送消息给群组或好友由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

使用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 。

最后此篇关于使用python3调用wxpy模块监控linux日志并定时发送消息给群组或好友的文章就讲到这里了,如果你想了解更多关于使用python3调用wxpy模块监控linux日志并定时发送消息给群组或好友的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

28 4 0
文章推荐： 哈利波特魔法觉醒幕后真凶画像位置在哪里 哈利波特魔法觉醒幕后真凶通关攻略
文章推荐： 全面了解java中的异常处理
文章推荐： 哈利波特魔法觉醒会移动的楼梯在哪里 哈利波特魔法觉醒会移动的楼梯巧克力蛙攻略
文章推荐： 哈利波特魔法觉醒巧克力蛙画片需要集齐多少个？巧克力蛙卡片可以兑换什么？
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com