zabbix 监控ssl证书是否过期

cxs7225032

　　cd /usr/lib/zabbix/externalscripts
　　#cat check_ssl
#/bin/bash
host=$1
port=$2
end_date=`openssl s_client -host $host -port $port -showcerts /dev/null |
          sed -n '/BEGIN CERTIFICATE/,/END CERT/p' |
      openssl x509 -text 2>/dev/null |
      sed -n 's/ *Not After : *//p'`
if [ -n "$end_date" ]
then
    end_date_seconds=`date '+%s' --date "$end_date"`
# date指令format字符串时间。
    now_seconds=`date '+%s'`
    echo "($end_date_seconds-$now_seconds)/24/3600" | bc
fi　　zabbix 界面配置如下

　　check_rabbitmq_stats
　　cat check_rabbitmq_stats
#/bin/bash
host=$1
port=$2
end_date=`openssl s_client -host $host -port $port -showcerts /dev/null |
          sed -n '/BEGIN CERTIFICATE/,/END CERT/p' |
      openssl x509 -text 2>/dev/null |
      sed -n 's/ *Not After : *//p'`
if [ -n "$end_date" ]
then
    end_date_seconds=`date '+%s' --date "$end_date"`
# date指令format字符串时间。
    now_seconds=`date '+%s'`
    echo "($end_date_seconds-$now_seconds)/24/3600" | bc
fi
[root@it-zabbix03 externalscripts]#
[root@it-zabbix03 externalscripts]#
[root@it-zabbix03 externalscripts]#
[root@it-zabbix03 externalscripts]#
[root@it-zabbix03 externalscripts]#ls
check_rabbitmq_stats  check_ssl  digium_active_calls  digium_active_ports  mikoomi-mongodb-plugin.php  mikoomi-mongodb-plugin.sh  rbl.check  rblwatch.py  rblwatch.pyc  ronglianyun.php  ronglianyun.sh
[root@it-zabbix03 externalscripts]#cat check_rabbitmq_stats
#!/usr/bin/python
import sys
import socket
import re
import ZabbixSender
#from ZabbixSender.ZabbixSender import ZabbixSender
import json
import socket
import urllib2
import requests
from collections import defaultdict
class RabbitMQAPI(object):
    '''Class for RabbitMQ Management API'''
    def __init__(self, username='guest', password='guest', hostname='',
                 port=15672, interval=60):
        self.username = username
        self.password = password
        self.hostname = hostname or socket.gethostname()
        self.port = port
        self.stat_interval = interval
    def call_api(self, path):
        '''Call the REST API and convert the results into JSON.'''
        url = 'http://{0}:{1}/api/{2}'.format(self.hostname, self.port, path)
        response = requests.get(url, auth=(self.username, self.password))
        '''
        password_mgr = urllib2.HTTPPasswordMgrWithDefaultRealm()
        password_mgr.add_password(None, url, self.username, self.password)
        handler = urllib2.HTTPBasicAuthHandler(password_mgr)
        '''
        return json.loads(response.content)
    def get_message_details(self):
        '''get messages overview'''
        messages = {}
        cluster = self.call_api('overview')
        messages['cluster.messages_ready'] = cluster.get('queue_totals', {}).get('messages_ready',0)
        messages['cluster.messages_unacknowledged'] = cluster.get(
            'queue_totals', {}).get('messages_unacknowledged', 0)
        messages['cluster.messages_deliver_get'] = float(format(cluster.get('message_stats', {}).get(
            'deliver_get_details',{}).get('rate',0),'.2f'))
        messages['cluster.messages_publish'] = float(format(cluster.get('message_stats', {}).get(
            'publish_details',{}).get('rate', 0), '.2f'))
        messages['cluster.messages_redeliver'] = float(format(cluster.get('message_stats', {}).get(
            'redeliver_details',{}).get('rate', 0), '.2f'))
        messages['cluster.messages_ack'] = float(format(cluster.get('message_stats',{}).get(
            'ack_details',{}).get('rate',0), '.2f'))
        return messages
    def get_nodes_details(self):
        detail = defaultdict(float)
        for node in self.call_api('nodes'):
            name = node['name'].split('@')[1]
            if name == self.hostname.split('.')[0]:
                detail['nodes.proc_used'] = node['proc_used']
                detail['nodes.proc_total'] = node['proc_total']
                detail['nodes.proc_used_ratio'] =format(
                    node['proc_used']/float(node['proc_total']) * 100, '.2f')
                detail['nodes.fd_used'] = node['fd_used']
                detail['nodes.fd_total'] = node['fd_total']
                detail['nodes.fd_used_ratio'] = format(
                    node['fd_used']/float(node['fd_total']) * 100, '.2f')
                detail['nodes.sockets_used'] = node['sockets_used']
                detail['nodes.sockets_total'] = node['sockets_total']
                detail['nodes.sockets_used_ratio'] = format(
                    node['sockets_used']/float(node['sockets_total']) * 100, '.2f')
                detail['nodes.mem_used'] = format(
                    node['mem_used']/1024.0/1024.0,'.2f')
                detail['nodes.mem_limit'] = format(
                    node['mem_limit']/1024.0/1024.0,'.2f')
                detail['nodes.mem_used_ratio'] = format(
                    node['mem_used']/float(node['mem_limit']) * 100, '.2f')
                detail['nodes.disk_free'] = format(
                    node['disk_free']/1024.0/1024.0/1024.0,'.2f')
                detail['nodes.disk_free_limit'] = format(
                    node['disk_free_limit']/1024.0/1024.0/1024.0,'.2f')
                detail['nodes.disk_free_ratio'] = format(
                    node['disk_free']/float(node['disk_free_limit']), '.2f')
        return detail
    def get_channels_details(self):
        channels = defaultdict(float)
        for channel in self.call_api('channels'):
            channels['cluster.channels'] += 1
            name = channel['node'].split('@')[1]
            if name == self.hostname.split('.')[0]:
                channels['nodes.channels'] += 1
                if 'nodes.channels_blocked' not in channels:
                    channels['nodes.channels_blocked'] = 0
                if 'client_flow_blocked' in channel and channel['client_flow_blocked']:
                    channels['nodes.channels_blocked'] += 1
                else:
                    channels['nodes.channels_blocked'] += 0
                channels['nodes.messages_ack'] += float(format(channel.get(
                    'message_stats',{}).get('ack_details',{}).get('rate',0), '.2f'))
                channels['nodes.messages_deliver_get'] += float(format(channel.get(
                    'message_stats',{}).get('deliver_get_details',{}).get('rate',0), '.2f'))
                channels['nodes.messages_redeliver'] += float(format(channel.get(
                    'message_stats',{}).get('redeliver_details',{}).get('rate',0), '.2f'))
                channels['nodes.messages_publish'] += float(format(channel.get(
                    'message_stats',{}).get('publish_details',{}).get('rate',0), '.2f'))
        return channels
    def get_queues_details(self):
        queues = defaultdict(int)
        max_queue_message_ready = 0
        max_queue_message_ready_queue = ''
        max_queue_message_unack = 0
        max_queue_message_unack_queue = ''
        for queue in self.call_api('queues'):
            queues['cluster.queues'] += 1
            queues['cluster.consumers'] += queue['consumers']
            vhost_name = queue['vhost'].replace('.', '-')
            if vhost_name == '/':
                vhost_name = 'default'
            node_name = queue['node'].split('@')[1]
            queue_name = queue['name'].replace('.', '-')
            if node_name == self.hostname.split('.')[0]:
                queues['nodes.consumers'] += queue['consumers']
                queues['nodes.queues'] += 1
                queues['nodes.messages_ready'] += \
                    queue.get('messages_ready', 0)
                queues['nodes.messages_unacknowledged'] += \
                    queue.get('messages_unacknowledged',0)
            queues['queues_' + vhost_name + '_' + queue_name + '.messages_ready'] = \
                queue.get('messages_ready',0)
            if queue.get('messages_ready', 0) >= max_queue_message_ready:
                max_queue_message_ready = queue.get('messages_ready',0)
                max_queue_message_ready_queue = queue_name
            queues['queues_' + vhost_name + '_' + queue_name + '.messages_unacknowledged'] = \
                queue.get('messages_unacknowledged', 0)
            if queue.get('messages_unacknowledged',0) >= max_queue_message_unack:
                max_queue_message_unack = queue.get('messages_unacknowledged', 0)
                max_queue_message_unack_queue = queue_name
            queues['queues_' + vhost_name + '_' + queue_name + '.messages_ack'] = float(format(queue.get(
                'message_stats',{}).get('ack_details',{}).get('rate',0), '.2f'))
            queues['queues_' + vhost_name + '_' + queue_name + '.messages_deliver_get'] = float(format(queue.get(
                'message_stats',{}).get('deliver_get_details',{}).get('rate',0), '.2f'))
            queues['queues_' + vhost_name + '_' + queue_name + '.messages_publish'] = float(format(queue.get(
                'message_stats',{}).get('publish_details',{}).get('rate',0), '.2f'))
            queues['queues_' + vhost_name + '_' + queue_name + '.messages_redeliver'] = float(format(queue.get(
                'message_stats',{}).get('redeliver_details',{}).get('rate',0), '.2f'))
        queues['queues_max-queue-message-ready'] = max_queue_message_ready
        queues['queues_max-queue-message-ready-queue'] = max_queue_message_ready_queue
        queues['queues_max-queue-message-unack'] = max_queue_message_unack
        queues['queues_max-queue-message-unack-queue'] = max_queue_message_unack_queue
        return queues
    def get_connections_details(self):
        connections = defaultdict(int)
        for connection in self.call_api('connections'):
            connections['cluster.connections'] += 1
            node_name = connection['node'].split('@')[1]
            if node_name == self.hostname.split('.')[0]:
                connections['nodes.connections'] += 1
                key = 'nodes.connections_blocked'
                if key not in connections:
                    connections[key] = 0
                if 'last_blocked_age' in connection and \
                        connection['last_blocked_age'] != 'infinity' and \
                        connection['last_blocked_age']