zabbix系列zabbix3.4监控rabbitmq

红色多瑙河

　　rabbitmq3.6.10版本

rabbitmq监控要点
　　具体监控什么东西，主要是rabbitmq-web监控页面的overview内容

还有就是队列堆积数，如果超过某个数值，比如5000个就立马报警

添加rabbitmq脚本

[root@test-mq02 ~]# ll -al /etc/zabbix/script/rabbitmq/
total 44
drwxr-xr-x 2 root root  4096 Feb  6 11:22 .
drwxr-xr-x 3 root root  4096 Feb  1 15:48 ..
-rwxr-xr-x 1 root root 13155 Feb  1 16:29 api.py
-rwxr-xr-x 1 root root   424 Jul 21  2017 list_rabbit_nodes.sh
-rwxr-xr-x 1 root root   426 Jul 21  2017 list_rabbit_queues.sh
-rwxr-xr-x 1 root root   430 Jul 21  2017 list_rabbit_shovels.sh
-rw-r--r-- 1 root root   138 Feb  6 11:22 .rab.auth
-rwxr-xr-x 1 root root   782 Jul 21  2017 rabbitmq-status.sh
　　api.py

#!/usr/bin/env /usr/bin/python
'''Python module to query the RabbitMQ Management Plugin REST API and get
results that can then be used by Zabbix.
https://github.com/jasonmcintosh/rabbitmq-zabbix
'''
import json
import optparse
import socket
import urllib2
import subprocess
import tempfile
import os
import logging
class RabbitMQAPI(object):
'''Class for RabbitMQ Management API'''
def __init__(self, user_name='guest', password='guest', host_name='',
port=15672, conf='/etc/zabbix/zabbix_agentd.conf', senderhostname=None, protocol='http'):
self.user_name = user_name
self.password = password
self.host_name = host_name or socket.gethostname()
self.port = port
self.conf = conf or '/etc/zabbix/zabbix_agentd.conf'
self.senderhostname = senderhostname
self.protocol = protocol or 'http'
def call_api(self, path):
'''Call the REST API and convert the results into JSON.'''
url = '{0}://{1}:{2}/api/{3}'.format(self.protocol, self.host_name, self.port, path)
password_mgr = urllib2.HTTPPasswordMgrWithDefaultRealm()
password_mgr.add_password(None, url, self.user_name, self.password)
handler = urllib2.HTTPBasicAuthHandler(password_mgr)
logging.debug('Issue a rabbit API call to get data on ' + path + " against " + self.host_name)
logging.debug('Full URL:' + url)
return json.loads(urllib2.build_opener(handler).open(url).read())
def list_queues(self, filters=None):
'''
List all of the RabbitMQ queues, filtered against the filters provided
in .rab.auth. See README.md for more information.
'''
queues = []
if not filters:
filters = [{}]
for queue in self.call_api('queues'):
logging.debug("Discovered queue " + queue['name'] + ", checking to see if it's filtered...")
for _filter in filters:
check = [(x, y) for x, y in queue.items() if x in _filter]
shared_items = set(_filter.items()).intersection(check)
if len(shared_items) == len(_filter):
element = {'{#NODENAME}': queue['node'],
'{#VHOSTNAME}': queue['vhost'],
'{#QUEUENAME}': queue['name']}
queues.append(element)
logging.debug('Discovered queue '+queue['vhost']+'/'+queue['name'])
break
return queues
def list_shovels(self, filters=None):
'''
List all of the RabbitMQ shovels, filtered against the filters provided
in .rab.auth. See README.md for more information.
'''
shovels = []
if not filters:
filters = [{}]
try:
for shovel in self.call_api('shovels'):
logging.debug("Discovered shovel " + shovel['name'] + ", checking to see if it's filtered...")
for _filter in filters:
check = [(x, y) for x, y in shovel.items() if x in _filter]
shared_items = set(_filter.items()).intersection(check)
if len(shared_items) == len(_filter):
element = {'{#VHOSTNAME}': shovel['vhost'],
'{#SHOVELNAME}': shovel['name']}
shovels.append(element)
logging.debug('Discovered shovel '+shovel['vhost']+'/'+shovel['name'])
break
return shovels
except urllib2.HTTPError as err:
if err.code == 404:
return shovels
else:
raise err
def list_nodes(self):
'''Lists all rabbitMQ nodes in the cluster'''
nodes = []
for node in self.call_api('nodes'):
# We need to return the node name, because Zabbix
# does not support @ as an item parameter
name = node['name'].split('@')[1]
element = {'{#NODENAME}': name,
'{#NODETYPE}': node['type']}
nodes.append(element)
logging.debug('Discovered nodes '+name+'/'+node['type'])
return nodes
def check_queue(self, filters=None):
'''Return the value for a specific item in a queue's details.'''
return_code = 0
if not filters:
filters = [{}]
rdatafile = tempfile.NamedTemporaryFile(delete=False)
for queue in self.call_api('queues'):
success = False
logging.debug("Filtering out by " + str(filters))
for _filter in filters:
check = [(x, y) for x, y in queue.items() if x in _filter]
shared_items = set(_filter.items()).intersection(check)
if len(shared_items) == len(_filter):
success = True
break
if success:
self._prepare_data(queue, rdatafile)
rdatafile.close()
return_code = self._send_data(rdatafile)
os.unlink(rdatafile.name)
return return_code
def check_shovel(self, filters=None):
'''Return the value for a specific item in a shovel's details.'''
return_code = 0
if not filters:
filters = [{}]
rdatafile = tempfile.NamedTemporaryFile(delete=False)
for shovel in self.call_api('shovels'):
success = False
logging.debug("Filtering out by " + str(filters))
for _filter in filters:
check = [(x, y) for x, y in shovel.items() if x in _filter]
shared_items = set(_filter.items()).intersection(check)
if len(shared_items) == len(_filter):
success = True
break
if success:
key = '"rabbitmq.shovels[{0},shovel_{1},{2}]"'
key = key.format(shovel['vhost'], 'state', shovel['name'])
value = shovel.get('state', 0)
logging.debug("SENDER_DATA: - %s %s" % (key,value))
rdatafile.write("- %s %s\n" % (key, value))
rdatafile.close()
return_code = self._send_data(rdatafile)
os.unlink(rdatafile.name)
return return_code
def _prepare_data(self, queue, tmpfile):
'''Prepare the queue data for sending'''
for item in ['memory', 'messages', 'messages_unacknowledged',
'consumers']:
key = '"rabbitmq.queues[{0},queue_{1},{2}]"'
key = key.format(queue['vhost'], item, queue['name'])
value = queue.get(item, 0)
logging.debug("SENDER_DATA: - %s %s" % (key,value))
tmpfile.write("- %s %s\n" % (key, value))
##  This is a non standard bit of information added after the standard items
for item in ['deliver_get', 'publish', 'ack']:
key = '"rabbitmq.queues[{0},queue_message_stats_{1},{2}]"'
key = key.format(queue['vhost'], item, queue['name'])
value = queue.get('message_stats', {}).get(item, 0)
logging.debug("SENDER_DATA: - %s %s" % (key,value))
tmpfile.write("- %s %s\n" % (key, value))
def _send_data(self, tmpfile):
'''Send the queue data to Zabbix.'''
args = 'zabbix_sender -vv -c {0} -i {1}'
if self.senderhostname:
args = args + " -s " + self.senderhostname
return_code = 0
process = subprocess.Popen(args.format(self.conf, tmpfile.name),
shell=True, stdout=subprocess.PIPE,
stderr=subprocess.PIPE)
out, err = process.communicate()
logging.debug("Finished sending data")
return_code = process.wait()
logging.info("Found return code of " + str(return_code))
if return_code == 1:
logging.error(out)
logging.error(err)
else:
logging.debug(err)
logging.debug(out)
return return_code
def check_aliveness(self):
'''Check the aliveness status of a given vhost.'''
return self.call_api('aliveness-test/%2f')['status']
def check_server(self, item, node_name):
'''First, check the overview specific items'''
if item == 'message_stats_deliver_get':
return self.call_api('overview').get('message_stats', {}).get('deliver_get_details', {}).get('rate',0)
elif item == 'message_stats_publish':
return self.call_api('overview').get('message_stats', {}).get('publish_details', {}).get('rate',0)
elif item == 'message_stats_ack':
return self.call_api('overview').get('message_stats', {}).get('ack_details', {}).get('rate',0)
elif item == 'message_count_total':
return self.call_api('overview').get('queue_totals', {}).get('messages',0)
elif item == 'message_count_ready':
return self.call_api('overview').get('queue_totals', {}).get('messages_ready',0)
elif item == 'message_count_unacknowledged':
return self.call_api('overview').get('queue_totals', {}).get('messages_unacknowledged',0)
elif item == 'rabbitmq_version':
return self.call_api('overview').get('rabbitmq_version', 'None')
'''Return the value for a specific item in a node's details.'''
node_name = node_name.split('.')[0]
nodeInfo = self.call_api('nodes')
for nodeData in nodeInfo:
logging.debug("Checking to see if node name {0} is in {1} for item {2} found {3} nodes".format(node_name, nodeData['name'], item, len(nodeInfo)))
if node_name in nodeData['name'] or len(nodeInfo) == 1:
logging.debug("Got data from node {0} of {1} ".format(node_name, nodeData.get(item)))
return nodeData.get(item)
return 'Not Found'
def main():
'''Command-line parameters and decoding for Zabbix use/consumption.'''
choices = ['list_queues', 'list_shovels', 'list_nodes', 'queues', 'shovels', 'check_aliveness',
'server']
parser = optparse.OptionParser()
parser.add_option('--username', help='RabbitMQ API username', default='guest')
parser.add_option('--password', help='RabbitMQ API password', default='guest')
parser.add_option('--hostname', help='RabbitMQ API host', default=socket.gethostname())
parser.add_option('--protocol', help='Use http or https', default='http')
parser.add_option('--port', help='RabbitMQ API port', type='int', default=15672)
parser.add_option('--check', type='choice', choices=choices, help='Type of check')
parser.add_option('--metric', help='Which metric to evaluate', default='')
parser.add_option('--filters', help='Filter used queues (see README)')
parser.add_option('--node', help='Which node to check (valid for --check=server)')
parser.add_option('--conf', default='/etc/zabbix/zabbix_agentd.conf')
parser.add_option('--senderhostname', default='', help='Allows including a sender parameter on calls to zabbix_sender')
parser.add_option('--logfile', help='File to log errors (defaults to /var/log/zabbix/rabbitmq_zabbix.log)', default='/var/log/zabbix/rabbitmq_zabbix.log')
parser.add_option('--loglevel', help='Defaults to INFO', default='INFO')
(options, args) = parser.parse_args()
if not options.check:
parser.error('At least one check should be specified')
logging.basicConfig(filename=options.logfile or "/var/log/zabbix/rabbitmq_zabbix.log", level=logging.getLevelName(options.loglevel or "INFO"), format='%(asctime)s %(levelname)s: %(message)s')
logging.debug("Started trying to process data")
api = RabbitMQAPI(user_name=options.username, password=options.password,
host_name=options.hostname, port=options.port,
conf=options.conf, senderhostname=options.senderhostname,
protocol=options.protocol)
if options.filters:
try:
filters = json.loads(options.filters)
except KeyError:
parser.error('Invalid filters object.')
else:
filters = [{}]
if not isinstance(filters, (list, tuple)):
filters = [filters]
if options.check == 'list_queues':
print json.dumps({'data': api.list_queues(filters)})
elif options.check == 'list_nodes':
print json.dumps({'data': api.list_nodes()})
elif options.check == 'list_shovels':
print json.dumps({'data': api.list_shovels()})
elif options.check == 'queues':
print api.check_queue(filters)
elif options.check == 'shovels':
print api.check_shovel(filters)
elif options.check == 'check_aliveness':
print api.check_aliveness()
elif options.check == 'server':
if not options.metric:
parser.error('Missing required parameter: "metric"')
else:
if options.node:
print api.check_server(options.metric, options.node)
else:
print api.check_server(options.metric, api.host_name)
if __name__ == '__main__':
main()

　　list_rabbit_nodes.sh

#!/bin/bash
#
# https://github.com/jasonmcintosh/rabbitmq-zabbix
#
cd "$(dirname "$0")"
. .rab.auth
if [[ -z "$HOSTNAME" ]]; then
HOSTNAME=`hostname`
fi
if [[ -z "$NODE" ]]; then
NODE=`hostname`
fi
./api.py --username=$USERNAME --password=$PASSWORD --check=list_nodes --filter="$FILTER" --conf=$CONF --hostname=$HOSTNAME --node="$NODE" --loglevel=${LOGLEVEL} --logfile=${LOGFILE} --port=$PORT --protocol=$PROTOCOL

　　list_rabbit_queues.sh

#!/bin/bash
#
# https://github.com/jasonmcintosh/rabbitmq-zabbix
#
cd "$(dirname "$0")"
. .rab.auth
if [[ -z "$HOSTNAME" ]]; then
HOSTNAME=`hostname`
fi
if [[ -z "$NODE" ]]; then
NODE=`hostname`
fi
./api.py --username=$USERNAME --password=$PASSWORD --check=list_queues --filter="$FILTER" --conf=$CONF --hostname=$HOSTNAME --node="$NODE"  --loglevel=${LOGLEVEL} --logfile=${LOGFILE} --port=$PORT --protocol=$PROTOCOL

　　list_rabbit_shovels.sh

#!/bin/bash
#
# https://github.com/jasonmcintosh/rabbitmq-zabbix
#
cd "$(dirname "$0")"
. .rab.auth
if [[ -z "$HOSTNAME" ]]; then
HOSTNAME=`hostname`
fi
if [[ -z "$NODE" ]]; then
NODE=`hostname`
fi
./api.py --username=$USERNAME --password=$PASSWORD --check=list_shovels --filter="$FILTER"  --hostname=$HOSTNAME --node="$NODE"  --conf=$CONF  --loglevel=${LOGLEVEL} --logfile=${LOGFILE} --port=$PORT --protocol=$PROTOCOL

　　rabbitmq-status.sh

#!/bin/bash
#
# https://github.com/jasonmcintosh/rabbitmq-zabbix
#
#UserParameter=rabbitmq

,/rabbitmq-status.sh
cd "$(dirname "$0")"
. .rab.auth
TYPE_OF_CHECK=$1
METRIC=$2
NODE=$3
if [[ -z "$HOSTNAME" ]]; then
HOSTNAME=`hostname`
fi
if [[ -z "$NODE" ]]; then
NODE=`hostname`
fi
#rabbitmq[queues]
#rabbitmq[server,disk_free]
#rabbitmq[check_aliveness]
# This assumes that the server is going to then use zabbix_sender to feed the data BACK to the server.  Right now, I'm doing that
# in the python script
./api.py --hostname=$HOSTNAME --username=$USERNAME --password=$PASSWORD --check=$TYPE_OF_CHECK --metric=$METRIC --node="$NODE" --filters="$FILTER" --conf=$CONF  --loglevel=${LOGLEVEL} --logfile=${LOGFILE} --port=$PORT --protocol=$PROTOCOL

　　.rab.auth

USERNAME=xxxxx
PASSWORD=xxxxx
CONF=/etc/zabbix/zabbix_agentd.conf
LOGLEVEL=INFO
LOGFILE=/var/log/zabbix/rabbitmq_zabbix.log
PORT=15672
添加zabbix-agent配置文件
　　/etc/zabbix/zabbix_agentd.d/rabbitmq_status.conf

UserParameter=rabbitmq.discovery_queues,/etc/zabbix/script/rabbitmq/list_rabbit_queues.sh
UserParameter=rabbitmq.discovery_shovels,/etc/zabbix/script/rabbitmq/list_rabbit_shovels.sh
UserParameter=rabbitmq.discovery_nodes,/etc/zabbix/script/rabbitmq/list_rabbit_nodes.sh
UserParameter=rabbitmq

,/etc/zabbix/script/rabbitmq/rabbitmq-status.sh $1 $2 $3
zabbix-web添加rabbitmq模板
　　rabbitmq.template.xml



2.0
2016-09-14T11:33:16Z


Rabbit Servers


Templates




Template App RabbitMQ v3
Template App RabbitMQ v3



Rabbit Servers


Templates




rabbitmq data


rabbitmq server




RabbitMQ Check Aliveness
0

0

rabbitmq[check_aliveness]
60
90
365
0
4


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Message Deliver Rates
7

0

rabbitmq[server,message_stats_deliver_get]
60
7
365
0
0

msgs/s
1


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Message Receive Rates
7

0

rabbitmq[server,message_stats_publish]
60
7
365
0
0

msgs/s
1


0
0

0

1



0
0





This is the number of messages published TO the rabbit server
0


rabbitmq server






RabbitMQ Messages Total Count
7

0

rabbitmq[server,message_count_total]
30
7
365
0
3

msgs
0


0
0

0

1



0
0





This is the total number of messages
0


rabbitmq server






RabbitMQ Messages Total Ready
7

0

rabbitmq[server,message_count_ready]
30
7
365
0
3

msgs
0


0
0

0

1



0
0





This is the total number of ready messages
0


rabbitmq server






RabbitMQ Messages Total Unacknowledged
7

0

rabbitmq[server,message_count_unacknowledged]
30
7
365
0
3

msgs
0


0
0

0

1



0
0





This is the total number of unacknowledged messages
0


rabbitmq server






RabbitMQ Refresh Rabbit Queue Status
7

0

rabbitmq[queues]
30
90
365
0
3


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Refresh Rabbit Shovel Status
7

0

rabbitmq[shovels]
30
90
365
0
4


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server Disk Free
7

0

rabbitmq[server,disk_free]
300
90
365
0
3

bytes
0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server File Desc Limit
7

0

rabbitmq[server,fd_total]
1800
90
365
0
3


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server File Desc Percent Used
15

1

rabbitmq.server.filedesc.percentused
300
90
365
0
0

%
0


0
0

0

100

last("rabbitmq[server,fd_used]")/last("rabbitmq[server,fd_total]")

0
0






0


rabbitmq server






RabbitMQ Server File Desc Used
7

0

rabbitmq[server,fd_used]
300
90
365
0
3


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server Memory Limit
7

0

rabbitmq[server,mem_limit]
1800
90
365
0
3

bytes
0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server Memory Percent Used
15

1

rabbitmq.server.mem.percentused
300
90
365
0
0

%
0


0
0

0

100

last("rabbitmq[server,mem_used]")/last("rabbitmq[server,mem_limit]")

0
0






0


rabbitmq server






RabbitMQ Server Memory Used
7

0

rabbitmq[server,mem_used]
300
90
365
0
3

bytes
0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server Partitions
7

0

rabbitmq[server,partitions]
30
90
365
0
1


0


0
0

0

1



0
0





Server partitions - SHOULD be [] which is none, so if something shows up here, partition has occurred.
0


rabbitmq server






RabbitMQ Server Sockets Limit
7

0

rabbitmq[server,sockets_total]
1800
90
365
0
3


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server Sockets Percent Used
15

1

rabbitmq.server.sockets.percentused
300
90
365
0
0

%
0


0
0

0

100

last("rabbitmq[server,sockets_used]")/last("rabbitmq[server,sockets_total]")

0
0






0


rabbitmq server






RabbitMQ Server Sockets Used
7

0

rabbitmq[server,sockets_used]
300
90
365
0
3


0


0
0

0

1



0
0






0


rabbitmq server






RabbitMQ Server Version
7

0

rabbitmq[server,rabbitmq_version]
3600
90
365
0
4


0


0
0

0

1



0
0





RabbitMQ Server Version
18


rabbitmq server








rabbitmq queues
7


rabbitmq.discovery_queues
360
0



0
0

0




0






1



{#VHOSTNAME}

8
A



1



RabbitMQ  $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_messages_unacknowledged,{#QUEUENAME}]
0
7
90
0
3


0


0
0

0

1



0
0






0


rabbitmq data






RabbitMQ $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_message_stats_deliver_get,{#QUEUENAME}]
0
7
365
0
0

msgs/s
1


0
0

0

1



0
0





Rate of message delivery to a consumer per queue
0


rabbitmq data






RabbitMQ  $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_consumers,{#QUEUENAME}]
0
7
90
0
3


0


0
0

0

1



0
0






0


rabbitmq data






RabbitMQ  $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_memory,{#QUEUENAME}]
0
7
90
0
3

B
0


0
0

0

1



0
0






0


rabbitmq data






RabbitMQ $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_message_stats_ack,{#QUEUENAME}]
0
7
365
0
0

msgs/s
1


0
0

0

1



0
0





Rate of message acknowledgement per queue
0


rabbitmq data






RabbitMQ $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_message_stats_publish,{#QUEUENAME}]
0
7
365
0
0

msgs/s
1


0
0

0

1



0
0





Rate of message delivery to a consumer per queue
0


rabbitmq data






RabbitMQ  $2 on vhost $1, queue $3
2

0

rabbitmq.queues[{#VHOSTNAME},queue_messages,{#QUEUENAME}]
0
7
90
0
3


0


0
0

0

1



0
0






0


rabbitmq data








{Template App RabbitMQ v3:rabbitmq.queues[{#VHOSTNAME},queue_messages,{#QUEUENAME}].nodata(10m)}=1
No data received on queue {#VHOSTNAME}/{#QUEUENAME} in 10 minutes.

0
4
No data received on queue {#VHOSTNAME}/{#QUEUENAME}
0


{Template App RabbitMQ v3:rabbitmq.queues[{#VHOSTNAME},queue_consumers,{#QUEUENAME}].max(120)}=0 and {Template App RabbitMQ v3:rabbitmq.queues[{#VHOSTNAME},queue_messages,{#QUEUENAME}].max(120)}0
No queue consumer found and messages present on: {#VHOSTNAME}/{#QUEUENAME}

0
3

0


{Template App RabbitMQ v3:rabbitmq.queues[{#VHOSTNAME},queue_messages,{#QUEUENAME}].last(0)}>{$RABBIT_QUEUE_MESSAGES_CRIT}
{#NODENAME}/{#VHOSTNAME}/{#QUEUENAME} - CRITICAL
http://{#FQDN}:15672/#/queues/
0
4

0


{Template App RabbitMQ v3:rabbitmq.queues[{#VHOSTNAME},queue_messages,{#QUEUENAME}].last(0)}>{$RABBIT_QUEUE_MESSAGES_WARN} and {Template App RabbitMQ v3:rabbitmq.queues[{#VHOSTNAME},queue_messages,{#QUEUENAME}].last(0)}50
Percent file descriptors greater than 50%

0
2

0


Percent file descriptors greater than 75%
{Template App RabbitMQ v3:rabbitmq.server.filedesc.percentused.last(0)}>75




{Template App RabbitMQ v3:rabbitmq.server.filedesc.percentused.last(0)}>75
Percent file descriptors greater than 75%

0
4

0



{Template App RabbitMQ v3:rabbitmq.server.mem.percentused.last(0)}>50
Percent memory use greater than 50%

0
2

0


Percent memory use greater than 75%
{Template App RabbitMQ v3:rabbitmq.server.mem.percentused.last(0)}>75




{Template App RabbitMQ v3:rabbitmq.server.mem.percentused.last(0)}>75
Percent memory use greater than 75%

0
4

0



{Template App RabbitMQ v3:rabbitmq.server.sockets.percentused.last(0)}>50
Percent sockets in use greater than 50%

0
2

0


Percent sockets in use greater than 75%
{Template App RabbitMQ v3:rabbitmq.server.sockets.percentused.last(0)}>75




{Template App RabbitMQ v3:rabbitmq.server.sockets.percentused.last(0)}>75
Percent sockets in use greater than 75%

0
4

0



{Template App RabbitMQ v3:rabbitmq[queues].last(0)}=1 or {Template App RabbitMQ v3:rabbitmq[queues].nodata(5m)}=1
Queue data status issue

0
3

0


Dead Rabbit
{Template App RabbitMQ v3:rabbitmq[check_aliveness].str(ok)}=0




{Template App RabbitMQ v3:rabbitmq[server,partitions].regexp(\[\]|^\s*$)}=0
RabbitMQ Cluster partition detected

0
3
RabbitMQ Cluster is in a BAD state!
0



{Template App RabbitMQ v3:rabbitmq[server,rabbitmq_version].diff(0)}>0
RabbitMQ server version has changed

0
2

0





Rabbit Server Overall Message Count
900
200
0.0000
100.0000
1
1
0
1
0
0.0000
0.0000
0
0
0
0


0
0
00C800
0
2
0

Template App RabbitMQ v3
rabbitmq[server,message_count_ready]



1
0
C80000
0
2
0

Template App RabbitMQ v3
rabbitmq[server,message_count_unacknowledged]





Rabbit Server Overall Message Rates
900
200
0.0000
100.0000
1
1
0
1
0
0.0000
0.0000
0
0
0
0


0
0
C80000
0
2
0

Template App RabbitMQ v3
rabbitmq[server,message_stats_deliver_get]



1
0
00C800
0
2
0

Template App RabbitMQ v3
rabbitmq[server,message_stats_publish]







重启zabbix-agent

service zabbix-agent restart