Changeset 3242

Timestamp:

08/06/13 10:40:14 (11 years ago)

Author:

sanmai

Message:

• First work on LDAP monitoring plugin.
• Separate processing of command-line arguments into generic plus a minimal amount of plugin-specific source code.

Location:

monitoring/plugins/mpi

Files:

• check_clarin_discojuice_html.py (modified) (1 prop)
• check_clarin_discojuice_json.py (modified) (1 prop)
• check_clarin_ldap.py (added)
• check_lat_cql_endpoint.py (modified) (1 diff)
• generic_tla_monitoring.py (modified) (3 diffs)

monitoring/plugins/mpi/check_lat_cql_endpoint.py

@@ -23 +23 @@
     # Check status for all UP_URLs.
     results = \
-      map(lambda UP_URL : generic_tla_monitoring.check_condition(host                      = host,
-                                                                 UP_URL                    = UP_URL,
-                                                                 HTTP_method               = 'GET',
-                                                                 validator                 = generic_tla_monitoring.check_XML_validity,
-                                                                 valid_root_element_tag    = valid_root_element_tag,
-                                                                 special_plugin_file_name  = special_plugin_file_name),
+        map(lambda UP_URL : generic_tla_monitoring.check_condition(host                      = host,
+                                                                   UP_URL                    = UP_URL,
+                                                                   HTTP_method               = 'GET',
+                                                                   validator                 = generic_tla_monitoring.check_XML_validity,
+                                                                   valid_root_element_tag    = valid_root_element_tag,
+                                                                   special_plugin_file_name  = special_plugin_file_name),
           UP_URLs)
     

monitoring/plugins/mpi/generic_tla_monitoring.py

@@ -33 +33 @@
     sys.exit(max(suggested_exit_codes))
 
-def usage() :
-    """ returns nagios status UNKNOWN with
+def usage(command_line_parameters_usage_string) :
+    """ returns Nagios status UNKNOWN with
         a one line usage description
         usage() calls nagios_return()
     """
     nagios_return('UNKNOWN',
-                  "usage: %s -h host" % (sys.argv[0]))
+                  "usage: " + sys.argv[0] + command_line_parameters_usage_string)
 
 def generic_validator(data, 
@@ -133 +133 @@
                                        special_validator)
     return (wellformedness)
+
+
+def check_LDAP_validity(data, 
+                       descriptive_string,
+                       **kwargs) :
+
+    def special_validator(data, 
+                          descriptive_string, 
+                          kwargs) :
+        try :            
+            return True # X-
+        except :
+            return False
+
+    wellformedness = generic_validator(data, 
+                                       descriptive_string, 
+                                       kwargs, 
+                                       special_validator)
+    return (wellformedness)
+
+
+def check_ldap(host, 
+               bindDN,
+               validator, 
+               **validator_arguments) :
+
+    OpenDJ_directory_path = '/srv/LDAP/OpenDJ-2.5.0-Xpress1/'
+
+    command = [OpenDJ_directory_path + "/bin/ldapsearch", 
+              '--port', '10389',
+              '--baseDN', 'dc=clarin,dc=eu',
+              '--useStartTLS',
+              '--trustAll',
+              '--hostname', "'" + host + "'",
+              '--bindDN', "'" + bindDN + "'",
+              "--bindPasswordFile", "'/root/LDAP_passwdfile'",
+              "'(objectClass=CLARINPerson)'",
+              'isMemberOf']
+
+    # Run OpenDJ's "ldapsearch" command line utility
+    pdb.set_trace()
+    
+    process = subprocess.Popen(command, 
+                               stdout = subprocess.PIPE, 
+                               stderr = subprocess.PIPE)
+
+    stdout, stderr = process.communicate()
+
+    print stdout
+    print stderr
+
+    pdb.set_trace()
+
+    if response :
+        return {
+                "code"      : "OK", 
+                "message"   : 'Host %s is up and responds as expected.' % (host, UP_URL)
+               }
+    else :
+        return {
+                "code"      : "CRITICAL", 
+                "message"   : 'Host %s is up but does not respond as expected.' % (host, UP_URL)
+                }
+
 
 def check_condition(host, 
@@ -227 +291 @@
                        }
 
-def main(special_main_subroutine) :
-    """ example options processing
-        here we're expecting 1 option "-h"
-        with a parameter
-    """
-
-    if len(sys.argv) < 2 :
-        usage()
-
-    try:
-        opts, args  = getopt.getopt(sys.argv[1:], "h:u:")
+def main(special_main_subroutine, 
+         command_line_parameters = [("-h", "host",)]) :
+
+    ##  Process plugin-specific command line parameters.
+    command_line_parameters_getopt_string = command_line_parameters_usage_string = ""
+    for (parameter, description) in command_line_parameters :
+       command_line_parameters_usage_string = command_line_parameters_usage_string + parameter + "  " + description + "\n"
+       command_line_parameters_getopt_string = command_line_parameters_getopt_string + parameter.lstrip("-")  + ":"
+
+    try :
+        opts = filter(None, getopt.getopt(sys.argv[1:], command_line_parameters_getopt_string))[0] # X- fix other plugins with -u option
     except getopt.GetoptError, err :
-        usage()
-    
-    url = None
-    for o, value in opts :
-        if o == "-h" :
-            host = value
-        elif o == "-u" :
-            url = value
-
+        usage(command_line_parameters_usage_string)
+    else : 
+        if len(command_line_parameters) == len(opts) :
+            main_subroutine_argument_values = [parameter_value for parameter_name, parameter_value in opts]
+            # pdb.set_trace()
+            special_main_subroutine(*main_subroutine_argument_values)        
         else :
-            usage()
-            
-    # this is necessary for all old probes (annex, etc).
-    # -u only works for cql/oai
-    if url:   
-        special_main_subroutine(host, url)
-    else:
-        special_main_subroutine(host)
+            usage(command_line_parameters_usage_string)
+    
 
 if __name__ == "__main__" :