全部文档
当前文档
最近更新时间：2026-11-11 10:30:12
以下代码用于对视频进行实时截帧，处理结果（图片）直接作为响应体返回：
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
"io"
)
func main() {
// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换为实际值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建KS3客户端，更多配置项请查看初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 访问地域
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 访问域名
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 源视频对象的Key
objectKey := "video/source.mp4"
// 视频截帧
resp, err := client.GetObject(&s3.GetObjectInput{
Bucket: aws.String(bucket), // 存储空间名称，必填
Key: aws.String(objectKey), // 对象Key，必填
Process: aws.String("video/snapshot,t_7000,w_800"), // 视频处理参数，必填
})
if err != nil {
panic(err)
}
defer resp.Body.Close()
// 处理结果为图片二进制，读取响应体
body, err := io.ReadAll(resp.Body)
if err != nil {
panic(err)
}
fmt.Printf("截帧成功，图片大小：%d 字节\n", len(body))
}以下代码用于获取视频元信息，处理结果为 JSON 直接作为响应体返回：
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
"io"
)
func main() {
// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换为实际值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建KS3客户端，更多配置项请查看初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 访问地域
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 访问域名
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 源视频对象的Key
objectKey := "video/source.mp4"
// 获取视频元信息
resp, err := client.GetObject(&s3.GetObjectInput{
Bucket: aws.String(bucket), // 存储空间名称，必填
Key: aws.String(objectKey), // 对象Key，必填
Process: aws.String("video/info"), // 视频处理参数，必填
})
if err != nil {
panic(err)
}
defer resp.Body.Close()
// 处理结果为JSON文本，读取并打印
body, err := io.ReadAll(resp.Body)
if err != nil {
panic(err)
}
fmt.Println("视频元信息：")
fmt.Println(string(body))
}以下代码用于对视频截帧并通过 sys/saveas 将结果另存到指定桶：
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换为实际值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建KS3客户端，更多配置项请查看初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 访问地域
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 访问域名
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 源视频对象的Key
objectKey := "video/source.mp4"
// 处理产物存放的目标桶
saveAsBucket := "<saveas_bucket>"
// 处理产物存放的对象Key
saveAsKey := "output/snapshot.png"
// 处理参数：截取第10秒画面，输出800x600的PNG，并另存到指定桶
process := "video/snapshot,t_10000,f_png,w_800,h_600|sys/saveas,b_" + s3.GetURLSafeBase64Str(saveAsBucket) + ",o_" + s3.GetURLSafeBase64Str(saveAsKey)
// 视频截帧并另存
resp, err := client.ProcessObject(&s3.ProcessObjectInput{
Bucket: aws.String(bucket), // 源对象所在存储空间名称，必填
Key: aws.String(objectKey), // 源对象Key，必填
Process: aws.String(process), // 处理参数，必填
})
if err != nil {
panic(err)
}
fmt.Println("结果：\n", awsutil.StringValue(resp))
}以下代码用于提交视频转码的异步处理任务，返回任务ID用于后续查询：
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换为实际值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建KS3客户端，更多配置项请查看初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 访问地域
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 访问域名
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 源视频对象的Key
objectKey := "video/source.mp4"
// 处理产物存放的目标桶
saveAsBucket := "<saveas_bucket>"
// 转码产物存放的对象Key
saveAsKey := "output/sample.mp4"
// 处理参数：转码为 H.265/MP4，分辨率1920x1080，码率2Mbps，帧率30fps，音频AAC
process := "video/convert,f_mp4,vcodec_h265,s_1920x1080,vb_2000000,fps_30,acodec_aac,ab_100000,sn_1|sys/saveas,b_" + s3.GetURLSafeBase64Str(saveAsBucket) + ",o_" + s3.GetURLSafeBase64Str(saveAsKey)
// 视频转码
resp, err := client.AsyncProcessObject(&s3.AsyncProcessObjectInput{
Bucket: aws.String(bucket), // 源对象所在存储空间名称，必填
Key: aws.String(objectKey), // 源对象Key，必填
Process: aws.String(process), // 处理参数，必填
})
if err != nil {
panic(err)
}
fmt.Println("结果：\n", awsutil.StringValue(resp))
}以下代码用于查看指定异步任务的详情：
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换为实际值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建KS3客户端，更多配置项请查看初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 访问地域
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 访问域名
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 异步任务ID，由 AsyncProcessObject 返回
processId := "<process_id>"
// 查看异步任务详情
resp, err := client.GetAsyncProcess(&s3.GetAsyncProcessInput{
Bucket: aws.String(bucket), // 存储空间名称，必填
ProcessId: aws.String(processId), // 异步任务ID，必填
})
if err != nil {
panic(err)
}
fmt.Println("结果：\n", awsutil.StringValue(resp))
}以下代码用于列举异步任务：
package main
import (
"fmt"
"github.com/ks3sdklib/aws-sdk-go/aws"
"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
"github.com/ks3sdklib/aws-sdk-go/service/s3"
)
func main() {
// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换为实际值
cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
// 创建KS3客户端，更多配置项请查看初始化文档
client := s3.New(&aws.Config{
Credentials: cre, // 访问凭证
Region: "BEIJING", // 访问地域
Endpoint: "ks3-cn-beijing.ksyuncs.com", // 访问域名
})
// 填写存储空间名称
bucket := "<bucket_name>"
// 列举异步任务
resp, err := client.ListAsyncProcess(&s3.ListAsyncProcessInput{
Bucket: aws.String(bucket), // 存储空间名称，必填
ProcessType: aws.String("mediaConvert"), // 任务类型，如 mediaConvert，非必填
MaxResults: aws.String("10"), // 每页最大返回数，取值范围(0,1000]，非必填
})
if err != nil {
panic(err)
}
fmt.Println("结果：\n", awsutil.StringValue(resp))
}纯净模式