Nagios Support Forum

Code: Select all

#!/usr/bin/env python

NagiosUrl="http://127.0.0.1/nagiosxi/api/v1/"
APIKey="your-api-key"

import requests
import datetime
import json
import syslog
from time import sleep

stage2=(datetime.date.today() - datetime.timedelta(days=5)).strftime("%Y-%m-%d")
stage1=(datetime.date.today() - datetime.timedelta(days=3)).strftime("%Y-%m-%d")
syslog.openlog(logoption=syslog.LOG_PID, facility=syslog.LOG_LOCAL6)

def fetchServiceObjects(days):
    service_objects = []
    if not days:
        return False

    API_Response = requests.get(
        NagiosUrl + 'objects/servicestatus?apikey='
        + APIKey + '&last_check=lt:' + days,
        verify=False
    )
    if (API_Response.status_code != 200):
        syslog.syslog(syslog.LOG_ERR,
                      'Error occured reterving ServicesObjects')
        return False

    data = json.loads(API_Response.content)
    
    if int(data['servicestatuslist']['recordcount']) == 0:
        return False

    # XI API returns array only if objects are more than 1
    if int(data['servicestatuslist']['recordcount']) == 1:
        object = data['servicestatuslist']['servicestatus']
        service_objects.append( {'host_name': object['host_name'], 
            'service_description': object['name']} )

    if int(data['servicestatuslist']['recordcount']) > 1:  
        for object in data['servicestatuslist']['servicestatus']:
            service_objects.append( {'host_name': object['host_name'], 
            'service_description': object['name']} )

    return service_objects

def fetchHostObjects(days):
    host_objects = []
    if not days:
        return False

    API_Response = requests.get(
        NagiosUrl + 'objects/hoststatus?apikey='
        + APIKey + '&last_check=lt:' + days,
        verify=False
    )
    if (API_Response.status_code != 200):
        syslog.syslog(syslog.LOG_ERR,
                      'Error occured reterving HostObjects')
        return False

    data = json.loads(API_Response.content)
    
    if int(data['hoststatuslist']['recordcount']) == 0:
        return False
    if int(data['hoststatuslist']['recordcount']) == 1:
        object = data['hoststatuslist']['hoststatus']
        host_objects.append({ 'host_name': object['name'] })

    if int(data['hoststatuslist']['recordcount']) > 1:
        for object in data['hoststatuslist']['hoststatus']:
            host_objects.append({ 'host_name': object['name'] })

    return host_objects


# Fetch and Delete
host_has_dependents = []
hosts_deleted = 0
service_has_dependents = []
service_deleted = 0

Stage2ServiceObjects = fetchServiceObjects(stage2)
if Stage2ServiceObjects:
    for object in Stage2ServiceObjects:
        API_Response = requests.delete(
            NagiosUrl + 'config/service?apikey='
            + APIKey + '&host_name=' + object['host_name']
            + '&service_description=' + object['service_description'],
            verify=False)
        if (API_Response.status_code == 200):
            deleteResponse = json.loads(API_Response.content)
            if ('error' in deleteResponse.keys()):
                service_has_dependents.append(object['host_name'] 
                + ':' + object['service_description'])
                print deleteResponse['error']
                syslog.syslog(syslog.LOG_INFO, deleteResponse['error'])
            else:
                service_deleted += 1
                print deleteResponse['success']
                syslog.syslog(syslog.LOG_INFO, deleteResponse['success'])

if service_deleted > 0:
    API_Response = requests.post(NagiosUrl + 'system/applyconfig?apikey=' 
    + APIKey, verify=False)
    # Lets wait for applyconfig to complete 
    # (this will resolve dependent service objects if any for deleting hosts)
    sleep(30)

Stage2HostObjects = fetchHostObjects(stage2)
if Stage2HostObjects:
    for object in Stage2HostObjects:
        API_Response = requests.delete(
            NagiosUrl + 'config/host?apikey='
            + APIKey + '&host_name=' + object['host_name'],
            verify=False
        )
        if (API_Response.status_code == 200):
            deleteResponse = json.loads(API_Response.content)
            if ('error' in deleteResponse.keys()):
                host_has_dependents.append(object['host_name'])
                print deleteResponse['error']
                syslog.syslog(syslog.LOG_INFO, deleteResponse['error'])
            else:
                hosts_deleted += 1
                print deleteResponse['success']
                syslog.syslog(syslog.LOG_INFO, deleteResponse['success'])
            
if hosts_deleted > 0:
    API_Response = requests.post(NagiosUrl + 'system/applyconfig?apikey=' 
    + APIKey, verify=False)

if (hosts_deleted == 0) and (service_deleted ==0):
    print 'no objects identified for deletion'
    

Stage1ServiceObjects = fetchServiceObjects(stage1)

if Stage1ServiceObjects:
    for object in Stage1ServiceObjects:
        print object['host_name'] + ': ' + object['service_description']

Stage1HostObjects = fetchHostObjects(stage1)
if Stage1HostObjects:
    for object in Stage1HostObjects:
        print object['host_name']

exit(0)
#TODO: Compose Email and send summary of Stage 1 and Stage 2 including errors

# Fetch stage 2 services
# Delete stage 2 services
# Apply configuraiton
# Wait for 30 seconds
# Fetch stage 2 hosts
# Check if stage 2 hosts have associated services
# Delete stage 2 hosts
# Apply configuration
# Fetch Satge 1 hosts
# Fetch stage 1 services
# Compose Email and send summary of Stage 1 and Stage 2 including errors