| | |
| | | String originalName = file.getOriginalFilename(); |
| | | String objectKey = buildObjectKey(bizPath, originalName); |
| | | File tempFile = createTempFile(file, originalName); |
| | | uploadProgressService.init(taskId); |
| | | long totalBytes = file.getSize(); |
| | | uploadProgressService.init(taskId, totalBytes); |
| | | try (ObsClient obsClient = new ObsClient( |
| | | properties.getAccessKeyId(), |
| | | properties.getSecretAccessKey(), |
| | |
| | | request.setProgressInterval(1024 * 100L); |
| | | obsClient.putObject(request); |
| | | UploadFileResult result = new UploadFileResult(buildFileUrl(objectKey), originalName, objectKey); |
| | | uploadProgressService.markSuccess(taskId, result); |
| | | uploadProgressService.markSuccess(taskId, result, totalBytes); |
| | | return result; |
| | | } catch (ObsException e) { |
| | | log.error("OBS文件上传失败: bucket={}, objectKey={}", properties.getBucketName(), objectKey, e); |