Merge pull request #68 from agin719/addbatch

Addbatch
6 years ago · 9d27f18335
12 changed files with 1074 additions and 11 deletions
--- a/batch.go
+++ b/batch.go
@ -0,0 +1,262 @@
+package cos
+
+import (
+	"context"
+	"encoding/xml"
+	"fmt"
+	"net/http"
+)
+
+type BatchService service
+
+type BatchRequestHeaders struct {
+	XCosAppid     int          `header:"x-cos-appid" xml:"-" url:"-"`
+	ContentLength string       `header:"Content-Length,omitempty" xml:"-" url:"-"`
+	ContentType   string       `header:"Content-Type,omitempty" xml:"-" url:"-"`
+	Headers       *http.Header `header:"-" xml:"-", url:"-"`
+}
+
+// BatchProgressSummary
+type BatchProgressSummary struct {
+	NumberOfTasksFailed    int `xml:"NumberOfTasksFailed" header:"-" url:"-"`
+	NumberOfTasksSucceeded int `xml:"NumberOfTasksSucceeded" header:"-" url:"-"`
+	TotalNumberOfTasks     int `xml:"TotalNumberOfTasks" header:"-" url:"-"`
+}
+
+// BatchJobReport
+type BatchJobReport struct {
+	Bucket      string `xml:"Bucket" header:"-" url:"-"`
+	Enabled     string `xml:"Enabled" header:"-" url:"-"`
+	Format      string `xml:"Format" header:"-" url:"-"`
+	Prefix      string `xml:"Prefix,omitempty" header:"-" url:"-"`
+	ReportScope string `xml:"ReportScope" header:"-" url:"-"`
+}
+
+// BatchJobOperationCopy
+type BatchMetadata struct {
+	Key   string `xml:"Key" header:"-" url:"-"`
+	Value string `xml:"Value" header:"-" url:"-"`
+}
+type BatchNewObjectMetadata struct {
+	CacheControl       string          `xml:"CacheControl,omitempty" header:"-" url:"-"`
+	ContentDisposition string          `xml:"ContentDisposition,omitempty" header:"-" url:"-"`
+	ContentEncoding    string          `xml:"ContentEncoding,omitempty" header:"-" url:"-"`
+	ContentType        string          `xml:"ContentType,omitempty" header:"-" url:"-"`
+	HttpExpiresDate    string          `xml:"HttpExpiresDate,omitempty" header:"-" url:"-"`
+	SSEAlgorithm       string          `xml:"SSEAlgorithm,omitempty" header:"-" url:"-"`
+	UserMetadata       []BatchMetadata `xml:"UserMetadata>member,omitempty" header:"-" url:"-"`
+}
+type BatchGrantee struct {
+	DisplayName    string `xml:"DisplayName,omitempty" header:"-" url:"-"`
+	Identifier     string `xml:"Identifier" header:"-" url:"-"`
+	TypeIdentifier string `xml:"TypeIdentifier" header:"-" url:"-"`
+}
+type BatchCOSGrant struct {
+	Grantee    *BatchGrantee `xml:"Grantee" header:"-" url:"-"`
+	Permission string        `xml:"Permission" header:"-" url:"-"`
+}
+type BatchAccessControlGrants struct {
+	COSGrants *BatchCOSGrant `xml:"COSGrant,omitempty" header:"-" url:"-"`
+}
+type BatchJobOperationCopy struct {
+	AccessControlGrants       *BatchAccessControlGrants `xml:"AccessControlGrants,omitempty" header:"-" url:"-"`
+	CannedAccessControlList   string                    `xml:"CannedAccessControlList,omitempty" header:"-" url:"-"`
+	MetadataDirective         string                    `xml:"MetadataDirective,omitempty" header:"-" url:"-"`
+	ModifiedSinceConstraint   int64                     `xml:"ModifiedSinceConstraint,omitempty" header:"-" url:"-"`
+	UnModifiedSinceConstraint int64                     `xml:"UnModifiedSinceConstraint,omitempty" header:"-" url:"-"`
+	NewObjectMetadata         *BatchNewObjectMetadata   `xml:"NewObjectMetadata,omitempty" header:"-" url:"-"`
+	StorageClass              string                    `xml:"StorageClass,omitempty" header:"-" url:"-"`
+	TargetResource            string                    `xml:"TargetResource" header:"-" url:"-"`
+}
+
+// BatchJobOperation
+type BatchJobOperation struct {
+	PutObjectCopy *BatchJobOperationCopy `xml:"COSPutObjectCopy,omitempty" header:"-" url:"-"`
+}
+
+// BatchJobManifest
+type BatchJobManifestLocation struct {
+	ETag            string `xml:"ETag" header:"-" url:"-"`
+	ObjectArn       string `xml:"ObjectArn" header:"-" url:"-"`
+	ObjectVersionId string `xml:"ObjectVersionId,omitempty" header:"-" url:"-"`
+}
+type BatchJobManifestSpec struct {
+	Fields []string `xml:"Fields>member,omitempty" header:"-" url:"-"`
+	Format string   `xml:"Format" header:"-" url:"-"`
+}
+type BatchJobManifest struct {
+	Location *BatchJobManifestLocation `xml:"Location" header:"-" url:"-"`
+	Spec     *BatchJobManifestSpec     `xml:"Spec" header:"-" url:"-"`
+}
+
+type BatchCreateJobOptions struct {
+	XMLName              xml.Name           `xml:"CreateJobRequest" header:"-" url:"-"`
+	ClientRequestToken   string             `xml:"ClientRequestToken" header:"-" url:"-"`
+	ConfirmationRequired string             `xml:"ConfirmationRequired,omitempty" header:"-" url:"-"`
+	Description          string             `xml:"Description,omitempty" header:"-" url:"-"`
+	Manifest             *BatchJobManifest  `xml:"Manifest" header:"-" url:"-"`
+	Operation            *BatchJobOperation `xml:"Operation" header:"-" url:"-"`
+	Priority             int                `xml:"Priority" header:"-" url:"-"`
+	Report               *BatchJobReport    `xml:"Report" header:"-" url:"-"`
+	RoleArn              string             `xml:"RoleArn" header:"-" url:"-"`
+}
+
+type BatchCreateJobResult struct {
+	XMLName xml.Name `xml:"CreateJobResult"`
+	JobId   string   `xml:"JobId,omitempty"`
+}
+
+func processETag(opt *BatchCreateJobOptions) *BatchCreateJobOptions {
+	if opt != nil && opt.Manifest != nil && opt.Manifest.Location != nil {
+		opt.Manifest.Location.ETag = "<ETag>" + opt.Manifest.Location.ETag + "</ETag>"
+	}
+	return opt
+}
+
+func (s *BatchService) CreateJob(ctx context.Context, opt *BatchCreateJobOptions, headers *BatchRequestHeaders) (*BatchCreateJobResult, *Response, error) {
+	var res BatchCreateJobResult
+	sendOpt := sendOptions{
+		baseURL:   s.client.BaseURL.BatchURL,
+		uri:       "/jobs",
+		method:    http.MethodPost,
+		optHeader: headers,
+		body:      opt,
+		result:    &res,
+	}
+
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
+
+type BatchJobFailureReasons struct {
+	FailureCode   string `xml:"FailureCode" header:"-" url:"-"`
+	FailureReason string `xml:"FailureReason" header:"-" url:"-"`
+}
+
+type BatchDescribeJob struct {
+	ConfirmationRequired string                  `xml:"ConfirmationRequired,omitempty" header:"-" url:"-"`
+	CreationTime         string                  `xml:"CreationTime,omitempty" header:"-" url:"-"`
+	Description          string                  `xml:"Description,omitempty" header:"-" url:"-"`
+	FailureReasons       *BatchJobFailureReasons `xml:"FailureReasons>JobFailure,omitempty" header:"-" url:"-"`
+	JobId                string                  `xml:"JobId" header:"-" url:"-"`
+	Manifest             *BatchJobManifest       `xml:"Manifest" header:"-" url:"-"`
+	Operation            *BatchJobOperation      `xml:"Operation" header:"-" url:"-"`
+	Priority             int                     `xml:"Priority" header:"-" url:"-"`
+	ProgressSummary      *BatchProgressSummary   `xml:"ProgressSummary" header:"-" url:"-"`
+	Report               *BatchJobReport         `xml:"Report,omitempty" header:"-" url:"-"`
+	RoleArn              string                  `xml:"RoleArn,omitempty" header:"-" url:"-"`
+	Status               string                  `xml:"Status,omitempty" header:"-" url:"-"`
+	StatusUpdateReason   string                  `xml:"StatusUpdateReason,omitempty" header:"-" url:"-"`
+	SuspendedCause       string                  `xml:"SuspendedCause,omitempty" header:"-" url:"-"`
+	SuspendedDate        string                  `xml:"SuspendedDate,omitempty" header:"-" url:"-"`
+	TerminationDate      string                  `xml:"TerminationDate,omitempty" header:"-" url:"-"`
+}
+type BatchDescribeJobResult struct {
+	XMLName xml.Name          `xml:"DescribeJobResult"`
+	Job     *BatchDescribeJob `xml:"Job,omitempty"`
+}
+
+func (s *BatchService) DescribeJob(ctx context.Context, id string, headers *BatchRequestHeaders) (*BatchDescribeJobResult, *Response, error) {
+	var res BatchDescribeJobResult
+	u := fmt.Sprintf("/jobs/%s", id)
+	sendOpt := sendOptions{
+		baseURL:   s.client.BaseURL.BatchURL,
+		uri:       u,
+		method:    http.MethodGet,
+		optHeader: headers,
+		result:    &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
+
+type BatchListJobsOptions struct {
+	JobStatuses string `url:"jobStatuses,omitempty" header:"-" xml:"-"`
+	MaxResults  int    `url:"maxResults,omitempty" header:"-" xml:"-"`
+	NextToken   string `url:"nextToken,omitempty" header:"-" xml:"-"`
+}
+
+type BatchListJobsMember struct {
+	CreationTime    string                `xml:"CreationTime,omitempty" header:"-" url:"-"`
+	Description     string                `xml:"Description,omitempty" header:"-" url:"-"`
+	JobId           string                `xml:"JobId,omitempty" header:"-" url:"-"`
+	Operation       string                `xml:"Operation,omitempty" header:"-" url:"-"`
+	Priority        int                   `xml:"Priority,omitempty" header:"-" url:"-"`
+	ProgressSummary *BatchProgressSummary `xml:"ProgressSummary,omitempty" header:"-" url:"-"`
+	Status          string                `xml:"Status,omitempty" header:"-" url:"-"`
+	TerminationDate string                `xml:"TerminationDate,omitempty" header:"-" url:"-"`
+}
+type BatchListJobs struct {
+	Members []BatchListJobsMember `xml:"member,omitempty" header:"-" url:"-"`
+}
+type BatchListJobsResult struct {
+	XMLName   xml.Name       `xml:"ListJobsResult"`
+	Jobs      *BatchListJobs `xml:"Jobs,omitempty"`
+	NextToken string         `xml:"NextToken,omitempty"`
+}
+
+func (s *BatchService) ListJobs(ctx context.Context, opt *BatchListJobsOptions, headers *BatchRequestHeaders) (*BatchListJobsResult, *Response, error) {
+	var res BatchListJobsResult
+	sendOpt := sendOptions{
+		baseURL:   s.client.BaseURL.BatchURL,
+		uri:       "/jobs",
+		method:    http.MethodGet,
+		optQuery:  opt,
+		optHeader: headers,
+		result:    &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
+
+type BatchUpdatePriorityOptions struct {
+	JobId    string `url:"-" header:"-" xml:"-"`
+	Priority int    `url:"priority" header:"-" xml:"-"`
+}
+type BatchUpdatePriorityResult struct {
+	XMLName  xml.Name `xml:"UpdateJobPriorityResult"`
+	JobId    string   `xml:"JobId,omitempty"`
+	Priority int      `xml:"Priority,omitempty"`
+}
+
+func (s *BatchService) UpdateJobPriority(ctx context.Context, opt *BatchUpdatePriorityOptions, headers *BatchRequestHeaders) (*BatchUpdatePriorityResult, *Response, error) {
+	u := fmt.Sprintf("/jobs/%s/priority", opt.JobId)
+	var res BatchUpdatePriorityResult
+	sendOpt := sendOptions{
+		baseURL:   s.client.BaseURL.BatchURL,
+		uri:       u,
+		method:    http.MethodPost,
+		optQuery:  opt,
+		optHeader: headers,
+		result:    &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
+
+type BatchUpdateStatusOptions struct {
+	JobId              string `header:"-" url:"-" xml:"-"`
+	RequestedJobStatus string `url:"requestedJobStatus" header:"-" xml:"-"`
+	StatusUpdateReason string `url:"statusUpdateReason,omitempty" header:"-", xml:"-"`
+}
+type BatchUpdateStatusResult struct {
+	XMLName            xml.Name `xml:"UpdateJobStatusResult"`
+	JobId              string   `xml:"JobId,omitempty"`
+	Status             string   `xml:"Status,omitempty"`
+	StatusUpdateReason string   `xml:"StatusUpdateReason,omitempty"`
+}
+
+func (s *BatchService) UpdateJobStatus(ctx context.Context, opt *BatchUpdateStatusOptions, headers *BatchRequestHeaders) (*BatchUpdateStatusResult, *Response, error) {
+	u := fmt.Sprintf("/jobs/%s/status", opt.JobId)
+	var res BatchUpdateStatusResult
+	sendOpt := sendOptions{
+		baseURL:   s.client.BaseURL.BatchURL,
+		uri:       u,
+		method:    http.MethodPost,
+		optQuery:  opt,
+		optHeader: headers,
+		result:    &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
--- a/batch_test.go
+++ b/batch_test.go
@ -0,0 +1,389 @@
+package cos
+
+import (
+	"context"
+	"encoding/xml"
+	"fmt"
+	"net/http"
+	"reflect"
+	"testing"
+
+	"github.com/google/uuid"
+)
+
+func TestBatchService_CreateJob(t *testing.T) {
+	setup()
+	defer teardown()
+	uuid_str := uuid.New().String()
+	opt := &BatchCreateJobOptions{
+		ClientRequestToken: uuid_str,
+		Description:        "test batch",
+		Manifest: &BatchJobManifest{
+			Location: &BatchJobManifestLocation{
+				ETag:      "15150651828fa9cdcb8356b6d1c7638b",
+				ObjectArn: "qcs::cos:ap-chengdu:uid/1250000000:sourcebucket-1250000000/manifests/batch-copy-manifest.csv",
+			},
+			Spec: &BatchJobManifestSpec{
+				Fields: []string{"Bucket", "Key"},
+				Format: "COSBatchOperations_CSV_V1",
+			},
+		},
+		Operation: &BatchJobOperation{
+			PutObjectCopy: &BatchJobOperationCopy{
+				TargetResource: "qcs::cos:ap-chengdu:uid/1250000000:destinationbucket-1250000000",
+			},
+		},
+		Priority: 1,
+		Report: &BatchJobReport{
+			Bucket:      "qcs::cos:ap-chengdu:uid/1250000000:sourcebucket-1250000000",
+			Enabled:     "true",
+			Format:      "Report_CSV_V1",
+			Prefix:      "job-result",
+			ReportScope: "AllTasks",
+		},
+		RoleArn: "qcs::cam::uin/100000000001:roleName/COS_Batch_QcsRole",
+	}
+
+	mux.HandleFunc("/jobs", func(w http.ResponseWriter, r *http.Request) {
+		testHeader(t, r, "x-cos-appid", "1250000000")
+		testMethod(t, r, http.MethodPost)
+		v := new(BatchCreateJobOptions)
+		xml.NewDecoder(r.Body).Decode(v)
+
+		want := opt
+		want.XMLName = xml.Name{Local: "CreateJobRequest"}
+		if !reflect.DeepEqual(v, want) {
+			t.Errorf("Batch.CreateJob request body: %+v, want %+v", v, want)
+		}
+		fmt.Fprint(w, `<?xml version='1.0' encoding='utf-8' ?>
+<CreateJobResult>
+    <JobId>53dc6228-c50b-46f7-8ad7-65e7159f1aae</JobId>
+</CreateJobResult>`)
+	})
+
+	headers := &BatchRequestHeaders{
+		XCosAppid: 1250000000,
+	}
+	ref, _, err := client.Batch.CreateJob(context.Background(), opt, headers)
+	if err != nil {
+		t.Fatalf("Batch.CreateJob returned error: %v", err)
+	}
+
+	want := &BatchCreateJobResult{
+		XMLName: xml.Name{Local: "CreateJobResult"},
+		JobId:   "53dc6228-c50b-46f7-8ad7-65e7159f1aae",
+	}
+
+	if !reflect.DeepEqual(ref, want) {
+		t.Errorf("Batch.CreateJob returned %+v, want %+v", ref, want)
+	}
+
+}
+
+func TestBatchService_DescribeJob(t *testing.T) {
+	setup()
+	defer teardown()
+
+	mux.HandleFunc("/jobs/53dc6228-c50b-46f7-8ad7-65e7159f1aae", func(w http.ResponseWriter, r *http.Request) {
+		testHeader(t, r, "x-cos-appid", "1250000000")
+		testMethod(t, r, http.MethodGet)
+
+		fmt.Fprint(w, `<?xml version='1.0' encoding='utf-8' ?>
+<DescribeJobResult>
+    <Job>
+        <ConfirmationRequired>false</ConfirmationRequired>
+        <CreationTime>2019-12-19T18:00:30Z</CreationTime>
+        <Description>example-job</Description>
+        <FailureReasons>
+            <JobFailure>
+                <FailureCode/>
+                <FailureReason/>
+            </JobFailure>
+        </FailureReasons>
+        <JobId>53dc6228-c50b-46f7-8ad7-65e7159f1aae</JobId>
+        <Manifest>
+            <Location>
+                <ETag>&quot;15150651828fa9cdcb8356b6d1c7638b&quot;</ETag>
+                <ObjectArn>qcs::cos:ap-chengdu:uid/1250000000:sourcebucket-1250000000/manifests/batch-copy-manifest.csv</ObjectArn>
+            </Location>
+            <Spec>
+                <Fields>
+                    <member>Bucket</member>
+                    <member>Key</member>
+                </Fields>
+                <Format>COSBatchOperations_CSV_V1</Format>
+            </Spec>
+        </Manifest>
+        <Operation>
+            <COSPutObjectCopy>
+                <TargetResource>qcs::cos:ap-chengdu:uid/1250000000:destinationbucket-1250000000</TargetResource>
+            </COSPutObjectCopy>
+        </Operation>
+        <Priority>10</Priority>
+        <ProgressSummary>
+            <NumberOfTasksFailed>0</NumberOfTasksFailed>
+            <NumberOfTasksSucceeded>10</NumberOfTasksSucceeded>
+            <TotalNumberOfTasks>10</TotalNumberOfTasks>
+        </ProgressSummary>
+        <Report>
+            <Bucket>qcs::cos:ap-chengdu:uid/1250000000:sourcebucket-1250000000</Bucket>
+            <Enabled>true</Enabled>
+            <Format>Report_CSV_V1</Format>
+            <Prefix>job-result</Prefix>
+            <ReportScope>AllTasks</ReportScope>
+        </Report>
+        <RoleArn>qcs::cam::uin/100000000001:roleName/COS_Batch_QcsRole</RoleArn>
+        <Status>Complete</Status>
+        <StatusUpdateReason>Job complete</StatusUpdateReason>
+        <TerminationDate>2019-12-19T18:00:42Z</TerminationDate>
+    </Job>
+</DescribeJobResult>`)
+	})
+
+	headers := &BatchRequestHeaders{
+		XCosAppid: 1250000000,
+	}
+	ref, _, err := client.Batch.DescribeJob(context.Background(), "53dc6228-c50b-46f7-8ad7-65e7159f1aae", headers)
+	if err != nil {
+		t.Fatalf("Batch.DescribeJob returned error: %v", err)
+	}
+
+	want := &BatchDescribeJobResult{
+		XMLName: xml.Name{Local: "DescribeJobResult"},
+		Job: &BatchDescribeJob{
+			ConfirmationRequired: "false",
+			CreationTime:         "2019-12-19T18:00:30Z",
+			Description:          "example-job",
+			FailureReasons:       &BatchJobFailureReasons{},
+			JobId:                "53dc6228-c50b-46f7-8ad7-65e7159f1aae",
+			Manifest: &BatchJobManifest{
+				Location: &BatchJobManifestLocation{
+					ETag:      "\"15150651828fa9cdcb8356b6d1c7638b\"",
+					ObjectArn: "qcs::cos:ap-chengdu:uid/1250000000:sourcebucket-1250000000/manifests/batch-copy-manifest.csv",
+				},
+				Spec: &BatchJobManifestSpec{
+					Fields: []string{"Bucket", "Key"},
+					Format: "COSBatchOperations_CSV_V1",
+				},
+			},
+			Operation: &BatchJobOperation{
+				PutObjectCopy: &BatchJobOperationCopy{
+					TargetResource: "qcs::cos:ap-chengdu:uid/1250000000:destinationbucket-1250000000",
+				},
+			},
+			Priority: 10,
+			ProgressSummary: &BatchProgressSummary{
+				NumberOfTasksFailed:    0,
+				NumberOfTasksSucceeded: 10,
+				TotalNumberOfTasks:     10,
+			},
+			Report: &BatchJobReport{
+				Bucket:      "qcs::cos:ap-chengdu:uid/1250000000:sourcebucket-1250000000",
+				Enabled:     "true",
+				Format:      "Report_CSV_V1",
+				Prefix:      "job-result",
+				ReportScope: "AllTasks",
+			},
+			RoleArn:            "qcs::cam::uin/100000000001:roleName/COS_Batch_QcsRole",
+			Status:             "Complete",
+			StatusUpdateReason: "Job complete",
+			TerminationDate:    "2019-12-19T18:00:42Z",
+		},
+	}
+
+	if !reflect.DeepEqual(ref, want) {
+		t.Errorf("Batch.DescribeJob returned %+v, want %+v", ref, want)
+	}
+
+}
+
+func TestBatchService_ListJobs(t *testing.T) {
+	setup()
+	defer teardown()
+
+	mux.HandleFunc("/jobs", func(w http.ResponseWriter, r *http.Request) {
+		testHeader(t, r, "x-cos-appid", "1250000000")
+		testMethod(t, r, http.MethodGet)
+		vs := values{
+			"maxResults": "2",
+		}
+		testFormValues(t, r, vs)
+
+		fmt.Fprint(w, `<?xml version='1.0' encoding='utf-8' ?>
+<ListJobsResult>
+    <Jobs>
+        <member>
+            <CreationTime>2019-12-19T11:05:40Z</CreationTime>
+            <Description>example-job</Description>
+            <JobId>021140d8-67ca-4e89-8089-0de9a1e40943</JobId>
+            <Operation>COSPutObjectCopy</Operation>
+            <Priority>10</Priority>
+            <ProgressSummary>
+                <NumberOfTasksFailed>0</NumberOfTasksFailed>
+                <NumberOfTasksSucceeded>10</NumberOfTasksSucceeded>
+                <TotalNumberOfTasks>10</TotalNumberOfTasks>
+            </ProgressSummary>
+            <Status>Complete</Status>
+            <TerminationDate>2019-12-19T11:05:56Z</TerminationDate>
+        </member>
+        <member>
+            <CreationTime>2019-12-19T11:07:05Z</CreationTime>
+            <Description>example-job</Description>
+            <JobId>066d919e-49b9-429e-b844-e17ea7b16421</JobId>
+            <Operation>COSPutObjectCopy</Operation>
+            <Priority>10</Priority>
+            <ProgressSummary>
+                <NumberOfTasksFailed>0</NumberOfTasksFailed>
+                <NumberOfTasksSucceeded>10</NumberOfTasksSucceeded>
+                <TotalNumberOfTasks>10</TotalNumberOfTasks>
+            </ProgressSummary>
+            <Status>Complete</Status>
+            <TerminationDate>2019-12-19T11:07:21Z</TerminationDate>
+        </member>
+    </Jobs>
+    <NextToken>066d919e-49b9-429e-b844-e17ea7b16421</NextToken>
+</ListJobsResult>`)
+	})
+
+	opt := &BatchListJobsOptions{
+		MaxResults: 2,
+	}
+	headers := &BatchRequestHeaders{
+		XCosAppid: 1250000000,
+	}
+
+	ref, _, err := client.Batch.ListJobs(context.Background(), opt, headers)
+	if err != nil {
+		t.Fatalf("Batch.DescribeJob returned error: %v", err)
+	}
+
+	want := &BatchListJobsResult{
+		XMLName: xml.Name{Local: "ListJobsResult"},
+		Jobs: &BatchListJobs{
+			Members: []BatchListJobsMember{
+				{
+					CreationTime: "2019-12-19T11:05:40Z",
+					Description:  "example-job",
+					JobId:        "021140d8-67ca-4e89-8089-0de9a1e40943",
+					Operation:    "COSPutObjectCopy",
+					Priority:     10,
+					ProgressSummary: &BatchProgressSummary{
+						NumberOfTasksFailed:    0,
+						NumberOfTasksSucceeded: 10,
+						TotalNumberOfTasks:     10,
+					},
+					Status:          "Complete",
+					TerminationDate: "2019-12-19T11:05:56Z",
+				},
+				{
+					CreationTime: "2019-12-19T11:07:05Z",
+					Description:  "example-job",
+					JobId:        "066d919e-49b9-429e-b844-e17ea7b16421",
+					Operation:    "COSPutObjectCopy",
+					Priority:     10,
+					ProgressSummary: &BatchProgressSummary{
+						NumberOfTasksFailed:    0,
+						NumberOfTasksSucceeded: 10,
+						TotalNumberOfTasks:     10,
+					},
+					Status:          "Complete",
+					TerminationDate: "2019-12-19T11:07:21Z",
+				},
+			},
+		},
+		NextToken: "066d919e-49b9-429e-b844-e17ea7b16421",
+	}
+	if !reflect.DeepEqual(ref, want) {
+		t.Errorf("Batch.ListJobs returned %+v, want %+v", ref, want)
+	}
+}
+
+func TestBatchService_UpdateJobsPriority(t *testing.T) {
+	setup()
+	defer teardown()
+
+	mux.HandleFunc("/jobs/021140d8-67ca-4e89-8089-0de9a1e40943/priority", func(w http.ResponseWriter, r *http.Request) {
+		testHeader(t, r, "x-cos-appid", "1250000000")
+		testMethod(t, r, http.MethodPost)
+		vs := values{
+			"priority": "10",
+		}
+		testFormValues(t, r, vs)
+
+		fmt.Fprint(w, `<?xml version='1.0' encoding='utf-8' ?>
+<UpdateJobPriorityResult>
+    <JobId>021140d8-67ca-4e89-8089-0de9a1e40943</JobId>
+    <Priority>10</Priority>
+</UpdateJobPriorityResult>`)
+	})
+
+	opt := &BatchUpdatePriorityOptions{
+		JobId:    "021140d8-67ca-4e89-8089-0de9a1e40943",
+		Priority: 10,
+	}
+
+	headers := &BatchRequestHeaders{
+		XCosAppid: 1250000000,
+	}
+
+	ref, _, err := client.Batch.UpdateJobPriority(context.Background(), opt, headers)
+	if err != nil {
+		t.Fatalf("Batch.UpdateJobPriority returned error: %v", err)
+	}
+
+	want := &BatchUpdatePriorityResult{
+		XMLName:  xml.Name{Local: "UpdateJobPriorityResult"},
+		JobId:    "021140d8-67ca-4e89-8089-0de9a1e40943",
+		Priority: 10,
+	}
+	if !reflect.DeepEqual(ref, want) {
+		t.Errorf("Batch.UpdateJobsPriority returned %+v, want %+v", ref, want)
+	}
+}
+
+func TestBatchService_UpdateJobsStatus(t *testing.T) {
+	setup()
+	defer teardown()
+
+	mux.HandleFunc("/jobs/021140d8-67ca-4e89-8089-0de9a1e40943/status", func(w http.ResponseWriter, r *http.Request) {
+		testHeader(t, r, "x-cos-appid", "1250000000")
+		testMethod(t, r, http.MethodPost)
+		vs := values{
+			"requestedJobStatus": "Ready",
+			"statusUpdateReason": "to do",
+		}
+		testFormValues(t, r, vs)
+
+		fmt.Fprint(w, `<?xml version='1.0' encoding='utf-8' ?>
+<UpdateJobStatusResult>
+    <JobId>021140d8-67ca-4e89-8089-0de9a1e40943</JobId>
+    <Status>Ready</Status>
+    <StatusUpdateReason>to do</StatusUpdateReason>
+</UpdateJobStatusResult>`)
+	})
+
+	opt := &BatchUpdateStatusOptions{
+		JobId:              "021140d8-67ca-4e89-8089-0de9a1e40943",
+		RequestedJobStatus: "Ready",
+		StatusUpdateReason: "to do",
+	}
+
+	headers := &BatchRequestHeaders{
+		XCosAppid: 1250000000,
+	}
+
+	ref, _, err := client.Batch.UpdateJobStatus(context.Background(), opt, headers)
+	if err != nil {
+		t.Fatalf("Batch.UpdateJobStatus returned error: %v", err)
+	}
+
+	want := &BatchUpdateStatusResult{
+		XMLName:            xml.Name{Local: "UpdateJobStatusResult"},
+		JobId:              "021140d8-67ca-4e89-8089-0de9a1e40943",
+		Status:             "Ready",
+		StatusUpdateReason: "to do",
+	}
+	if !reflect.DeepEqual(ref, want) {
+		t.Errorf("Batch.UpdateJobsStatus returned %+v, want %+v", ref, want)
+	}
+}
--- a/cos.go
+++ b/cos.go
@ -39,6 +39,8 @@ type BaseURL struct {
 	BucketURL *url.URL
 	// 访问 service API 的基础 URL（不包含 path 部分）: http://example.com
 	ServiceURL *url.URL
+	// 访问 job API 的基础 URL （不包含 path 部分）: http://example.com
+	BatchURL *url.URL
 }

 // NewBucketURL 生成 BaseURL 所需的 BucketURL
@ -78,6 +80,7 @@ type Client struct {
 	Service *ServiceService
 	Bucket  *BucketService
 	Object  *ObjectService
+	Batch   *BatchService
 }

 type service struct {
@ -94,6 +97,7 @@ func NewClient(uri *BaseURL, httpClient *http.Client) *Client {
 	if uri != nil {
 		baseURL.BucketURL = uri.BucketURL
 		baseURL.ServiceURL = uri.ServiceURL
+		baseURL.BatchURL = uri.BatchURL
 	}
 	if baseURL.ServiceURL == nil {
 		baseURL.ServiceURL, _ = url.Parse(defaultServiceBaseURL)
@ -108,6 +112,7 @@ func NewClient(uri *BaseURL, httpClient *http.Client) *Client {
 	c.Service = (*ServiceService)(&c.common)
 	c.Bucket = (*BucketService)(&c.common)
 	c.Object = (*ObjectService)(&c.common)
+	c.Batch = (*BatchService)(&c.common)
 	return c
 }

--- a/cos_test.go
+++ b/cos_test.go
@ -32,7 +32,7 @@ func setup() {
 	server = httptest.NewServer(mux)

 	u, _ := url.Parse(server.URL)
-	client = NewClient(&BaseURL{u, u}, nil)
+	client = NewClient(&BaseURL{u, u, u}, nil)
 }

 // teardown closes the test HTTP server.
--- a/costesting/ci_test.go
+++ b/costesting/ci_test.go
@ -3,6 +3,7 @@ package cos
 // Basic imports
 import (
 	"context"
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"math/rand"
@ -13,6 +14,7 @@ import (
 	"testing"
 	"time"

+	"github.com/google/uuid"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/suite"
 	"github.com/tencentyun/cos-go-sdk-v5"
@ -44,14 +46,24 @@ type CosTestSuite struct {
 	SepFileName string
 }

-// replace
+// 请替换成您的账号及存储桶信息
 const (
 	//uin
-	kUin = "100010805041"
-	//Replication Target Region,
-	kRepRegion = "ap-chengdu"
-	//Replication Target Bucket, Version management needs to be turned on beforehand
+	kUin   = "100010805041"
+	kAppid = 1259654469
+
+	// 常规测试需要的存储桶
+	kBucket = "cosgosdktest-1259654469"
+	kRegion = "ap-guangzhou"
+
+	// 跨区域复制需要的目标存储桶，地域不能与kBucket存储桶相同。
 	kRepBucket = "cosgosdkreptest"
+	kRepRegion = "ap-chengdu"
+
+	// Batch测试需要的源存储桶和目标存储桶，目前只在成都、重庆地域公测
+	kBatchBucket       = "testcd-1259654469"
+	kTargetBatchBucket = "cosgosdkreptest-1259654469" //复用了存储桶
+	kBatchRegion       = "ap-chengdu"
 )

 func (s *CosTestSuite) SetupSuite() {
@ -62,11 +74,13 @@ func (s *CosTestSuite) SetupSuite() {

 	// CI client for test interface
 	// URL like this http://test-1253846586.cos.ap-guangzhou.myqcloud.com
-	u := "https://cosgosdktest-1259654469.cos.ap-guangzhou.myqcloud.com"
+	u := "https://" + kBucket + ".cos." + kRegion + ".myqcloud.com"
+	u2 := "https://" + kUin + ".cos-control." + kBatchRegion + ".myqcloud.com"

 	// Get the region
-	iu, _ := url.Parse(u)
-	p := strings.Split(iu.Host, ".")
+	bucketurl, _ := url.Parse(u)
+	batchurl, _ := url.Parse(u2)
+	p := strings.Split(bucketurl.Host, ".")
 	assert.Equal(s.T(), 5, len(p), "Bucket host is not right")
 	s.Region = p[2]

@ -75,7 +89,7 @@ func (s *CosTestSuite) SetupSuite() {
 	s.Bucket = pp[0]
 	s.Appid = pp[1]

-	ib := &cos.BaseURL{BucketURL: iu}
+	ib := &cos.BaseURL{BucketURL: bucketurl, BatchURL: batchurl}
 	s.Client = cos.NewClient(ib, &http.Client{
 		Transport: &cos.AuthorizationTransport{
 			SecretID:  os.Getenv("COS_SECRETID"),
@ -105,7 +119,7 @@ func (s *CosTestSuite) TestGetService() {
 // Bucket API
 func (s *CosTestSuite) TestPutHeadDeleteBucket() {
 	// Notic sometimes the bucket host can not analyis, may has i/o timeout problem
-	u := "http://gosdkbuckettest-" + s.Appid + ".cos.ap-beijing-1.myqcloud.com"
+	u := "http://" + "testgosdkbucket-create-head-del-" + s.Appid + ".cos." + kRegion + ".myqcloud.com"
 	iu, _ := url.Parse(u)
 	ib := &cos.BaseURL{BucketURL: iu}
 	client := cos.NewClient(ib, &http.Client{
@ -710,6 +724,112 @@ func (s *CosTestSuite) TestMultiUpload() {
 	assert.Nil(s.T(), err, "remove tmp file failed")
 }

+func (s *CosTestSuite) TestBatch() {
+	client := cos.NewClient(s.Client.BaseURL, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+		},
+	})
+
+	source_name := "test/1.txt"
+	sf := strings.NewReader("batch test content")
+	_, err := client.Object.Put(context.Background(), source_name, sf, nil)
+	assert.Nil(s.T(), err, "object put Failed")
+
+	manifest_name := "test/manifest.csv"
+	f := strings.NewReader(kBatchBucket + "," + source_name)
+	resp, err := client.Object.Put(context.Background(), manifest_name, f, nil)
+	assert.Nil(s.T(), err, "object put Failed")
+	etag := resp.Header.Get("ETag")
+
+	uuid_str := uuid.New().String()
+	opt := &cos.BatchCreateJobOptions{
+		ClientRequestToken:   uuid_str,
+		ConfirmationRequired: "true",
+		Description:          "test batch",
+		Manifest: &cos.BatchJobManifest{
+			Location: &cos.BatchJobManifestLocation{
+				ETag:      etag,
+				ObjectArn: "qcs::cos:" + kBatchRegion + ":uid/" + s.Appid + ":" + kBatchBucket + "/" + manifest_name,
+			},
+			Spec: &cos.BatchJobManifestSpec{
+				Fields: []string{"Bucket", "Key"},
+				Format: "COSBatchOperations_CSV_V1",
+			},
+		},
+		Operation: &cos.BatchJobOperation{
+			PutObjectCopy: &cos.BatchJobOperationCopy{
+				TargetResource: "qcs::cos:" + kBatchRegion + ":uid/" + s.Appid + ":" + kTargetBatchBucket,
+			},
+		},
+		Priority: 1,
+		Report: &cos.BatchJobReport{
+			Bucket:      "qcs::cos:" + kBatchRegion + ":uid/" + s.Appid + ":" + kBatchBucket,
+			Enabled:     "true",
+			Format:      "Report_CSV_V1",
+			Prefix:      "job-result",
+			ReportScope: "AllTasks",
+		},
+		RoleArn: "qcs::cam::uin/" + kUin + ":roleName/COSBatch_QcsRole",
+	}
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: kAppid,
+	}
+
+	res1, _, err := client.Batch.CreateJob(context.Background(), opt, headers)
+	assert.Nil(s.T(), err, "create job Failed")
+
+	jobid := res1.JobId
+
+	res2, _, err := client.Batch.DescribeJob(context.Background(), jobid, headers)
+	assert.Nil(s.T(), err, "describe job Failed")
+	assert.Equal(s.T(), res2.Job.ConfirmationRequired, "true", "ConfirmationRequired not right")
+	assert.Equal(s.T(), res2.Job.Description, "test batch", "Description not right")
+	assert.Equal(s.T(), res2.Job.JobId, jobid, "jobid not right")
+	assert.Equal(s.T(), res2.Job.Priority, 1, "priority not right")
+	assert.Equal(s.T(), res2.Job.RoleArn, "qcs::cam::uin/"+kUin+":roleName/COSBatch_QcsRole", "priority not right")
+
+	_, _, err = client.Batch.ListJobs(context.Background(), nil, headers)
+	assert.Nil(s.T(), err, "list jobs failed")
+
+	up_opt := &cos.BatchUpdatePriorityOptions{
+		JobId:    jobid,
+		Priority: 3,
+	}
+	res3, _, err := client.Batch.UpdateJobPriority(context.Background(), up_opt, headers)
+	assert.Nil(s.T(), err, "list jobs failed")
+	assert.Equal(s.T(), res3.JobId, jobid, "jobid failed")
+	assert.Equal(s.T(), res3.Priority, 3, "priority not right")
+
+	for i := 0; i < 10; i = i + 1 {
+		res, _, err := client.Batch.DescribeJob(context.Background(), jobid, headers)
+		assert.Nil(s.T(), err, "describe job Failed")
+		assert.Equal(s.T(), res2.Job.ConfirmationRequired, "true", "ConfirmationRequired not right")
+		assert.Equal(s.T(), res2.Job.Description, "test batch", "Description not right")
+		assert.Equal(s.T(), res2.Job.JobId, jobid, "jobid not right")
+		assert.Equal(s.T(), res2.Job.Priority, 1, "priority not right")
+		assert.Equal(s.T(), res2.Job.RoleArn, "qcs::cam::uin/"+kUin+":roleName/COSBatch_QcsRole", "priority not right")
+		if res.Job.Status == "Suspended" {
+			break
+		}
+		if i == 9 {
+			assert.Error(s.T(), errors.New("Job status is not Suspended or timeout"))
+		}
+		time.Sleep(time.Second * 2)
+	}
+	us_opt := &cos.BatchUpdateStatusOptions{
+		JobId:              jobid,
+		RequestedJobStatus: "Ready", // 允许状态转换见 https://cloud.tencent.com/document/product/436/38604
+		StatusUpdateReason: "to test",
+	}
+	res4, _, err := client.Batch.UpdateJobStatus(context.Background(), us_opt, headers)
+	assert.Nil(s.T(), err, "list jobs failed")
+	assert.Equal(s.T(), res4.JobId, jobid, "jobid failed")
+	assert.Equal(s.T(), res4.Status, "Ready", "status failed")
+	assert.Equal(s.T(), res4.StatusUpdateReason, "to test", "StatusUpdateReason failed")
+}
+
 // End of api test

 // All methods that begin with "Test" are run as tests within a
--- a/example/batch/create_job.go
+++ b/example/batch/create_job.go
@ -0,0 +1,100 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"net/url"
+	"os"
+	"strconv"
+	"strings"
+
+	"github.com/google/uuid"
+	"github.com/tencentyun/cos-go-sdk-v5"
+	"github.com/tencentyun/cos-go-sdk-v5/debug"
+)
+
+func main() {
+	test_batch_bucket := "testcd-1259654469"
+	target_batch_bucket := "cosgosdkreptest-1259654469"
+	appid := 1259654469
+	uin := "100010805041"
+	region := "ap-chengdu"
+
+	// bucket url：<Bucketname-Appid>.cos.<region>.mycloud.com
+	bucketurl, _ := url.Parse("https://" + test_batch_bucket + ".cos." + region + ".myqcloud.com")
+	// batch url：<uin>.cos-control.<region>.myqcloud.ccom
+	batchurl, _ := url.Parse("https://" + uin + ".cos-control." + region + ".myqcloud.com")
+
+	b := &cos.BaseURL{BucketURL: bucketurl, BatchURL: batchurl}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader:  true,
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+
+	// 创建需要复制的文件
+	source_name := "test/1.txt"
+	sf := strings.NewReader("batch test content")
+	_, err := c.Object.Put(context.Background(), source_name, sf, nil)
+	if err != nil {
+		panic(err)
+	}
+
+	// 创建清单文件
+	manifest_name := "test/manifest.csv"
+	f := strings.NewReader(test_batch_bucket + "," + source_name)
+	resp, err := c.Object.Put(context.Background(), manifest_name, f, nil)
+	if err != nil {
+		panic(err)
+	}
+	etag := resp.Header.Get("ETag")
+
+	uuid_str := uuid.New().String()
+	opt := &cos.BatchCreateJobOptions{
+		ClientRequestToken:   uuid_str,
+		ConfirmationRequired: "true",
+		Description:          "test batch",
+		Manifest: &cos.BatchJobManifest{
+			Location: &cos.BatchJobManifestLocation{
+				ETag:      etag,
+				ObjectArn: "qcs::cos:" + region + "::" + test_batch_bucket + "/" + manifest_name,
+			},
+			Spec: &cos.BatchJobManifestSpec{
+				Fields: []string{"Bucket", "Key"},
+				Format: "COSBatchOperations_CSV_V1",
+			},
+		},
+		Operation: &cos.BatchJobOperation{
+			PutObjectCopy: &cos.BatchJobOperationCopy{
+				TargetResource: "qcs::cos:" + region + ":uid/" + strconv.Itoa(appid) + ":" + target_batch_bucket,
+			},
+		},
+		Priority: 1,
+		Report: &cos.BatchJobReport{
+			Bucket:      "qcs::cos:" + region + "::" + test_batch_bucket,
+			Enabled:     "true",
+			Format:      "Report_CSV_V1",
+			Prefix:      "job-result",
+			ReportScope: "AllTasks",
+		},
+		RoleArn: "qcs::cam::uin/" + uin + ":roleName/COSBatch_QcsRole",
+	}
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: appid,
+	}
+
+	res, _, err := c.Batch.CreateJob(context.Background(), opt, headers)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Println(res)
+
+}
--- a/example/batch/describe_job.go
+++ b/example/batch/describe_job.go
@ -0,0 +1,44 @@
+package main
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"os"
+
+	"fmt"
+	"github.com/tencentyun/cos-go-sdk-v5"
+	"github.com/tencentyun/cos-go-sdk-v5/debug"
+)
+
+func main() {
+	uin := "100010805041"
+	appid := 1259654469
+	jobid := "795ad997-5557-4869-9a19-b66ec087d460"
+	u, _ := url.Parse("https://" + uin + ".cos-control.ap-chengdu.myqcloud.com")
+	b := &cos.BaseURL{BatchURL: u}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader:  true,
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: appid,
+	}
+
+	res, _, err := c.Batch.DescribeJob(context.Background(), jobid, headers)
+	if err != nil {
+		panic(err)
+	}
+	if res != nil && res.Job != nil {
+		fmt.Printf("%+v", res.Job)
+	}
+}
--- a/example/batch/list_jobs.go
+++ b/example/batch/list_jobs.go
@ -0,0 +1,43 @@
+package main
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"os"
+
+	"fmt"
+	"github.com/tencentyun/cos-go-sdk-v5"
+	"github.com/tencentyun/cos-go-sdk-v5/debug"
+)
+
+func main() {
+	uin := "100010805041"
+	appid := 1259654469
+	u, _ := url.Parse("https://" + uin + ".cos-control.ap-chengdu.myqcloud.com")
+	b := &cos.BaseURL{BatchURL: u}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader:  true,
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: appid,
+	}
+
+	res, _, err := c.Batch.ListJobs(context.Background(), nil, headers)
+	if err != nil {
+		panic(err)
+	}
+	if res != nil && res.Jobs != nil {
+		fmt.Printf("%+v", res.Jobs)
+	}
+}
--- a/example/batch/update_priority.go
+++ b/example/batch/update_priority.go
@ -0,0 +1,48 @@
+package main
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"os"
+
+	"fmt"
+	"github.com/tencentyun/cos-go-sdk-v5"
+	"github.com/tencentyun/cos-go-sdk-v5/debug"
+)
+
+func main() {
+	uin := "100010805041"
+	appid := 1259654469
+	jobid := "795ad997-5557-4869-9a19-b66ec087d460"
+	u, _ := url.Parse("https://" + uin + ".cos-control.ap-chengdu.myqcloud.com")
+	b := &cos.BaseURL{BatchURL: u}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader:  true,
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+
+	opt := &cos.BatchUpdatePriorityOptions{
+		JobId:    jobid,
+		Priority: 3,
+	}
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: appid,
+	}
+
+	res, _, err := c.Batch.UpdateJobPriority(context.Background(), opt, headers)
+	if err != nil {
+		panic(err)
+	}
+	if res != nil {
+		fmt.Printf("%+v", res)
+	}
+}
--- a/example/batch/update_status.go
+++ b/example/batch/update_status.go
@ -0,0 +1,49 @@
+package main
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"os"
+
+	"fmt"
+	"github.com/tencentyun/cos-go-sdk-v5"
+	"github.com/tencentyun/cos-go-sdk-v5/debug"
+)
+
+func main() {
+	uin := "100010805041"
+	appid := 1259654469
+	jobid := "289b0ea1-5ac5-453d-8a61-7f452dd4a209"
+	u, _ := url.Parse("https://" + uin + ".cos-control.ap-chengdu.myqcloud.com")
+	b := &cos.BaseURL{BatchURL: u}
+	c := cos.NewClient(b, &http.Client{
+		Transport: &cos.AuthorizationTransport{
+			SecretID:  os.Getenv("COS_SECRETID"),
+			SecretKey: os.Getenv("COS_SECRETKEY"),
+			Transport: &debug.DebugRequestTransport{
+				RequestHeader:  true,
+				RequestBody:    true,
+				ResponseHeader: true,
+				ResponseBody:   true,
+			},
+		},
+	})
+
+	opt := &cos.BatchUpdateStatusOptions{
+		JobId:              jobid,
+		RequestedJobStatus: "Ready", // 允许状态转换见 https://cloud.tencent.com/document/product/436/38604
+		StatusUpdateReason: "to test",
+	}
+	headers := &cos.BatchRequestHeaders{
+		XCosAppid: appid,
+	}
+
+	res, _, err := c.Batch.UpdateJobStatus(context.Background(), opt, headers)
+	if err != nil {
+		panic(err)
+	}
+	if res != nil {
+		fmt.Printf("%+v", res)
+	}
+}
--- a/go.mod
+++ b/go.mod
@ -5,6 +5,7 @@ go 1.12
 require (
 	github.com/QcloudApi/qcloud_sign_golang v0.0.0-20141224014652-e4130a326409
 	github.com/google/go-querystring v1.0.0
+	github.com/google/uuid v1.1.1
 	github.com/mozillazg/go-httpheader v0.2.1
 	github.com/stretchr/testify v1.3.0
 )
--- a/go.sum
+++ b/go.sum
@ -4,6 +4,8 @@ github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/google/go-querystring v1.0.0 h1:Xkwi/a1rcvNg1PPYe5vI8GbeBY/jrVuDX5ASuANWTrk=
 github.com/google/go-querystring v1.0.0/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck=
+github.com/google/uuid v1.1.1 h1:Gkbcsh/GbpXz7lPftLA3P6TYMwjCLYm83jiFQZF/3gY=
+github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/mozillazg/go-httpheader v0.2.1 h1:geV7TrjbL8KXSyvghnFm+NyTux/hxwueTSrwhe88TQQ=
 github.com/mozillazg/go-httpheader v0.2.1/go.mod h1:jJ8xECTlalr6ValeXYdOF8fFUISeBAdw6E61aqQma60=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=