腾讯云对象存储任务接口

简介

本文档提供关于任务接口的 API 概览以及 SDK 示例代码。说明：阅读本文档前请先打开 示例代码。

提交任务

接口文档及示例函数名

示例代码

以提交转码任务为例

func InvokeTranscodeJob() {    c := getClient()    createJobOpt := &cos.CreateJobsOptions{        Tag: "Transcode",        Input: &cos.JobInput{            Object: "input/test.mp4",        },        Operation: &cos.MediaProcessJobOperation{            Output: &cos.JobOutput{                Region: "ap-chongqing",                Object: "output/test.mp4",                Bucket: "test-1234567890",            },            Transcode: &cos.Transcode{                Container: &cos.Container{                    Format: "mp4",                },                Video: &cos.Video{                    Codec: "H.264",                },                Audio: &cos.Audio{                    Codec: "AAC",                },                TimeInterval: &cos.TimeInterval{                    Start:    "10",                    Duration: "",                },            },            UserData: "hello world",        },    }    createJobRes, _, err := c.CI.CreateJob(context.Background(), createJobOpt)    log_status(err)    fmt.Printf("%+v\n", createJobRes.JobsDetail)}

查询任务

接口文档及示例函数名

示例代码

func DescribeJobs() {    c := getClient()    opt := &cos.DescribeJobsOptions{        Tag:     "Transcode",    }    DescribeJobRes, _, err := c.CI.DescribeJobs(context.Background(), opt)    log_status(err)    fmt.Printf("%+v\n", DescribeJobRes.JobsDetail)}
func DescribeJob() {    c := getClient()    DescribeJobRes, _, err := c.CI.DescribeJob(context.Background(), "j8ddec28406a111eea5fe55494cf3fdf1")    log_status(err)    fmt.Printf("%+v\n", DescribeJobRes.JobsDetail)}

取消任务

接口文档及示例函数名

示例代码

func CancelJob() {    c := getClient()    _, err := c.CI.CancelJob(context.Background(), "j9334ff26044611eebf2565013e042dc9")    log_status(err)}

提交多任务处理

接口文档及示例函数名

示例代码

func InvokeMultiJobs() {    c := getClient()    createJobOpt := &cos.CreateMultiMediaJobsOptions{        Input: &cos.JobInput{            Object: "input/test.mp4",        },        Operation: []cos.MediaProcessJobOperation{            cos.MediaProcessJobOperation{                Tag: "Snapshot",                Output: &cos.JobOutput{                    Region: "ap-chongqing",                    Object: "output/go_${Number}.mp4",                    Bucket: "test-1234567890",                },                Snapshot: &cos.Snapshot{                    Mode:  "Interval",                    Start: "0",                    Count: "1",                },            },            cos.MediaProcessJobOperation{                Tag: "Transcode",                Output: &cos.JobOutput{                    Region: "ap-chongqing",                    Object: "output/go_test.mp4",                    Bucket: "test-1234567890",                },                Transcode: &cos.Transcode{                    Container: &cos.Container{                        Format: "mp4",                    },                    Video: &cos.Video{                        Codec: "H.264",                    },                    Audio: &cos.Audio{                        Codec: "AAC",                    },                    TimeInterval: &cos.TimeInterval{                        Start:    "10",                        Duration: "",                    },                },            },            cos.MediaProcessJobOperation{                Tag: "Animation",                Output: &cos.JobOutput{                    Region: "ap-chongqing",                    Object: "output/go_117374C.gif",                    Bucket: "test-1234567890",                },                Animation: &cos.Animation{                    Container: &cos.Container{                        Format: "gif",                    },                    Video: &cos.AnimationVideo{                        Codec:                   "gif",                        AnimateOnlyKeepKeyFrame: "true",                    },                    TimeInterval: &cos.TimeInterval{                        Start:    "0",                        Duration: "",                    },                },            },        },    }    createJobRes, _, err := c.CI.CreateMultiMediaJobs(context.Background(), createJobOpt)    log_status(err)    for k, job := range createJobRes.JobsDetail {        fmt.Printf("job:%d, %+v\n", k, job)    }}

解析任务回调

接口文档

示例代码

func JobNotifyCallback() {    taskBody := "TaskFinishSuccess2022-06-30T19:30:20+08002022-06-30T19:31:56+0800test-123456789ap-chongqingContent-Typevideo/mp4x-cos-request-idNjJiZDYwYTFfNjUzYTYyNjRfZjEwZl8xMmZhYzY5EventNamecos:ObjectCreated:PutSize1424687j06668dc0f86811ecb90d0b03267ce0e5false123456789abFailedTextV18867.17200013.654000QuickTime / MOVmov,mp4,m4a,3gp,3g2,mj202151340460.000000128.7260002stereoAAC (Advanced Audio Coding)aac0x6134706dmp4a1/4410013.6529931undfltp441000.0000001/44100test-123456789852883012a6ba726e6ed8d9b984edfdfoutput/super_resolution.mp4output/super_resolution.mp4ap-chongqingtest-123456789ap-chongqingt1f1ae1dfsdc9ds41dsb31632d45710642atemplate_superresolutiont156c107210e7243c5817354565d81b578This is my SuperResolution job.0t143ae6e040af6431aa772c9ec3f0a3f36t12a74d11687d444deba8a6cc52051ac27p2242ab62c7c94486915508540933a2c62022-06-30T19:30:21+0800Success100DigitalWatermarkSuperResolutionSuperResolution_1581665960537ic90edd59f84f11ec9d4f525400a3c59fweb6ac56c1ef54dbfa44d7f4103203be9workflow-test"    var body cos.JobsNotifyBody    err := xml.Unmarshal([]byte(taskBody), &body)    if err != nil {        fmt.Println(fmt.Sprintf("err:%v", err))    } else {        fmt.Println(fmt.Sprintf("body:%+v", body))        fmt.Println(fmt.Sprintf("mediaInfo:%+v", body.JobsDetail[0].Operation.MediaInfo))        fmt.Println(fmt.Sprintf("mediaResult:%+v", body.JobsDetail[0].Operation.MediaResult))    }}



对象存储官网1折活动，限时活动，即将结束，速速收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折，更有现金返利。同意关联立享优惠