fix: 解决 sftp 上传大文件失败的问题 (#1294)

backend/utils/cloud_storage/client/sftp.go

@@ -1,8 +1,8 @@
 package client
 
 import (
+	"bufio"
 	"fmt"
-	"io"
 	"net"
 	"os"
 	"path"
@@ -75,11 +75,18 @@ func (s sftpClient) Upload(src, target string) (bool, error) {
 		return false, err
 	}
 	defer dstFile.Close()
-	ff, err := io.ReadAll(srcFile)
+
-	if err != nil {
+	reader := bufio.NewReaderSize(srcFile, 128*1024*1024)
-		return false, err
+	for {
+		chunk, err := reader.Peek(8 * 1024 * 1024)
+		if len(chunk) != 0 {
+			_, _ = dstFile.Write(chunk)
+			_, _ = reader.Discard(len(chunk))
+		}
+		if err != nil {
+			break
+		}
 	}
-	_, _ = dstFile.Write(ff)
 	return true, nil
 }