首先,我将解释如何使用Youtube API创建实时流,其次,我将解释用例,其次,我将粘贴我的代码段。
怎么运行的 :
基本上,您需要创建一个直播(youtube.liveBroadcasts.insert
)并获取直播ID(1)
然后创建一个直播(youtube.liveStreams.insert
)并从中获取直播ID(2),您需要将直播绑定到直播(youtube.liveBroadcasts.bind
):
绑定的结果基本上包含流URL。
用例:
基本上,这是一个实时流API:用户注册一个或多个YouTube帐户,我运行以下代码来创建实时流并获取rtmp网址,这样我就可以同时在多个YouTube频道上进行流式传输。
代码 :
oauth2Client.setCredentials({
access_token: youtube_tokens.access_token,
refresh_token: youtube_tokens.refresh_token,
expiry_date: true
});
var youtube_broadcasts_body = {
snippet: {
// "scheduledEndTime": "2016-11-23T20:00:00.0+08",
"scheduledStartTime": start_date,
"title": target.stream_title
},
status: {
"privacyStatus": "private"
},
contentDetails: {
"projection": youtubeProjection
}
}
var youtube_livebroadcast_params = {
part: "id,snippet,status, contentDetails",
resource: youtube_broadcasts_body
}
var youtube_stream_body = {
snippet: {
"title": target.stream_title
},
cdn: {
"ingestionType": "rtmp",
"frameRate": "30fps",
"resolution": target.youtube_resolution
}
}
var youtube_stream_params = {
part: "id,snippet,cdn,status",
resource: youtube_stream_body
}
var youtube = google.youtube({ version: 'v3', auth: oauth2Client });
youtube.liveBroadcasts.insert(youtube_livebroadcast_params, function(err, res) {
if (err) {
logger.fatal(err)
return callback(err)
}
target.broadcast = res
target.status = "livebroadcast_event_created"
var broadcast_id = res.id
youtube.liveStreams.insert(youtube_stream_params, function(err, res) {
if (err) {
logger.fatal(err)
return callback(err)
}
var stream_id = res.id
res.broadcast_id = broadcast_id
target.stream = res
target.status = "livestream_created"
var youtube_livebroadcast_bind_params = {
part: "id,contentDetails",
streamId: stream_id,
id: broadcast_id
}
youtube.liveBroadcasts.bind(youtube_livebroadcast_bind_params, function(err, res) {
if (err) return callback(err)
target.status = "livebroadcast_bound_to_livestream"
target.ingest_url = target.stream.cdn.ingestionInfo.ingestionAddress + "/" + target.stream.cdn.ingestionInfo.streamName
target._id = broadcast_id
return callback(null, target)
})
})
})
发生的是,当我两次调用此代码(在for循环中)时,Youtube api返回了一个错误:找不到Livebroadcast好像某处存在竞争条件导致创建1个单播,其他所有都失败了。
我要做的一个肮脏的解决方法是添加一个超时(每2秒),但是如果一个以上的用户将使用“我的API”,这将导致整个操作失败。
现在,我正在考虑创建一个队列,该队列将管理youtube直播的创建。想知道是否有人遇到这个问题...
最佳答案
问题在于此代码被包装在使用在其外部初始化的外部oauth2Client对象的函数中:
const oauth2Client = new OAuth2( // initialize the object outside is wrong
YOUTUBE_CLIENT_ID, // when you wanna use new tokens
YOUTUBE_CLIENT_SECRET, // inside the function.
YOUTUBE_REDIRECT_URL
);
var createLiveEvent = function(target, callback) {
var youtubeDestination = target.destination
var youtube_tokens = youtubeDestination.user_data;
oauth2Client.setCredentials({
access_token: youtube_tokens.access_token, //tokens got from oauth2 authentication
refresh_token: youtube_tokens.refresh_token,
expiry_date: true
});
var youtube = google.youtube({
version: 'v3',
auth: oauth2Client
});
logger.debug("Youtube: Creating event on Channel ")
....
....
})
解决方案实际上是针对每个不同的access_token / refresh_token在函数内使用不同的oauth2Client对象:
var createLiveEvent = function(target, callback) {
let oauth2Client = new OAuth2(
YOUTUBE_CLIENT_ID,
YOUTUBE_CLIENT_SECRET,
YOUTUBE_REDIRECT_URL
);
var youtubeDestination = target.destination
var youtube_tokens = youtubeDestination.user_data;
oauth2Client.setCredentials({
access_token: youtube_tokens.access_token,
refresh_token: youtube_tokens.refresh_token,
expiry_date: true
});
....
....
});
关于node.js - Youtube API无法同时创建直播和直播的两个绑定(bind)(1到1),我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/42793385/