Das deutsche Python-Forum

Code: Alles auswählen

status = open("status.dat", "r") 
	for line in status: 
	    if "plugin_output=OK" in line:

Code: Alles auswählen

	status = open("status.dat", "r") 
	for line in status: 
	    if "plugin_output=" in line:
		if "text" in zeilen + 25:  #genau hier ist das Prob...

Code: Alles auswählen

with open("status.dat") as fp:
    match = None
    for index, line in enumerate(fp):
        if match is None:
            if line.startswith("plugin_output="):
                match = index
        elif match + 25 <= index:
            ....

Code: Alles auswählen

servicestatus {
        host_name=localhost
        service_description=Current Load
        modified_attributes=2
        check_command=check_load!5.0!4.0!3.0!10.0!6.0!4.0
        check_period=24x7
        notification_period=24x7
        check_interval=5.000000
        retry_interval=1.000000
        event_handler=
        has_been_checked=1
        should_be_scheduled=1
        check_execution_time=0.004
        check_latency=0.065
        check_type=0
        current_state=0
        last_hard_state=0
        last_event_id=19
        current_event_id=21
        current_problem_id=0
        last_problem_id=8
        current_attempt=1
        max_attempts=4
        state_type=1
        last_state_change=1347004244
        last_hard_state_change=1346916726
        last_time_ok=1347017144
        last_time_warning=0
        last_time_unknown=1346942507
        last_time_critical=1347004184
        plugin_output=OK - load average: 0.00, 0.00, 0.00 # <-- das ist das erste Anzeichen nach dem ich suche, danach sollen die weiteren zeilen geprüft werden
        long_plugin_output=
        performance_data=load1=0.000;5.000;10.000;0; load5=0.000;4.000;6.000;0; load15=0.000;3.000;4.000;0;
        last_check=1347017144
        next_check=1347017444
        check_options=0
        current_notification_number=0
        current_notification_id=0
        last_notification=0
        next_notification=0
        no_more_notifications=0
        notifications_enabled=1
        active_checks_enabled=1
        passive_checks_enabled=1
        event_handler_enabled=1
        problem_has_been_acknowledged=0   # <-- das hier muss nach OK abgefragt werden
        acknowledgement_type=0
        flap_detection_enabled=1
        failure_prediction_enabled=1
        process_performance_data=0
        obsess_over_service=0
        last_update=1347007258
        is_flapping=0
        percent_state_change=0.00
        scheduled_downtime_depth=1  # <-- das hier muss auch nach OK abgefragt werden
        __LB_SERVER=0;192.168.121.10
        __LB_PORT=0;7297
        __LB_CUSTOM=0;
        __LB=0;__lb
        }

Code: Alles auswählen

def parse(filename):
    with open(filename) as fp:
        obj = None
        
        for line in (l.strip() for l in fp):
            if line.endswith("{"):
                obj = {}
            elif line.startswith("}"):
                yield obj
                obj = None
            elif obj is not None and line:
                name, value = line.split("=", 1)
                obj[name] = value

for obj in parse("test.dat"):
    if (obj["plugin_output"].startswith("OK") and
        obj["problem_has_been_acknowledged"] == "1" and
        obj["scheduled_downtime_depth"] == "1"):
        ....

Code: Alles auswählen

  File "lampe2.py", line 32, in <module>
    Main(sys.argv[1:])
  File "lampe2.py", line 22, in Main
    for obj in parse("status2.dat"):
  File "lampe2.py", line 11, in parse
    for line in (l.strip() for l in fp):
ValueError: I/O operation on closed file

Code: Alles auswählen

#!/usr/bin/env python

import time
import commands
import sys

def Main(argv):
	i = 0
	while i < 1:
		OK = 0
		WARNING = 0
		CRITICAL = 0
		UNKNOWN = 0
		ACKNOW = 0
		SCHEDU = 0
		with open("/home/tweber/status.dat") as fp:
			match = None
			for index, line in enumerate(fp):
				if match is None:
					if "plugin_output=" in line:
						if "OK" in line:
							match = index
							okay = match
							OK = OK + 1
							match = None
	
						elif "WARNING" in line:
							match = index
							WARN = match
							WARNING= WARNING + 1
							match = None

						elif "CRITICAL" in line:
							match = index
							CRIT = match
							CRITICAL = CRITICAL + 1
							match = None
	
						elif "UNKNOWN" in line:
							match = index
							UNKN = match
							UNKNOWN = UNKNOWN + 1
							match = None

				elif WARN + 10 <= index: 
					if "problem_has_been_acknowledged=0" in line:
						print "AH2!"
						match = None 

		fp.close()
		i = i +1
		print "UNKNOWN" 
		print UNKNOWN  
		print "WARNING" 
		print WARNING 
		print "OK"	
		print OK
		print "CRITICAL"
		print CRITICAL 
#		print "SCHEDU"
#		print SCHEDU	
#		print "ACKNOW"
#		print ACKNOW

if __name__ == '__main__':
    Main(sys.argv[1:])

Code: Alles auswählen

def auslesen(status):
	with open("/home/tweber/status.dat") as statuspart:
		servicestatus = None
        	for line in (l.strip(" ") for l in statuspart):
			if line.endswith("{", 1, len(line)):
				servicestatus = {}
								
			elif line.startswith("}", 0, len(line)):
				yield servicestatus
				servicestatus = None
			
			elif servicestatus is not None and line:
				name, value = line.split("=", 1)
				servicestatus["plugin_output"] = value 
				servicestatus["problem_has_been_acknowledged"] = value 
				servicestatus["scheduled_downtime_depth"] = value 
			
def Main(argv):
	print "hallo"
	for servicestatus in auslesen("/home/tweber/status.dat"):
		print "das hier?"
		if (servicestatus["plugin_output"].startswith("OK", 0, len(servicestatus["plugin_output"])) and   # oder "OK" in servicestatus["plugin_output"]
		servicestatus["problem_has_been_acknowledged"] == "0" and
		servicestatus["scheduled_downtime_depth"] == "0"):
			green()
		else:
			print "hallo?"			
			off()

if __name__ == "__main__":
    Main(sys.argv[1:])

Code: Alles auswählen

elif servicestatus is not None and line:
                                name, value = line.split("=", 1)
                                servicestatus["plugin_output"] = value 
                                servicestatus["problem_has_been_acknowledged"] = value 
                                servicestatus["scheduled_downtime_depth"] = value 

Code: Alles auswählen

with open("/home/tweber/status.dat") as statuspart:

Code: Alles auswählen

sein with open(status) as statuspart:

Code: Alles auswählen

 servicestatus["plugin_output"] = value 
servicestatus["problem_has_been_acknowledged"] = value 
servicestatus["scheduled_downtime_depth"] = value 

Code: Alles auswählen

 servicestatus[name] = value