请教zenoss的学习方法

307183927

看了下zenoss-api_2.5.0，变量好多，模块也多，
怎么入手啊，求教{:3_200:}

307183927

1. ###########################################################################
   
2. #
   
3. # This program is part of Zenoss Core, an open source monitoring platform.
   
4. # Copyright (C) 2007, Zenoss Inc.
   
5. #
   
6. # This program is free software; you can redistribute it and/or modify it
   
7. # under the terms of the GNU General Public License version 2 as published by
   
8. # the Free Software Foundation.
   
9. #
   
10. # For complete information please visit: http://www.zenoss.com/oss/
    
11. #
    
12. ###########################################################################
    
13. 
    
14. import sys
    
15. import os
    
16. import time
    
17. import socket
    
18. import ip
    
19. import icmp
    
20. import errno
    
21. import logging
    
22. log = logging.getLogger("zen.Ping")
    
23. 
    
24. from twisted.internet import reactor, defer
    
25. from twisted.spread import pb
    
26. 
    
27. class PermissionError(Exception):
    
28.     """Not permitted to access resource."""
    
29. 
    
30. class IpConflict(Exception):
    
31.     """Pinging two jobs simultaneously with different hostnames but the same IP"""
    
32. 
    
33. class PingJob(pb.Copyable, pb.RemoteCopy):
    
34.     """
    
35.     Class representing a single target to be pinged.
    
36.     """
    
37.     def __init__(self, ipaddr, hostname="", status=0, unused_cycle=60):
    
38.         self.parent = False
    
39.         self.ipaddr = ipaddr
    
40.         self.hostname = hostname
    
41.         self.status = status
    
42.         self.reset()
    
43. 
    
44. 
    
45.     def reset(self):
    
46.         self.deferred = defer.Deferred()
    
47.         self.rrt = 0
    
48.         self.start = 0
    
49.         self.sent = 0
    
50.         self.message = ""
    
51.         self.severity = 5
    
52.         self.inprocess = False
    
53.         self.pathcheck = 0
    
54.         self.eventState = 0
    
55. 
    
56. 
    
57.     def checkpath(self):
    
58.         if self.parent:
    
59.             return self.parent.checkpath()
    
60. 
    
61. 
    
62.     def routerpj(self):
    
63.         if self.parent:
    
64.             return self.parent.routerpj()
    
65. 
    
66. pb.setUnjellyableForClass(PingJob, PingJob)
    
67. 
    
68. 
    
69. plog = logging.getLogger("zen.Ping")
    
70. class Ping(object):   
    
71.     """
    
72.     Class that provides asyncronous icmp ping.
    
73.     """
    
74.    
    
75.     def __init__(self, tries=2, timeout=2, sock=None):
    
76.         self.reconfigure(tries, timeout)
    
77.         self.procId = os.getpid()
    
78.         self.jobqueue = {}
    
79.         self.pktdata = 'zenping %s %s' % (socket.getfqdn(), self.procId)
    
80.         self.createPingSocket(sock)
    
81. 
    
82. 
    
83.     def reconfigure(self, tries=2, timeout=2):
    
84.         self.tries = tries
    
85.         self.timeout = timeout
    
86. 
    
87. 
    
88.     def createPingSocket(self, sock):
    
89.         """make an ICMP socket to use for sending and receiving pings"""
    
90.         socketargs = socket.AF_INET, socket.SOCK_RAW, socket.IPPROTO_ICMP
    
91.         if sock is None:
    
92.             try:
    
93.                 s = socket
    
94.                 self.pingsocket = s.socket(*socketargs)
    
95.             except socket.error, e:
    
96.                 err, msg = e.args
    
97.                 if err == errno.EACCES:
    
98.                     raise PermissionError("must be root to send icmp.")
    
99.                 raise e
    
100.         else:
     
101.             self.pingsocket = socket.fromfd(sock, *socketargs)
     
102.             os.close(sock)
     
103.         self.pingsocket.setblocking(0)
     
104.         reactor.addReader(self)
     
105. 
     
106.     def fileno(self):
     
107.         return self.pingsocket.fileno()
     
108. 
     
109.     def doRead(self):
     
110.         self.recvPackets()
     
111. 
     
112.     def connectionLost(self, unused):
     
113.         reactor.removeReader(self)
     
114.         self.pingsocket.close()
     
115. 
     
116.     def logPrefix(self):
     
117.         return None
     
118. 
     
119.     def sendPacket(self, pingJob):
     
120.         """Take a pingjob and send an ICMP packet for it"""
     
121.         #### sockets with bad addresses fail
     
122.         try:
     
123.             pkt = icmp.Echo(self.procId, pingJob.sent, self.pktdata)
     
124.             buf = icmp.assemble(pkt)
     
125.             pingJob.start = time.time()
     
126.             plog.debug("send icmp to '%s'", pingJob.ipaddr)
     
127.             self.pingsocket.sendto(buf, (pingJob.ipaddr, 0))
     
128.             reactor.callLater(self.timeout, self.checkTimeout, pingJob)
     
129.             pingJob.sent += 1
     
130.             current = self.jobqueue.get(pingJob.ipaddr, None)
     
131.             if current:
     
132.                 if pingJob.hostname != current.hostname:
     
133.                     raise IpConflict("Host %s and %s are both using ip %s" %
     
134.                                      (pingJob.hostname,
     
135.                                       current.hostname,
     
136.                                       pingJob.ipaddr))
     
137.             self.jobqueue[pingJob.ipaddr] = pingJob
     
138.         except (SystemExit, KeyboardInterrupt): raise
     
139.         except Exception, e:
     
140.             pingJob.rtt = -1
     
141.             pingJob.message = "%s sendto error %s" % (pingJob.ipaddr, e)
     
142.             self.reportPingJob(pingJob)
     
143. 
     
144. 
     
145.     def recvPackets(self):
     
146.         """receive a packet and decode its header"""
     
147.         while reactor.running:
     
148.             try:
     
149.                 data, (host, port) = self.pingsocket.recvfrom(1024)
     
150.                 if not data: return
     
151.                 ipreply = ip.disassemble(data)
     
152.                 try:
     
153.                     icmppkt = icmp.disassemble(ipreply.data)
     
154.                 except ValueError:
     
155.                     plog.debug("checksum failure on packet %r", ipreply.data)
     
156.                     try:
     
157.                         icmppkt = icmp.disassemble(ipreply.data, 0)
     
158.                     except ValueError:
     
159.                         continue            # probably Unknown type
     
160.                 except Exception, ex:
     
161.                     plog.debug("Unable to decode reply packet payload %s", ex)
     
162.                     continue
     
163.                 sip =  ipreply.src
     
164.                 if (icmppkt.get_type() == icmp.ICMP_ECHOREPLY and
     
165.                     icmppkt.get_id() == self.procId and
     
166.                     self.jobqueue.has_key(sip)):
     
167.                     plog.debug("echo reply pkt %s %s", sip, icmppkt)
     
168.                     self.pingJobSucceed(self.jobqueue[sip])
     
169.                 elif icmppkt.get_type() == icmp.ICMP_UNREACH:
     
170.                     try:
     
171.                         origpkt = icmppkt.get_embedded_ip()
     
172.                         dip = origpkt.dst
     
173.                         if (origpkt.data.find(self.pktdata) > -1
     
174.                             and self.jobqueue.has_key(dip)):
     
175.                             self.pingJobFail(self.jobqueue[dip])
     
176.                     except ValueError, ex:
     
177.                         plog.warn("failed to parse host unreachable packet")
     
178.                 else:
     
179.                     plog.debug("unexpected pkt %s %s", sip, icmppkt)
     
180.             except (SystemExit, KeyboardInterrupt): raise
     
181.             except socket.error, err:
     
182.                 errnum, errmsg = err.args
     
183.                 if errnum == errno.EAGAIN:
     
184.                     return
     
185.                 raise err
     
186.             except Exception, ex:
     
187.                 log.exception("receiving packet error: %s" % ex)
     
188. 
     
189. 
     
190.     def pingJobSucceed(self, pj):
     
191.         """PingJob completed successfully.
     
192.         """
     
193.         plog.debug("pj succeed for %s", pj.ipaddr)
     
194.         pj.rtt = time.time() - pj.start
     
195.         pj.message = "ip %s is up" % (pj.ipaddr)
     
196.         self.reportPingJob(pj)
     
197. 
     
198. 
     
199.     def pingJobFail(self, pj):
     
200.         """PingJob has failed remove from jobqueue.
     
201.         """
     
202.         plog.debug("pj fail for %s", pj.ipaddr)
     
203.         pj.rtt = -1
     
204.         pj.message = "ip %s is down" % (pj.ipaddr)
     
205.         self.reportPingJob(pj)
     
206. 
     
207. 
     
208.     def reportPingJob(self, pj):
     
209.         if str(pj.message).endswith("is down"):
     
210.             cmdPing="ping "+pj.ipaddr+" -c 1"
     
211.             flag=os.system(cmdPing)
     
212.             if int(flag)==0:
     
213.                 pj.rtt = time.time() - pj.start
     
214.                 pj.message="ip "+pj.ipaddr+" is up"
     
215.         try:
     
216.             del self.jobqueue[pj.ipaddr]
     
217.         except KeyError:
     
218.             pass
     
219.         # also free the deferred from further reporting
     
220.         if pj.rtt < 0:
     
221.             pj.deferred.errback(pj)
     
222.         else:
     
223.             pj.deferred.callback(pj)
     
224. 
     
225. 
     
226.     def checkTimeout(self, pj):
     
227.         if self.jobqueue.has_key(pj.ipaddr):
     
228.             now = time.time()
     
229.             if now - pj.start > self.timeout:
     
230.                 if pj.sent >= self.tries:
     
231.                     plog.debug("pj timeout for %s", pj.ipaddr)
     
232.                     self.pingJobFail(pj)
     
233.                 else:
     
234.                     self.sendPacket(pj)
     
235.             else:
     
236.                 plog.debug("calling checkTimeout needlessly for %s", pj.ipaddr)
     
237. 
     
238.     def jobCount(self):
     
239.         return len(self.jobqueue)
     
240. 
     
241.     def ping(self, ip):
     
242.         "Ping the ip and return the result in a deferred"
     
243.         pj = PingJob(ip)
     
244.         self.sendPacket(pj)
     
245.         return pj.deferred
     
246. 
     
247. 
     
248. def _printResults(results, start):
     
249.     good = [pj for s, pj in results if s and pj.rtt >= 0]
     
250.     bad = [pj for s, pj in results if s and pj.rtt < 0]
     
251.     if good: print "Good ips: %s" % " ".join([g.ipaddr for g in good])
     
252.     if bad: print "Bad ips: %s" % " ".join([b.ipaddr for b in bad])
     
253.     print "Tested %d ips in %.1f seconds" % (len(results), time.time() - start)
     
254.     reactor.stop()
     
255. 
     
256. if __name__ == "__main__":
     
257.     ping = Ping()
     
258.     logging.basicConfig()
     
259.     log = logging.getLogger()
     
260.     log.setLevel(10)
     
261.     if len(sys.argv) > 1: targets = sys.argv[1:]
     
262.     else: targets = ("127.0.0.1",)
     
263.     lst = defer.DeferredList(map(ping.ping, targets), consumeErrors=True)
     
264.     lst.addCallback(_printResults, time.time())
     
265.     reactor.run()
     

复制代码

zenoss-api_2.5.0\api\Products.ZenStatus.AsyncPing-module.html
ip 和icmp模块在哪里可以找得到啊

106033177

回复 1# 307183927
自带了 在externallibs里。 这里也有 http://pypi.python.org/pypi/pyip/

307183927

真详细，地址都给出来了，‘106033177’ 谢谢了{:3_193:}