slowquery2es.py 文件源码

def initLastTime(self, path):
        if not os.path.exists(path):
            cur_time = dself._now.strftime("%y%m%d %H:%M:%S")
            self._last_time = datetime.strptime(cur_time, "%y%m%d %H:%M:%S").isoformat()
            return False

        last_re = re.compile("last_time : (.*)\\n?")

        ifs = open(path, "r")
        lines = ifs.readlines()

        for l in reversed(lines):
            if not l: continue
            m = last_re.match(l)
            if m is not None:
                self._last_time = (m.groups(0))[0]
                ifs.close()
                return True
        ifs.close()

        cur_time = self._now.strftime("%y%m%d %H:%M:%S")
        self._last_time = datetime.strptime(cur_time, "%y%m%d %H:%M:%S").isoformat()
        return False