首页

流式上传

    SDK 提供IOPut与IOMutipartAsyncUpload方法实现了流式上传功能，即使用io.Reader作为对象的数据源。IOPut适用于小文件，IOMutipartAsyncUpload适用于大文件。完整代码详见 Github。

    IOPut 代码示例

    1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

    package main

import (
	ufsdk "github.com/ufilesdk-dev/ufile-gosdk"
	"log"
	"os"
)

const (
	ConfigFile = "./config.json"
	FilePath = "./FakeSmallFile.txt"
	KeyName = "FakeSmallFile.txt"
)

func main() {
	config, err := ufsdk.LoadConfig(ConfigFile)
	if err != nil {
		log.Fatal(err.Error())
	}
	req, err := ufsdk.NewFileRequest(config, nil)
	if err != nil {
		log.Fatal(err.Error())
	}
	// 流式上传本地小文件
	f, err := os.Open(FilePath)
	if err != nil {
		panic(err.Error())
	}
	err = req.IOPut(f, KeyName, "")
	f.Close()
	if err != nil {
		log.Fatalf("%s\n", req.DumpResponse(true))
	}
	log.Printf("文件 %s 上传成功", FilePath)
}

    IOMutipartAsyncUpload代码示例

    1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

    package main

import (
	ufsdk "github.com/ufilesdk-dev/ufile-gosdk"
	"log"
	"os"
)

const (
	ConfigFile = "config.json"
	FilePath = "FakeBigFile.txt" 	// 待上传的本地文件路径
	KeyName = "FakeBigFile.txt" 	// 上传至US3 Bucket后文件的键值
)

func main() {
	config, err := ufsdk.LoadConfig(ConfigFile)
	if err != nil {
		log.Fatal(err.Error())
	}
	req, err := ufsdk.NewFileRequest(config, nil)
	if err != nil {
		log.Fatal(err.Error())
	}
	// 流式上传大文件
	f, err := os.Open(FilePath)
	if err != nil {
		panic(err.Error())
	}
	err = req.IOMutipartAsyncUpload(f, KeyName, "")
	f.Close()
	if err != nil {
		log.Fatalf("%s\n", req.DumpResponse(true))
	}
	log.Printf("文件 %s 上传成功", FilePath)
}