Method update_task_progress

client/util/reporter.py:75–101

向server上报,更新任务执行进度 :param info: 上报信息Info实例 :return:

(self, info)

        self._task_scene = task_params.get('task_scene', None)

    def update_task_progress(self, info):
        """向server上报,更新任务执行进度

        :param info: 上报信息Info实例
        :return:
        """
        # test任务无需上报,直接返回
        if self._task_scene and self._task_scene in [TaskScene.TEST]:
            return
        if QuickScan.is_quick_scan():
            return
        try:
            # 从param中获取server_url
            server_url = self._task_params.get("server_url", None)
            # 从param中获取token并解密
            encrypted_token = self._task_params.get("token", None)
            token = Crypto(settings.PASSWORD_KEY).decrypt(encrypted_token)

            dog_server = RetryDogServer(server_url, token).get_api_server(retry_times=0)
            # 非节点模式,NODE_ID字段传参为None
            node_id = persist_data.get('NODE_ID') if self._task_scene == TaskScene.NORMAL else None
            dog_server.update_task_progress(self._task_params,
                                            node_id,
                                            info.message,
                                            info.percent)
        except Exception as err:
            logger.exception('Update_task_progress fail. upload msg:%s', info.message)