首先,我将解释如何使用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/

10-09 06:08