阅读本文，您可以获取 Go SDK 回调管理的接口调用示例，实现快速开发。
说明
本文的调用示例包含接口的部分参数。由于参数间可能存在互斥关系，在调用时，请您参考注释，进行调整。
调用接口前，请先完成 Go SDK 的安装及初始化操作。
本节为您介绍回调管理相关接口的功能和调用示例。
您可以调用 UpdateCallback 接口添加或更新回调配置。详细的参数说明可参见 UpdateCallback 接口文档。
接口调用示例如下所示。
package main import ( "context" "fmt" "os" "github.com/volcengine/volc-sdk-golang/base" live "github.com/volcengine/volc-sdk-golang/service/live/v20230101" ) func StringPtr(v string) *string { return &v } func BoolPtr(v bool) *bool { return &v } func Int32Ptr(v int32) *int32 { return &v } func main() { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里，否则可能导致 AccessKey 泄露，威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY，来实现 API 访问的身份验证。运行代码示例前，请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY service := live.NewInstance() service.SetCredential(base.Credentials{ AccessKeyID: os.Getenv("VOLC_ACCESSKEY"), SecretAccessKey: os.Getenv("VOLC_SECRETKEY"), }) body := &live.UpdateCallbackBody{ // 应用名称，取值与直播流地址中 AppName 字段取值相同，默认为空，表示查询所有应用名称。支持由大小写字母（A - Z、a - z）、数字（0 - 9）、下划线（_）、短横线（-）和句点（.）组成，长度为 1 到 30 个字符。 // note： // 如果入参选择 Domain，则不可同时传 App。 App: StringPtr(`example_app`), // 回调消息发送是否开启鉴权，默认为 false，取值及含义如下所示。 // <li> false：不开启； </li> // <li> true：开启。 </li> AuthEnable: BoolPtr(false), // 回调消息发送鉴权密钥。 // note： // 如果 AuthEnable 为 true，则密钥必填。 AuthKeyPrimary: StringPtr(`1622194197-0-0-5552*****e4e20387c6dc18afce****`), // 直播流使用的推流域名。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，查看直播流使用的域名。 // note： // Vhost 和 Domain 传且仅传一个。 Domain: StringPtr(`push.example.com`), // 回调的消息类型，取值及含义如下所示。 // <li> push：推流开始回调； </li> // <li> push_end：推流结束回调； </li> // <li> snapshot：截图回调； </li> // <li> record：录制任务状态回调； </li> // <li> audit_snapshot：截图审核结果回调。 </li> MessageType: `push`, // 是否开启转码流回调，默认为 0。取值及含义如下所示。 // <li> 0：false，不开启； </li> // <li> 1：true，开启。 </li> // note： // 回调类型为推流开始或推流结束时生效。 TranscodeCallback: Int32Ptr(0), // 域名空间，即直播流地址的域名所属的域名空间。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，查看需要查询的直播流使用的域名所属的域名空间。 // note： // Vhost 和 Domain 传且仅传一个。 Vhost: StringPtr(`push.example.com`), } // 回调信息列表。 CallbackDetailList1 := live.UpdateCallbackBodyCallbackDetailListItem{ // 回调类型，返回 HTTP，表示可以使用 HTTP 和 HTTPS 地址接收回调消息。 CallbackType: `http`, // 回调消息接收地址。 URL: `http://example.com/callback`, } body.CallbackDetailList = append(body.CallbackDetailList, CallbackDetailList1) resp, err := service.UpdateCallback(context.Background(), body) if err != nil { fmt.Printf("error %v", err) } else { fmt.Printf("success %+v", resp) } }
您可以调用 DeleteCallback 接口删除回调配置。详细的参数说明可参见 DeleteCallback 接口文档。
接口调用示例如下所示。
package main import ( "context" "fmt" "os" "github.com/volcengine/volc-sdk-golang/base" live "github.com/volcengine/volc-sdk-golang/service/live/v20230101" ) func StringPtr(v string) *string { return &v } func main() { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里，否则可能导致 AccessKey 泄露，威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY，来实现 API 访问的身份验证。运行代码示例前，请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY service := live.NewInstance() service.SetCredential(base.Credentials{ AccessKeyID: os.Getenv("VOLC_ACCESSKEY"), SecretAccessKey: os.Getenv("VOLC_SECRETKEY"), }) body := &live.DeleteCallbackBody{ // 域名空间，与创建回调时传的值一致。您可以调用 [DescribeCallback](https://www.volcengine.com/docs/6469/1126931) 接口查看待删除回调配置的 Vhost 取值。 Vhost: StringPtr(`push.live.example.com`), // 推流域名，与创建回调时传的值一致。您可以调用 [DescribeCallback](https://www.volcengine.com/docs/6469/1126931) 接口查看待删除回调配置的 Domain 取值。 Domain: StringPtr(`push.live.example.com`), // 消息类型，与创建回调时传的值一致。您可以调用 [DescribeCallback](https://www.volcengine.com/docs/6469/1126931) 接口查看待删除回调配置的 MessageType 取值。 // <li> push：推流开始回调； </li> // <li> push_end：推流结束回调； </li> // <li> snapshot：截图回调； </li> // <li> record：录制任务状态回调； </li> // <li> audit_snapshot：截图审核结果回调。 </li> MessageType: StringPtr(`push`), // 应用名称，与创建回调时传的值一致。您可以调用 [DescribeCallback](https://www.volcengine.com/docs/6469/1126931) 接口查看待删除回调配置的 App 取值。 App: StringPtr(`live`), } resp, err := service.DeleteCallback(context.Background(), body) if err != nil { fmt.Printf("error %v", err) } else { fmt.Printf("success %+v", resp) } }
您可以调用 DescribeCallback 接口查询回调配置。详细的参数说明可参见 DescribeCallback 接口文档。
接口调用示例如下所示。
package main import ( "context" "fmt" "os" "github.com/volcengine/volc-sdk-golang/base" live "github.com/volcengine/volc-sdk-golang/service/live/v20230101" ) func StringPtr(v string) *string { return &v } func main() { // 强烈建议不要把 VOLC_ACCESSKEY 和 VOLC_SECRETKEY 保存到工程代码里，否则可能导致 AccessKey 泄露，威胁您账号下所有资源的安全。 // 本示例通过从环境变量中读取 VOLC_ACCESSKEY 和 VOLC_SECRETKEY，来实现 API 访问的身份验证。运行代码示例前，请配置环境变量 VOLC_ACCESSKEY 和 VOLC_SECRETKEY service := live.NewInstance() service.SetCredential(base.Credentials{ AccessKeyID: os.Getenv("VOLC_ACCESSKEY"), SecretAccessKey: os.Getenv("VOLC_SECRETKEY"), }) body := &live.DescribeCallbackBody{ // 应用名称，取值与直播流地址中 AppName 字段取值相同，默认为空，表示查询所有应用名称。支持由大小写字母（A - Z、a - z）、数字（0 - 9）、下划线（_）、短横线（-）和句点（.）组成，长度为 1 到 30 个字符。 App: StringPtr(`Live`), // 直播流使用的推流域名，默认为空，表示查询所有当前域名空间（Vhost）下的在线流。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，查看直播流使用的域名。 // note： // Vhost 和 Domain 传且仅传一个。 Domain: StringPtr(`push.example.com`), // 回调类型。默认为空，表示查询全部回调类型，取值及含义如下所示。 // <li> push：推流开始回调； </li> // <li> push_end：推流结束回调； </li> // <li> snapshot：截图回调； </li> // <li> record：录制回调； </li> // <li> audit_snapshot：截图审核回调。 </li> MessageType: StringPtr(`push`), // 域名空间，即直播流地址的域名所属的域名空间。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，查看需要查询的直播流使用的域名所属的域名空间。 // note： // Vhost 和 Domain 传且仅传一个。 Vhost: StringPtr(`push.example.com`), } resp, err := service.DescribeCallback(context.Background(), body) if err != nil { fmt.Printf("error %v", err) } else { fmt.Printf("success %+v", resp) } }