代码拉取完成，页面将自动刷新
English | 简体中文
Agora's Cloud Transcoding Service is developed specifically for live streaming scenarios in real-time interactive products. This service allows you to retrieve the host's audio and video source streams from an RTC channel on the server side, process them through transcoding, audio mixing, compositing, and other audio-video operations, and finally publish the processed streams to Agora's RTC channels for audience subscription. By using the Cloud Transcoding Service, viewers do not need to subscribe to multiple hosts' audio and video streams, thereby reducing downlink bandwidth pressure and performance consumption on client devices.
Obtain Agora App ID -------- Agora Console
Click Create Application
Select the type of application you want to create
Obtain App Certificate ----- Agora Console
In the project management page of the Agora Console, find your project and click Configure.
Click the copy icon under Primary Certificate to obtain the App Certificate for your project.
Enable Cloud Transcoding Service Please contact Agora Technical Support
Before creating a cloud transcoding task, you need to call the acquire method to obtain a tokenName. A builderToken can only be used for one cloud transcoding task.
Parameters that need to be set:
Implement acquiring cloud transcoding resources by calling the Acquire method
ctx := context.Background()
appId := "xxxx"
username := "xxxx"
password := "xxxx"
credential := auth.NewBasicAuthCredential(username, password)
config := &agora.Config{
AppID: appId,
Credential: credential,
DomainArea: domain.CN,
Logger: agoraLogger.NewDefaultLogger(agoraLogger.DebugLevel),
}
cloudTranscoderClient, err := cloudtranscoder.NewClient(config)
if err != nil {
log.Fatalln(err)
}
acquireResp, err := cloudTranscoderClient.Acquire(ctx, &cloudTranscoderAPI.AcquireReqBody{
InstanceId: instanceId,
})
if err != nil {
log.Fatalln(err)
}
if acquireResp.IsSuccess() {
log.Printf("acquire success:%+v\n", acquireResp)
} else {
log.Fatalf("acquire failed:%+v\n", acquireResp)
}
After acquiring cloud transcoding resources through the acquire method, call the create method to start cloud transcoding.
Parameters that need to be set:
Implement creating cloud transcoding by calling the Create method
createResp, err := cloudTranscoderClient.Create(ctx, tokenName, &cloudTranscoderAPI.CreateReqBody{
Services: &cloudTranscoderAPI.CreateReqServices{
CloudTranscoder: &cloudTranscoderAPI.CloudTranscoderPayload{
ServiceType: "cloudTranscoderV2",
Config: &cloudTranscoderAPI.CloudTranscoderConfig{
Transcoder: &cloudTranscoderAPI.CloudTranscoderConfigPayload{
IdleTimeout: 300,
AudioInputs: []cloudTranscoderAPI.CloudTranscoderAudioInput{
{
Rtc: &cloudTranscoderAPI.CloudTranscoderRtc{
RtcChannel: "test-abc",
RtcUID: 123,
RtcToken: "xxxxxx",
},
},
},
Outputs: []cloudTranscoderAPI.CloudTranscoderOutput{
{
Rtc: &cloudTranscoderAPI.CloudTranscoderRtc{
RtcChannel: "test-efg",
RtcUID: 456,
RtcToken: "xxxxx",
},
AudioOption: &cloudTranscoderAPI.CloudTranscoderOutputAudioOption{
ProfileType: "AUDIO_PROFILE_MUSIC_STANDARD",
},
},
},
},
},
},
},
})
if err != nil {
log.Fatalln(err)
}
if createResp.IsSuccess() {
log.Printf("create success:%+v\n", createResp)
} else {
log.Printf("create failed:%+v\n", createResp)
return
}
After starting cloud transcoding, you can call the query method to check the cloud transcoding status.
Parameters that need to be set:
Implement querying cloud transcoding status by calling the Query method:
queryResp, err := cloudTranscoderClient.Query(ctx, taskId, tokenName)
if err != nil {
log.Println(err)
return
}
if queryResp.IsSuccess() {
log.Printf("query success:%+v\n", queryResp)
} else {
log.Printf("query failed:%+v\n", queryResp)
return
}
After starting cloud transcoding, you can call the update method to update the cloud transcoding status.
Parameters that need to be set:
taskId: The taskId obtained from the Create method
builderToken: The tokenName obtained through the acquire method
sequenceId: The sequence number of the Update request. The value must be greater than or equal to 0. Ensure that the sequence number of a subsequent Update request is greater than that of the previous Update request. The sequence number ensures that the Agora server updates the cloud transcoder according to your latest specified configuration.
For more parameters in the request body, see the Update API documentation
Implement updating cloud transcoding by calling the Update method
updateResp, err := cloudTranscoderClient.Update(ctx, taskId, tokenName, 1, &cloudTranscoderAPI.UpdateReqBody{
Services: &cloudTranscoderAPI.CreateReqServices{
CloudTranscoder: &cloudTranscoderAPI.CloudTranscoderPayload{
ServiceType: "cloudTranscoderV2",
Config: &cloudTranscoderAPI.CloudTranscoderConfig{
Transcoder: &cloudTranscoderAPI.CloudTranscoderConfigPayload{
IdleTimeout: 300,
AudioInputs: []cloudTranscoderAPI.CloudTranscoderAudioInput{
{
Rtc: &cloudTranscoderAPI.CloudTranscoderRtc{
RtcChannel: "test-abc",
RtcUID: 123,
RtcToken: "xxxxxx",
},
},
},
Outputs: []cloudTranscoderAPI.CloudTranscoderOutput{
{
Rtc: &cloudTranscoderAPI.CloudTranscoderRtc{
RtcChannel: "test-efg",
RtcUID: 456,
RtcToken: "xxxxx",
},
AudioOption: &cloudTranscoderAPI.CloudTranscoderOutputAudioOption{
ProfileType: "AUDIO_PROFILE_MUSIC_HIGH_QUALITY_STEREO",
},
},
},
},
},
},
},
})
if err != nil {
log.Println(err)
return
}
if updateResp.IsSuccess() {
log.Printf("update success:%+v\n", updateResp)
} else {
log.Printf("update failed:%+v\n", updateResp)
return
}
If you no longer need cloud transcoding, you can initiate a Delete request to destroy it.
Parameters that need to be set:
Implement stopping cloud transcoding by calling the Delete method
deleteResp, err := cloudTranscoderClient.Delete(ctx, taskId, tokenName)
if err != nil {
log.Println(err)
return
}
if deleteResp.IsSuccess() {
log.Printf("delete success:%+v\n", deleteResp)
} else {
log.Printf("delete failed:%+v\n", deleteResp)
return
}
For specific business response codes, please refer to the Response Status Codes documentation
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手