"github.com/volcengine/ve-tos-golang-sdk/v2/tos"
func checkErr(err error) {
if serverErr, ok := err.(*tos.TosServerError); ok {
if serverErr.StatusCode == http.StatusNotFound {
fmt.Println("Error:", serverErr.Error())
fmt.Println("Request ID:", serverErr.RequestID)
fmt.Println("Response Status Code:", serverErr.StatusCode)
fmt.Println("Response Header:", serverErr.Header)
fmt.Println("Response Err Code:", serverErr.Code)
fmt.Println("Response Err Msg:", serverErr.Message)
} else if clientErr, ok := err.(*tos.TosClientError); ok {
fmt.Println("Error:", clientErr.Error())
fmt.Println("Client Cause Err:", clientErr.Cause.Error())
fmt.Println("Error:", err)
accessKey = os.Getenv("TOS_ACCESS_KEY")
secretKey = os.Getenv("TOS_SECRET_KEY")
endpoint = "https://tos-cn-beijing.volces.com"
bucketName = "*** Provide your bucket name ***"
ctx = context.Background()
client, err := tos.NewClientV2(endpoint, tos.WithRegion(region), tos.WithCredentials(tos.NewStaticCredentials(accessKey, secretKey)))
oldPrefix := "exampledir1/"
newPrefix := "exampledir2/"
output, err := client.ListObjectsType2(ctx, &tos.ListObjectsType2Input{
ContinuationToken: continuationToken,
for _, obj := range output.Contents {
newKey := strings.Replace(obj.Key, oldPrefix, newPrefix, 1)
output, err := client.CopyObject(ctx, &tos.CopyObjectInput{
fmt.Println("CopyObject Request ID:", output.RequestID)
deleteOutput, err := client.DeleteObjectV2(ctx, &tos.DeleteObjectV2Input{
fmt.Println("DeleteObjectV2 Request ID:", deleteOutput.RequestID)
truncated = output.IsTruncated
continuationToken = output.NextContinuationToken