From bde8258f7de3dfc5cbf0fc59f2b74ed0fd073df7 Mon Sep 17 00:00:00 2001
From: shikeying <shikeying@163.com>
Date: 星期日, 31 三月 2024 11:11:20 +0800
Subject: [PATCH] 添加milvus代码示例
---
iplatform-file-server/src/main/java/com/iplatform/file/FileEngineFactory.java | 27 +++++++++++++++++++++++++--
1 files changed, 25 insertions(+), 2 deletions(-)
diff --git a/iplatform-file-server/src/main/java/com/iplatform/file/FileEngineFactory.java b/iplatform-file-server/src/main/java/com/iplatform/file/FileEngineFactory.java
index 90e0b86..d1d64bc 100644
--- a/iplatform-file-server/src/main/java/com/iplatform/file/FileEngineFactory.java
+++ b/iplatform-file-server/src/main/java/com/iplatform/file/FileEngineFactory.java
@@ -1,5 +1,6 @@
package com.iplatform.file;
+import com.iplatform.base.PlatformRuntimeException;
import com.iplatform.file.util.FileStoreUtils;
import com.walker.file.FileInfo;
import com.walker.file.FileOperateEngine;
@@ -25,6 +26,21 @@
public class FileEngineFactory implements ApplicationBeanInitialized {
protected final transient Logger logger = LoggerFactory.getLogger(this.getClass());
+
+ /**
+ * 涓嬭浇oss鏂囦欢
+ * @param fileStoreType
+ * @param id 鏂囦欢鍞竴缂栧彿
+ * @return
+ * @date 2023-12-13
+ */
+ public byte[] downloadOssFile(FileStoreType fileStoreType, String id){
+ try {
+ return this.fileOperateEngineMap.get(fileStoreType).downloadFile(id);
+ } catch (FileOperateException e) {
+ throw new PlatformRuntimeException("涓嬭浇oss鏂囦欢閿欒锛�" + e.getMessage() + ", id=" + id, e);
+ }
+ }
/**
* 鏍规嵁鏂囦欢ID锛岃繑鍥炴枃浠跺璞°��
@@ -142,7 +158,8 @@
public FileInfo uploadFileToOss(InputStream inputStream, String fileName, String groupId
, long fileSize, Integer businessType, String owner, FileStoreType fileStoreType) throws FileOperateException{
if(fileStoreType != FileStoreType.OssQiNiu
- && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli){
+ && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli
+ && fileStoreType != FileStoreType.OssAws){
throw new UnsupportedOperationException("涓嶆敮鎸佺殑OSS绫诲瀷锛�" + fileStoreType);
}
if(this.remoteAsLocal){
@@ -155,7 +172,8 @@
public FileInfo[] uploadFileToOss(InputStream[] inputStream, String[] fileName, String groupId
, long[] fileSize, Integer businessType, String owner, FileStoreType fileStoreType) throws FileOperateException{
if(fileStoreType != FileStoreType.OssQiNiu
- && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli){
+ && fileStoreType != FileStoreType.OssTx && fileStoreType != FileStoreType.OssAli
+ && fileStoreType != FileStoreType.OssAws){
throw new UnsupportedOperationException("涓嶆敮鎸佺殑OSS绫诲瀷锛�" + fileStoreType);
}
if(this.remoteAsLocal){
@@ -238,6 +256,11 @@
if(StringUtils.isNotEmpty(fileUrlPrefixConfig)){
FileStoreUtils.fileStoreTypeUrlPrefix.put(FileStoreType.OssAli.getIndex(), fileUrlPrefixConfig);
}
+ // 2024-02-23 s3瀵硅薄涓婁紶
+ fileUrlPrefixConfig = this.getFileUrlPrefix(FileStoreType.OssAws.getIndex());
+ if(StringUtils.isNotEmpty(fileUrlPrefixConfig)){
+ FileStoreUtils.fileStoreTypeUrlPrefix.put(FileStoreType.OssAws.getIndex(), fileUrlPrefixConfig);
+ }
}
/**
--
Gitblit v1.9.1