如何通过Go SDK追加上传文件 - 对象存储 OSS

追加上传是指通过AppendObject方法在已上传的追加类型文件（Appendable Object）末尾直接追加内容。

注意事项

本文以华东1（杭州）外网Endpoint为例。如果您希望通过与OSS同地域的其他阿里云产品访问OSS，请使用内网Endpoint。关于OSS支持的Region与Endpoint的对应关系，请参见OSS访问域名、数据中心、开放端口。
本文以从环境变量读取访问凭证为例。如何配置访问凭证，请参见配置访问凭证。
本文以OSS域名新建OSSClient为例。如果您希望通过自定义域名、STS等方式新建OSSClient，请参见初始化。
要追加上传，您必须有oss:PutObject权限。具体操作，请参见为RAM用户授权自定义的权限策略。
当文件不存在时，调用AppendObject接口会创建一个追加类型文件。
当文件已存在时：
- 如果文件为追加类型文件，且设置的追加位置和文件当前长度相等，则直接在该文件末尾追加内容。
- 如果文件为追加类型文件，但是设置的追加位置和文件当前长度不相等，则抛出PositionNotEqualToLength异常。
- 如果文件为非追加类型文件时，例如通过简单上传的文件类型为Normal的文件，则抛出ObjectNotAppendable异常。

示例代码

以下代码用于追加上传文件：

package main

import (
	"log"
	"strings"
	"time"

	"github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func main() {
	// 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
	provider, err := oss.NewEnvironmentVariableCredentialsProvider()
	if err != nil {
		log.Fatalf("Failed to create credentials provider: %v", err)
	}

	// 创建OSSClient实例。
	// yourEndpoint填写Bucket对应的Endpoint，以华东1（杭州）为例，填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
	// yourRegion填写Bucket所在地域，以华东1（杭州）为例，填写为cn-hangzhou。其它Region请按实际情况填写。
	clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
	clientOptions = append(clientOptions, oss.Region("yourRegion"))
	// 设置签名版本
	clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
	client, err := oss.New("yourEndpoint", "", "", clientOptions...)
	if err != nil {
		log.Fatalf("Failed to create OSS client: %v", err)
	}

	// 填写Bucket名称，例如examplebucket。
	bucketName := "examplebucket" // 请替换为实际的Bucket名称
	bucket, err := client.Bucket(bucketName)
	if err != nil {
		log.Fatalf("Failed to get bucket: %v", err)
	}

	// 填写不包含Bucket名称在内的Object的完整路径，例如appendobject.txt。
	objectName := "appendobject.txt"
	var nextPos int64 = 0

	// 指定过期时间。
	expires := time.Date(2025, time.December, 10, 23, 0, 0, 0, time.UTC)
	options := []oss.Option{
		oss.Expires(expires),
	}

	// 第一次追加上传的位置是0，返回值为下一次追加的位置。
	appendValue1 := "YourObjectAppendValue1"
	nextPos, err = bucket.AppendObject(objectName, strings.NewReader(appendValue1), nextPos, options...)
	if err != nil {
		log.Fatalf("Failed to append first value: %v", err)
	}

	// 第二次追加上传。
	appendValue2 := "YourObjectAppendValue2"
	nextPos, err = bucket.AppendObject(objectName, strings.NewReader(appendValue2), nextPos)
	if err != nil {
		log.Fatalf("Failed to append second value: %v", err)
	}

	log.Println("Append uploads completed successfully.")
}

常见问题

如果不是第一次追加上传，该如何使用AppendObject方法？

当您遇到以下场景时，为了确保数据能够正确地追加到正确的位置，您可以通过调用GetObjectDetailedMeta方法获取对象的元数据，其中包含最后一次追加上传的结束位置。

应用日志收集：
- 应用程序运行时会产生大量的日志信息，通过追加上传的方式，可以将日志数据不断地追加到同一个对象中，而不必每次都创建新的对象。
实时数据分析：
- 实时数据分析系统通常会将数据流不断地发送到存储系统中。通过追加上传，可以将这些数据流实时地追加到同一个对象中，便于后续的批处理或实时处理。

...
props, err := bucket.GetObjectDetailedMeta(objectName)
if err != nil {
	log.Fatalf("Failed to get object detailed meta: %v", err)
}
nextPos, err = strconv.ParseInt(props.Get("X-Oss-Next-Append-Position"), 10, 64)
if err != nil {
	log.Fatalf("Failed to parse next position: %v", err)
}

// 追加上传。
appendValue2 := "YourObjectAppendValue2"
nextPos, err = bucket.AppendObject(objectName, strings.NewReader(appendValue2), nextPos)
if err != nil {
	log.Fatalf("Failed to append second value: %v", err)
}

log.Println("Append uploads completed successfully.")

对象存储 OSS：Go追加上传

注意事项

示例代码

常见问题

相关文档