以编程方式获取属于用户的所有 YouTube 视频

Programmatically Obtain All YouTube Videos Belonging to a User

利用 YouTube 数据 API 我们可以进行查询以获取属于具有以下请求的用户的前 50 个(单个查询可获得的结果的最大数量)视频:https://www.googleapis.com/youtube/v3/search?key={access_key}&channelId={users_id}&part=id&order=date&maxResults=50&type=video

如果有超过 50 个视频,那么生成的 JSON 将有一个 nextPageToken 字段,要获取接下来的 50 个视频,我们可以将 &pageToken={nextPageToken} 附加到上述请求,制作下一页的 50 个视频。这是可重复的,直到 nextPageToken 字段不再存在。

这是我使用 fetch API 编写的一个简单的 JavaScript 函数,用于获取 单个 视频页面,由 nextPageToken 参数(或缺少参数)。

function getUploadedVideosPage(nextPageToken) {
    return new Promise((resolve, reject) => {
        let apiUrl = 'https://www.googleapis.com/youtube/v3/search?key={access_key}&channelId={users_id}&part=id&order=date&maxResults=50&type=video';
        if(nextPageToken)
            apiUrl += '&pageToken=' + nextPageToken;

        fetch(apiUrl)
        .then((response) => {
            response.json()
            .then((data) => {
                resolve(data);
            });
        });
    });
}

现在我们需要一个包装函数,只要我们有 nextPageToken,它就会迭代调用 getUploadedVideosPage。这是我的 'working' 尽管很危险(稍后会详细介绍)的实现。

function getAllUploadedVideos() {
    return new Promise((resolve, reject) => {
        let dataJoined = [];
        let chain = getUploadedVideosPage();

        for(let i = 0; i < 20000; ++i) {
            chain = chain
            .then((data) => {
                dataJoined.push(data);

                if(data.nextPageToken !== undefined)
                    return getUploadedVideosPage(data.nextPageToken);
                else
                    resolve(dataJoined);
            });
        }
    });
}

'dangerous' 方面是 for 循环的条件,理论上它应该是无限的 for(;;) 因为我们没有预定义的方法来确切知道要进行多少次迭代,并且唯一的方法是终止循环应该使用 resolve 语句。然而,当我以这种方式实现它时,它确实是无限的并且永不终止。

因此我硬编码了 20,000 次迭代,它似乎有效,但我不相信该解决方案的可靠性。我希望这里有人可以阐明如何着手实现这个没有预定义终止条件的迭代 Promise 链。

完全摆脱 for 循环。像这样:

function getAllUploadedVideos() {
    return new Promise((resolve, reject) => {
        let dataJoined = [];

        function getNextPage(nextPageToken) {
            return new Promise((resolve, reject) => {
                getUploadedVideosPage(nextPageToken)
                    .then((data) => {
                        dataJoined.push(data);
                        if(data.nextPageToken !== undefined) {
                            resolve(data.nextPageToken);
                        }
                        else {
                            reject();
                        }
                    })
                    .catch((err) => {
                        // Just in case getUploadedVideosPage errors
                        reject(err);
                    });
            });
        }

        getNextPage()
            .then((nextPageToken) => {
                getNextPage(nextPageToken);
            })
            .catch(() => {
                // This will hit when there is no more pages to grab
                resolve(dataJoined);
            });

    });
}

如果适用,您可以使用一个调用自身的函数来完成这一切。

您还在 new Promise 中使用 explicit promise construction anti-pattern 包装 fetch() 因为 fetch() 已经 returns 一个承诺

function getVideos(nextPageToken, results = []) {

  let apiUrl = 'https://www.googleapis.com/youtube/v3/search?key={access_key}&channelId={users_id}&part=id&order=date&maxResults=50&type=video';
  if (nextPageToken) {
    apiUrl += '&pageToken=' + nextPageToken;
  }

  // return fetch() promise
  return fetch(apiUrl)
    .then(response => response.json())
    .then(data => {
      // merge new data into final results array
      results = results.concat(data);

      if (data.nextPageToken !== undefined) {
        // return another request promise
        return getVideos(data.nextPageToken, results);
      } else {
        // all done so return the final results
        return results
      }
    });
}

// usage
getVideos().then(results=>{/*do something with all results*/})
           .catch(err=>console.log('One of the requests failed'));