【发布时间】：2018-09-22 04:20:45
【问题描述】：
我的目标是通过传递视频 ID 从 Brightcove CMS API 获取有关视频的元数据。
我们的视频元数据存储在四个不同的业务部门（或配置文件）中，因此我必须分别查询每个业务部门的端点。不知道在哪个事业部会查到哪个视频ID。每次通话我最多可以发送 10 个视频 ID。以下是按视频 ID 获取视频元数据所需的步骤。
1) 获取访问权限token（此步骤使用我提供的客户端凭据）。
2) 通过 options 参数将访问权 token 传递给请求对象 (sendRequest)。
3) 解析响应并将其放入全局videosArray。
4) 对每组 10 个或更少的唯一视频 ID（由多维数组表示）重复步骤 1 到 3。
5) 为每个视频帐户（业务部门）重复步骤 1 到 4。
仅供参考：boilerplate code from Brightcove 使用回调。我已经将该代码转换为异步/等待。如果我的 async/await 代码不正确，也许有人也可以提出改进建议。
我正在使用 Node 8.10、ES6+ 和 request-promise-native 模块（以及其他）。任何看似隐式声明的变量都在全局范围内声明。我只是没有在这里粘贴它们。
bizUnit 是一个对象数组（我总共有四个不同的业务单元要迭代）：
businessUnits = [
bizUnitOne: {
account_id: 'uhdafoia98243r2',
client_id: 'oidahf982y229hr',
client_secret: 'iuahf9o4398oyg',
player_url: 'afdhy984wyyfsg',
},
bizUnitTwo: {
account_id: 'uhdafoia98243r2',
client_id: 'oidahf982y229hr',
client_secret: 'iuahf9o4398oyg',
player_url: 'afdhy984wyyfsg',
}
]
获取访问令牌函数声明：
async function getAccessToken(bizUnit) {
// base64 encode the client_id:client_secret string for basic auth
let bodyObj,
token;
authString = new Buffer(bizUnit.client_id + ':' + bizUnit.client_secret).toString('base64');
let payLoad = {
method: 'POST',
url: 'https://oauth.brightcove.com/v3/access_token?grant_type=client_credentials',
headers: {
'Authorization': 'Basic ' + authString,
'Content-Type': 'application/json'
},
json: true
};
try {
let result = await request(payLoad);
bodyObj = await JSON.parse(result);
token = bodyObj.access_token;
return token;
}
catch (error) {
console.log(oauthError, error);
}
}
发送请求声明：
async function sendRequest(options) {
let requestOptions = {
method: 'GET',
url: options.url,
headers: {
'Authorization': 'Bearer ' + options.token,
'Content-Type': 'application/json'
},
json: true
};
let makeRequest = async (reqOptions) => {
try {
let body = await request(reqOptions);
return JSON.parse(body);
} catch (error) {
console.log(apiError, error);
}
};
// make the request
await makeRequest(requestOptions);
}
视频 IDs 数组示例（理论上，该数组可以包含成百上千个视频 ID，分块为 10 或更少）：
videoIdsGroup = [ [53245,2352,243252,2352352,234234,234324,2342342,24242,23542,234324], [43534, 34543, 3453, 3453345] ];
将所有内容放在一起并提出请求：
function setUpVideoRequest(bizUnit) {
(async (bu) => {
// note that access tokens live for 5 minutes
// but you can always request one for each call to be safe
for (let videoIdsArr of videoIdsGroup) {
let endPoint,
videoIdsString = videoIdsArr.join();
endPoint = '/accounts/' + bu.account_id + '/videos/' + videoIdsString + '&sort=' + sort;
options.url = baseURL + endPoint;
options.token = await getAccessToken(bizUnit);
const videos = await sendRequest(options);
videosArray = videosArray.concat(videos);
}
})(bizUnit);
}
开始执行：
for (let bu of businessUnits) {
/*the counter below is to reveal how many times and in what sequence this for...of loop is executing. my console.log indicates that this loop iterates through all businessUnits immediately, but then it runs again and eventually succeeds in some of the calls and repeats those calls even though it already got data.*/
let parentCounter = 0;
console.log("BizUnit COUNTER", parentCounter++);
try {
promises.push(setUpVideoRequest(bu));
} catch (error) {
throw error;
}
}
我收到错误消息（此消息重复，然后我偶尔获取一些数据，然后错误再次重复）：
statusCode: 400,
message: '400 - {"error":"invalid_client","error_description":"The "client_id" parameter is missing, does not name a client registration that is applicable for the requested call, or is not properly authenticated."}',
我知道 for...of 循环运行不正确，但我尝试了带有 [i] 迭代器的常规 for 循环，我还尝试了 for...in，并且我已经尝试了每个。它们都不能正常工作。
我只是希望能够按帐户 ID（业务单位）和每个视频数组发出请求，并获取所有视频元数据并通过以下方式将其放入全局 videosArray：
Promise.all(promises).then((results) => {
promiseVidArray.push(results);
});
提前感谢您的帮助和洞察力。
【问题讨论】：
-
如果你想使用
await，你必须有一个promise并且不能使用request回调API。如果您已经在使用request-promise-*，请根本不要传递回调！看看它的文档。 -
另外，永远不要让
async function接受callback。你应该只await你正在做的异步工作，然后return。 -
如果您不熟悉
async/await´ yet, try using promises without any syntactic sugar, i.e. use.then()`，请仅调用 -
@Bergi 谢谢。我已经清理了与 Promise 相关的结构。将编辑原始帖子并添加新版本。仍然面临类似的问题。
标签： javascript node.js asynchronous brightcove request-promise