文档中心

视频直播

Golang SDK

拉流回源

阅读本文，您可以获取 Go SDK 拉流回源的接口调用示例，实现快速开发。

说明

本文的调用示例包含接口的部分参数。由于参数间可能存在互斥关系，在调用时，请您参考注释，进行调整。

调用说明

本文提供的接口调用示例均通过 AK 和 SK 初始化实例。
接口的参数说明和错误码等信息可通过接口文档或打开 API Explorer 的文档说明页签查看。

前提条件

调用接口前，请先完成 Go SDK 的安装及初始化操作。

调用示例

本节为您介绍拉流回源相关接口的功能和调用示例。

添加或更新播放触发回源配置

您可以调用 UpdateRelaySourceV3 接口添加或更新播放触发回源配置。详细的参数说明可参见 UpdateRelaySourceV3 接口文档。

接口调用示例如下所示。

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.UpdateRelaySourceV3Body{
		// 域名空间，即直播流地址的域名所属的域名空间。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，查看直播流使用的域名所属的域名空间。
		Vhost: "push.example.com",
		// 应用名称，即直播流地址的 AppName 字段取值，默认为空，表示为当前域名空间的全局播放触发回源配置。支持由大小写字母（A - Z、a - z）、数字（0 - 9）、下划线（_）、短横线（-）和句点（.）组成，长度为 1 到 30 个字符。
		App: StringPtr("live"),
	}

	// 回源组配置详情。
	GroupDetails1 := live.UpdateRelaySourceV3BodyGroupDetailsItem{
		// 回源组名称。
		Group: "relay1",
	}

	// 回源服务器配置列表。
	Servers1 := live.UpdateRelaySourceV3BodyGroupDetailsPropertiesItemsItem{
		// 回源协议，支持两种回源协议。
		// <li> rtmp：RTMP 回源协议； </li>
		// <li> flv：FLV 回源协议。 </li>
		RelaySourceProtocol: "rtmp",
		// 直播源服务器的地址，支持填写回源服务的域名或 IP 地址。
		// note：
		// <li> 当源站使用了非默认端口时，支持在回源地址中以域名:端口或 IP:端口的形式配置端口。 </li>
		// <li> 最多支持添加 10 个回源地址，回源失败时，将按照您添加的地址顺序轮循尝试。 </li>
		RelaySourceDomain: "example.org",
	}

	// 自定义回源参数，缺省情况下为空。格式为 "Key":"Value"，例如，"domain":"live.push.net"。
	RelaySourceParams := map[string]*string{
		"key1": StringPtr("value1"),
		"key2": StringPtr("value2"),
	}

	Servers1.RelaySourceParams = RelaySourceParams
	GroupDetails1.Servers = append(GroupDetails1.Servers, Servers1)
	body.GroupDetails = append(body.GroupDetails, GroupDetails1)

	resp, err := service.UpdateRelaySourceV3(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

删除播放触发回源配置

您可以调用 DeleteRelaySourceV3 接口删除播放触发回源配置。详细的参数说明可参见 DeleteRelaySourceV3 接口文档。

接口调用示例如下所示。

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.DeleteRelaySourceV3Body{
		// 直播流使用的域名所属的域名空间，您可以调用 [DescribeRelaySourceV3](https://www.volcengine.com/docs/6469/1126874) 接口获取待删除配置的 Vhost 取值。
		Vhost: "push.example.com",
		// 应用名称，您可以调用 [DescribeRelaySourceV3](https://www.volcengine.com/docs/6469/1126874) 接口获取待删除配置的 App 取值。
		App: StringPtr("live"),
		// 回源组名称。
		Group: StringPtr("relay1"),
	}

	resp, err := service.DeleteRelaySourceV3(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

查询播放触发回源配置

您可以调用 DescribeRelaySourceV3 接口查询播放触发回源配置。详细的参数说明可参见 DescribeRelaySourceV3 接口文档。

接口调用示例如下所示。

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.DescribeRelaySourceV3Body{
		// 直播流使用的域名所属的域名空间。您可以调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口或在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，查看直播流使用的域名。所属的域名空间。
		Vhost: "push.example.com",
		// 应用名称，即直播流地址的 AppName 字段取值，默认为空，表示查询当前域名空间下所有播放触发回源配置。支持由大小写字母（A - Z、a - z）、数字（0 - 9）、下划线（_）、短横线（-）和句点（.）组成，长度为 1 到 30 个字符。
		App: StringPtr("live"),
		// 回源组名称。
		Group: StringPtr("relay1"),
	}

	resp, err := service.DescribeRelaySourceV3(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

添加固定触发回源配置

您可以调用 CreateRelaySourceV4 接口添加固定触发回源配置。详细的参数说明可参见 CreateRelaySourceV4 接口文档。

接口调用示例如下所示。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/volcengine/volc-sdk-golang/base"
	live "github.com/volcengine/volc-sdk-golang/service/live/v20230101"
)

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.CreateRelaySourceV4Body{
		// 域名空间。
		// 通过以下任一方式，获取域名空间：
		// <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口，通过返回参数 Vhost 获取。 </li>
		// <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，通过**域名空间**字段获取。 </li>
		Vhost: "pull.example.com",
		// 视频直播播放地址中的 AppName。例如播放地址为 rtmp://pull.example.com/live/test?authinfo，则 AppName 为 live。
		// 支持由大小写字母（A - Z、a - z）、数字（0 - 9）、下划线（_）、短横线（-）和句点（.）组成，长度为 1 到 30 个字符。
		// note：
		// 同一 App 不能同时配置播放触发和固定触发的回源配置。您可调用 [DescribeRelaySourceV3](https://docs.volcengine.com/docs/6469/1126874?lang=zh) 查询已有播放触发回源配置的 App 取值。
		App: "live",
		// 视频直播播放地址中的 StreamName。例如播放地址为 rtmp://pull.example.com/live/test?authinfo，则 StreamName 为 test。
		// 支持由大小写字母（A - Z、a - z）、数字（0 - 9）、下划线（_）和短横线（-）组成，长度为 1 到 100 个字符。
		// note：
		// App 和 Stream 的组合不能与已有固定触发回源配置重复。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 查询已有固定触发回源配置的 App 和 Stream 取值。
		Stream: "example_stream",
		// 回源开始时间。Unix 时间戳，单位为秒。
		// note：
		// <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li>
		// <li> StartTime 和 EndTime 需同时传入或同时不传。传入时，表示添加固定回源类型的回源配置。不传时，表示添加永久回源类型的回源配置。 </li>
		StartTime: Int32Ptr(1785923506),
		// 回源结束时间。Unix 时间戳，单位为秒。
		// note：
		// <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li>
		// <li> StartTime 和 EndTime 需同时传入或同时不传。传入时，表示添加固定回源类型的回源配置。不传时，表示添加永久回源类型的回源配置。 </li>
		EndTime: Int32Ptr(1785953506),
	}

	// 回源地址列表，即视频直播从源站拉取直播流时访问的地址列表。支持 RTMP、RTMPS、FLV 或 HLS 协议。
	// 通常包含协议、源站的域名或 IP 地址，以及源站直播流的 AppName 和 StreamName。如果源站要求回源请求携带额外参数，还需包含查询参数。例如 rtmp://192.*.*.10/live01/test01?token=abc。
	// note：
	// <li> 支持配置自有源站或第三方源站的回源地址。触发回源后，视频直播会访问您配置的回源地址，从源站拉取直播流。 </li>
	// <li> 如果源站使用非默认端口，需在源站的域名或 IP 地址后填写端口，例如 rtmp://192.*.*.10:1936/live01/test01?token=abc，否则系统可能按默认端口访问源站，导致回源失败。 </li>
	// <li> 最多支持传入 10 个回源地址。系统会按照回源地址在数组中的排列顺序依次尝试回源，数组中越靠前的地址优先级越高。如果当前回源地址回源失败，系统会再尝试下一个回源地址。 </li>
	SrcAddrS := []string{"rtmp://live.example.com/live01/test01"}

	body.SrcAddrS = SrcAddrS

	resp, err := service.CreateRelaySourceV4(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

删除固定触发回源配置

您可以调用 DeleteRelaySourceV4 接口删除固定触发回源配置。详细的参数说明可参见 DeleteRelaySourceV4 接口文档。

接口调用示例如下所示。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/volcengine/volc-sdk-golang/base"
	live "github.com/volcengine/volc-sdk-golang/service/live/v20230101"
)

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.DeleteRelaySourceV4Body{
		// 域名空间。
		// 通过以下任一方式，获取域名空间：
		// <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口，通过返回参数 Vhost 获取。 </li>
		// <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，通过**域名空间**字段获取。 </li>
		Vhost: "pull.example.com",
		// 视频直播播放地址中的 AppName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 App 获取固定触发回源配置的 AppName。
		App: "live",
		// 视频直播播放地址中的 StreamName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 Stream 获取固定触发回源配置的 StreamName。
		Stream: "example_stream",
	}

	resp, err := service.DeleteRelaySourceV4(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

更新固定触发回源配置

您可以调用 UpdateRelaySourceV4 接口更新固定触发回源配置。详细的参数说明可参见 UpdateRelaySourceV4 接口文档。

接口调用示例如下所示。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/volcengine/volc-sdk-golang/base"
	live "github.com/volcengine/volc-sdk-golang/service/live/v20230101"
)

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.UpdateRelaySourceV4Body{
		// 域名空间。
		// 通过以下任一方式，获取域名空间：
		// <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口，通过返回参数 Vhost 获取。 </li>
		// <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，通过**域名空间**字段获取。 </li>
		Vhost: "pull.example.com",
		// 视频直播播放地址中的 AppName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 App 获取固定触发回源配置的 AppName。
		App: "live",
		// 视频直播播放地址中的 StreamName。您可调用 [ListRelaySourceV4](https://docs.volcengine.com/docs/6469/1126878?lang=zh) 并根据返回参数 Stream 获取固定触发回源配置的 StreamName。
		Stream: "example_stream",
		// 回源开始时间。Unix 时间戳，单位为秒。
		// note：
		// <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li>
		// <li> StartTime 和 EndTime 需同时传入或同时不传。传入时，表示更新固定回源类型的回源时间，或将永久回源类型变更为固定回源类型并设置回源时间。不传时，表示更新为永久回源类型。 </li>
		StartTime: Int32Ptr(1785923506),
		// 回源结束时间。Unix 时间戳，单位为秒。
		// note：
		// <li> StartTime 和 EndTime 的时间间隔不可超过 7 天。 </li>
		// <li> StartTime 和 EndTime 需同时传入或同时不传。传入时，表示更新固定回源类型的回源时间，或将永久回源类型变更为固定回源类型并设置回源时间。不传时，表示更新为永久回源类型。 </li>
		EndTime: Int32Ptr(1785953506),
	}

	// 回源地址列表，即视频直播从源站拉取直播流时访问的地址列表。支持 RTMP、RTMPS、FLV 或 HLS 协议。
	// 通常包含协议、源站的域名或 IP 地址，以及源站直播流的 AppName 和 StreamName。如果源站要求回源请求携带额外参数，还需包含查询参数。例如 rtmp://192.*.*.10/live01/test01?token=abc。
	// note：
	// <li> 支持配置自有源站或第三方源站的回源地址。触发回源后，视频直播会访问您配置的回源地址，从源站拉取直播流。 </li>
	// <li> 如果源站使用非默认端口，需在源站的域名或 IP 地址后填写端口，例如 rtmp://192.*.*.10:1936/live01/test01?token=abc，否则系统可能按默认端口访问源站，导致回源失败。 </li>
	// <li> 最多支持传入 10 个回源地址。系统会按照回源地址在数组中的排列顺序依次尝试回源，数组中越靠前的地址优先级越高。如果当前回源地址回源失败，系统会再尝试下一个回源地址。 </li>
	SrcAddrS := []string{"rtmp://live.example.com/live01/test01"}

	body.SrcAddrS = SrcAddrS

	resp, err := service.UpdateRelaySourceV4(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

查询固定触发回源配置列表

您可以调用 ListRelaySourceV4 接口查询固定触发回源配置列表。详细的参数说明可参见 ListRelaySourceV4 接口文档。

接口调用示例如下所示。

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/volcengine/volc-sdk-golang/base"
	live "github.com/volcengine/volc-sdk-golang/service/live/v20230101"
)

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.ListRelaySourceV4Body{
		// 域名空间。
		// 通过以下任一方式，获取域名空间：
		// <li> 调用 [ListDomainDetail](https://www.volcengine.com/docs/6469/1126815) 接口，通过返回参数 Vhost 获取。 </li>
		// <li> 在视频直播控制台的[域名管理](https://console.volcengine.com/live/main/domain/list)页面，通过**域名空间**字段获取。 </li>
		Vhost: "pull.example.com",
		// 查询数据的页码，默认值为 1，表示查询第一页的数据。
		Page: Int32Ptr(1),
		// 每页显示的数据条数，默认值为 20，最大值为 500。
		Size: Int32Ptr(20),
	}

	resp, err := service.ListRelaySourceV4(context.Background(), body)

	if err != nil {
		fmt.Printf("error %v", err)
	} else {
		fmt.Printf("success %+v", resp)
	}
}

最近更新时间：2026.08.31 19:52:26

这个页面对您有帮助吗？

有用

无用

视频直播

调用说明 #

前提条件 #

调用示例 #

添加或更新播放触发回源配置 #

删除播放触发回源配置 #

查询播放触发回源配置 #

添加固定触发回源配置 #

删除固定触发回源配置 #

更新固定触发回源配置 #

查询固定触发回源配置列表 #

调用说明

前提条件

调用示例

添加或更新播放触发回源配置

删除播放触发回源配置

查询播放触发回源配置

添加固定触发回源配置

删除固定触发回源配置

更新固定触发回源配置

查询固定触发回源配置列表