Youtube API 无法创建直播和直播的两个同时绑定(1 到 1)

Question

首先，我将解释如何使用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 返回错误：未找到直播好像某处存在竞争条件导致创建 1 个单曲而所有其他单曲都失败了。 我必须做的一个肮脏的解决方法是添加超时(每 2 秒一次)，但如果多个用户将使用"我的 API"，这将导致整个事情失败。

现在我正在考虑创建一个队列来管理 youtube 直播的创建。想知道是否有人有这个问题...

Answer 1

问题是这段代码被包装在一个函数中，该函数使用外部初始化的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
});
....
....
});