spider_runner.py 文件源码

def childDataReceived(self, childFD, data):
        #self.sptl.monitor
        try:
            for pid, sid in self.sptl.monitor_ps.iteritems():
                print pid, sid
                if pid == self.pid:
                    self.sptl.publish("psmonitor", data, eligible=[sid])
        except Exception, e:
            print e
        protocol.ProcessProtocol.childDataReceived(self, childFD, data)