Method parse

simcore/post_script/pb_save_agent.py:304–378

parse .pblog file :param pblog_file: .pblog file :return: None

(self, pblog_path: str, start_ms: float, end_ms: float, simrec_path: str, frames_path: str, ext_info: str)

        return json.dumps(data)

    def parse(self, pblog_path: str, start_ms: float, end_ms: float, simrec_path: str, frames_path: str, ext_info: str):
        """
        parse .pblog file
        :param pblog_file: .pblog file
        :return: None
        """

        # 异常处理 - pblog 文件不存在
        if not os.path.exists(pblog_path):
            glog.error("usage: python PostProcess.py -f <pblog file>")
            return False

        #
        self.pb_log_file = pblog_path
        # if simrec_file exists. remove
        if simrec_path and os.path.exists(simrec_path):
            os.remove(simrec_path)

        if frames_path and os.path.exists(frames_path):
            os.remove(frames_path)

        # 读取 pblog 文件, 并处理异常 - 读取失败
        if not self.pblog_reader.open(self.pb_log_file):
            glog.error("fail to open pblog file {}".format(self.pb_log_file))
            return False

        # 正常业务处理流程
        # protobuf msg read from .pblog file
        event = PbEvent(0.0, "", bytes())

        frames_dict = {"frameId": -1, "extInfo": "", "tfc": "", "loc": ""}

        # parse protobuf msg
        datas_frames = []
        while self.pblog_reader.read_one(event):
            if event.topic in self.parser_dict.keys() and start_ms <= event.timestamp <= end_ms:
                try:
                    if self.parser_dict[event.topic].parse(event):
                        self.parser_dict[TOPIC.TrafficRecords4LogSimParser].serialize(event.topic, self.parser_dict)

                    frame_id = int(event.timestamp / 20 + 1)

                    if frames_dict["frameId"] != -1 and frame_id != frames_dict["frameId"]:
                        # print("=================================")
                        datas_frames.append(json.dumps(frames_dict))

                    frames_dict["frameId"] = frame_id
                    frames_dict["extInfo"] = ext_info
                    # print(event.topic, frame_id)

                    if self.parser_dict[TOPIC.LOCATION].parse(event):
                        frames_dict["loc"] = self.parser_dict[TOPIC.LOCATION].get_base64()
                        # print(f"{frames_dict['loc'] = }")

                    if self.parser_dict[TOPIC.TRAFFIC].parse(event):
                        frames_dict["tfc"] = self.parser_dict[TOPIC.TRAFFIC].get_base64()
                        # print(f"{frames_dict['tfc'] = }")