Method put_file

server/projects/analysis/util/fileserver.py:83–111

将指定数据存储到文件服务器的指定路径下 :params data: 需要上传的数据 :type data: string :params to_file_url_or_path: 可以指定上传到指定路径，如已存在，则更新该文件，为空则由系统创建随机命名文件 :type to_file_url_or_path: string :params type: 仅在to_file_url_or_path为路径时有效 :type type: FileServer.TypeEnum :return

(self, data, to_file_url_or_path=None, type=TypeEnum.TEMPORARY)

    @RetryDecor(interval=3)
    def put_file(self, data, to_file_url_or_path=None, type=TypeEnum.TEMPORARY):
        """将指定数据存储到文件服务器的指定路径下
        :params data: 需要上传的数据
        :type data: string
        :params to_file_url_or_path: 可以指定上传到指定路径，如已存在，则更新该文件，为空则由系统创建随机命名文件
        :type to_file_url_or_path: string
        :params type: 仅在to_file_url_or_path为路径时有效
        :type type: FileServer.TypeEnum
        :return: file_url：文件服务器指定的路径
        """
        if type not in self.TypeEnum.values():
            raise ValueError("type参数错误。支持的类型：%s" % self.TypeEnum.values())
        if to_file_url_or_path:
            file_url = to_file_url_or_path if to_file_url_or_path.startswith(self._server_url) \
                else urllib.parse.urljoin(self._server_url, "%s_%s/%s" % (self._type_prefix, type, to_file_url_or_path))
        else:
            # 无命名文件默认上传到临时文件夹，数据保留7天
            file_url = urllib.parse.urljoin(self._server_url, "%s_%s/unnamed/%s.file" % (
                self._type_prefix, self.TypeEnum.TEMPORARY, uuid.uuid1().hex))
        headers = copy.copy(self.get_auth_headers())
        headers.update({"Content-SHA256": self.get_data_sha256(data), "Content-MD5": self.get_data_md5(data)})
        rsp = self._http_client.put(file_url, data=data, headers=headers)
        if rsp.status == self.OK_STATUS:
            return file_url
        else:
            logger.error('return code %d when put file to %s, content: %s' % (
                rsp.status, file_url, rsp.data.decode("utf-8")))
            raise ServerError(errcode.E_SERVER_FILE_SERVICE_ERROR,
                              'return code %d when put file to %s' % (rsp.status, file_url))

    @RetryDecor()
    def get_file(self, file_url):