Python监听RabbitMq ready数量

通过定时器每隔半小时监控一次。防止队列卡住。

说明：

vhost = '%2F'

当你的vhost是 / 的时候浏览器要通过转义

所以 / = %2F

#encoding: utf-8
#summary: 获取 RabbitMQ 中3种状态消息的数量import os, sys, time
import requests
import json
import smtplib
import time
from email.mime.text import MIMEText
from email.header import Headerclass RabbitMQTool(object):def __init__(self, host, vhost, user, passwd):self.host = hostself.vhost = vhostself.user = userself.passwd = passwd# 返回3种消息数量：ready, unacked, totaldef getMessageCount(self):now = time.strftime("%Y-%m-%d %H:%M:%S")print('Start time:%d',now)url = 'http://%s:15672/api/queues/%s' % (self.host, self.vhost)r = requests.get(url, auth=(self.user, self.passwd))print(r)if r.status_code != 200:return -1dic = json.loads(r.text)for item in dic:ready, unacked, total ,name= item['messages_ready'], item['messages_unacknowledged'], item['messages'], item['name']if ready >0 or unacked >0 or total >0:msg = """ready:%dunacked:%dtotal:%dqueryName:%stime:%s"""%(ready,unacked,total,name,now)sentMail(msg)print('ready: %d' % ready)print('unacked: %d' % unacked)    print('total: %d' % total)#return dic['messages_ready'], dic['messages_unacknowledged'], dic['messages']now = time.strftime("%Y-%m-%d %H:%M:%S")print('End time:%d',now)def sentMail(content):try:sender_qq_mail = '发件人邮邮'#收件人邮箱receiver = ['收件人1','收件人2']smtp = smtplib.SMTP() msg = MIMEText(content, "plain", 'utf-8')msg["Subject"] = Header("队列堵塞提醒", 'utf-8')msg["From"] = "系统管理员"msg["To"] = ','.join(receiver)smtp.connect('smtp.exmail.qq.com') print(msg)smtp.login(sender_qq_mail, '你的密码') smtp.sendmail(sender_qq_mail,receiver,msg.as_string()) smtp.quit()except Exception as e:print(e)if __name__ == '__main__':    mqTool = RabbitMQTool(host = '列表ip',vhost = '%2F',user = '登录名',passwd = '密码')mqTool.getMessageCount()

Python监听RabbitMq ready数量相关推荐

textfield监听输入汉字数量
2019独角兽企业重金招聘Python工程师标准>>> ###textfield监听输入汉字数量首先我们给textfield添加一个事件,当文字改变的时候调用 [self.name ...
【做一下1】python 监听数据库变化
前言用的yolov5,作者自己写的loadStream函数就是依据 streams.txt里面的rtsp流地址列表来新建线程,然后实现多路监控的. 大体就是这个图里面说的,我已经是为了个整体业务,去 ...
七十八、SpringBoot监听rabbitmq和创建交换器，队列
@Author:Runsen 来源:尚硅谷下面建议读者学习尚硅谷的B站的SpringBoot视频,我是学雷丰阳视频入门的. 具体链接如下:B站尚硅谷SpringBoot教程文章目录 AmqpAdm ...
golang gin 监听rabbitmq队列无限消费
golang gin 监听rabbitmq队列无限消费连接rabbitmq package databaseimport ("github.com/streadway/amqp" ...
python监听扫码枪扫描数据
背景:当扫码枪扫描达到输入的数量N时,自动调用打印机打印N个数据的二维码. 实现:因为需要一直监听扫码枪扫描数据的状态,因此创建线程.但是在调试的时候发现,扫码枪扫描的数据并不是一次性出来的,而是一个 ...
python监听文件更改记录_如何用机器人监听老板微信？
随着微信社交的兴起,我们加入的群也越来越多,一个不经意就被拉入好几个群,群是大家协同交流的平台,但是微信群却越来越泛滥,不知道大家有没有统计过自己浪费在毫无营养的群中的时间? 因为群质量或者群太吵的 ...
python监听文件最后修改人_Python持续监听文件变化代码实例
在日常的工作中,有时候会有这样的需求,需要一个常驻任务,持续的监听一个目录下文件的变化,对此作出回应. pyinotify就是这样的一个python包,使用方式如下: 一旦src.txt有新的内容,程 ...
python监听鼠标事件_Python中使用PyHook监听鼠标和键盘事件实例
Python 中使用 PyHook 监听鼠标和键盘事件实例 PyHook 是一个基于 Python 的"钩子"库,主要用于监听当前电脑上鼠标和键盘的事件.这个库依赖于另一个 Py ...
python监听多个udp端口_Python的Socket编程过程中实现UDP端口复用的实例分享
关于端口复用一个套接字不能同时绑定多个端口,如果客户端想绑定端口号,一定要调用发送信息函数之前绑定( bind )端口,因为在发送信息函数( sendto, 或 write ),系统会自动给当前网络 ...

Python监听RabbitMq ready数量

Python监听RabbitMq ready数量相关推荐

最新文章

热门文章