telescope_states.py 文件源码

def get(self):
        telescope_states = {}
        current_lump = dict(reasons=None, types=None, start=None)

        for event in self.event_data:
            if self._telescope(event['_source']) not in self.available_telescopes:
                continue

            if current_lump['start'] is None:
                current_lump = self._set_lump(event)
                continue

            if self._belongs_in_lump(event['_source'], current_lump):
                current_lump = self._update_lump(current_lump, event)
            else:
                lump_end = self._lump_end(current_lump, event['_source'])
                if lump_end >= self.start:
                    telescope_states = self._update_states(telescope_states, current_lump, lump_end)
                    current_lump = self._set_lump(event)

        if current_lump['start']:
            lump_end = self._lump_end(current_lump)
            telescope_states = self._update_states(telescope_states, current_lump, lump_end)

        return telescope_states