From 54de4fd0b462620d0e3ceb6ffdb65e2db76806f3 Mon Sep 17 00:00:00 2001
From: wanjiewu <wanjiewu@tencent.com>
Date: Thu, 7 Mar 2024 12:12:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E5=BC=80=E9=80=9A=E5=AA=92?=
 =?UTF-8?q?=E4=BD=93=E6=A1=B6=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ci_media.go                               | 21 +++++++++++++++++++++
 example/CI/media_process/media_process.go |  8 ++++++++
 2 files changed, 29 insertions(+)

diff --git a/ci_media.go b/ci_media.go
index 1c33827..e980d81 100644
--- a/ci_media.go
+++ b/ci_media.go
@@ -1319,6 +1319,27 @@ type MediaProcessBucket struct {
 	CreateTime string `xml:"CreateTime,omitempty"`
 }
 
+type CreateMediaProcessBucketOptions struct {
+}
+
+type CreateMediaProcessBucketResult struct {
+	XMLName     xml.Name           `xml:"Response"`
+	RequestId   string             `xml:"RequestId,omitempty"`
+	MediaBucket MediaProcessBucket `xml:"MediaBucket,omitempty"`
+}
+
+func (s *CIService) CreateMediaProcessBucket(ctx context.Context, opt *CreateMediaProcessBucketOptions) (*CreateMediaProcessBucketResult, *Response, error) {
+	var res CreateMediaProcessBucketResult
+	sendOpt := sendOptions{
+		baseURL: s.client.BaseURL.CIURL,
+		uri:     "/mediabucket",
+		method:  http.MethodPost,
+		result:  &res,
+	}
+	resp, err := s.client.send(ctx, &sendOpt)
+	return &res, resp, err
+}
+
 // DescribeMediaProcessBuckets TODO
 // 媒体bucket接口 https://cloud.tencent.com/document/product/436/48988
 func (s *CIService) DescribeMediaProcessBuckets(ctx context.Context, opt *DescribeMediaProcessBucketsOptions) (*DescribeMediaProcessBucketsResult, *Response, error) {
diff --git a/example/CI/media_process/media_process.go b/example/CI/media_process/media_process.go
index cb167a0..a3768b5 100644
--- a/example/CI/media_process/media_process.go
+++ b/example/CI/media_process/media_process.go
@@ -145,5 +145,13 @@ func ModifyM3U8Token() {
 	fmt.Printf("%s\n", rspBody)
 }
 
+func CreateMediaProcessBucket() {
+	c := getClient()
+	opt := &cos.CreateMediaProcessBucketOptions{}
+	res, _, err := c.CI.CreateMediaProcessBucket(context.Background(), opt)
+	log_status(err)
+	fmt.Printf("%+v\n", res)
+}
+
 func main() {
 }