我正在创建一个系统,使用API检查播放器数据,然后更新到我的DynamoDB,但看起来它停止了一半?因为Let's scan our players & update stats!
从未显示在我的日志中?
exports.handler = async (event, context) => {
var documentClient = new AWS.DynamoDB.DocumentClient();
var params = {
TableName: 'games',
FilterExpression:'updated_at = :updated_at',
ExpressionAttributeValues: {
":updated_at": 0,
}
};
var rows = await documentClient.scan(params).promise();
let gameAPI = new GameAPI();
await gameAPI.login().then(function() {
console.log("We have logged into our game!");
rows.Items.forEach(function(match) {
console.log("Let's look at our match! " + match.id);
var player_params = {
TableName: 'players',
FilterExpression:'match_id = :match_id',
ExpressionAttributeValues: {
":match_id": match.id,
}
};
documentClient.scan(player_params).promise().then(row => {
console.log("Let's scan our players & update stats!");
});
});
});
};
我假设它与我的async
和await
功能有关?有人能指出我正确的方向。
你在混合await
和then
。
试试这个:
exports.handler = async (event, context) => {
var documentClient = new AWS.DynamoDB.DocumentClient();
var params = {
TableName: 'games',
FilterExpression:'updated_at = :updated_at',
ExpressionAttributeValues: {
":updated_at": 0,
}
};
var rows = await documentClient.scan(params).promise();
let gameAPI = new GameAPI();
await gameAPI.login();
console.log("We have logged into our game!");
for (let match of rows.Items) {
console.log("Let's look at our match! " + match.id);
var player_params = {
TableName: 'players',
FilterExpression:'match_id = :match_id',
ExpressionAttributeValues: {
":match_id": match.id,
}
};
let row = await documentClient.scan(player_params).promise();
console.log("Let's scan our players & update stats!");
}
};
then
的工作方式是基于回调:
documentClient.scan(params).promise().then((rows) => {
// do something with the rows
});
虽然await
/ async
的工作原理是消除回调并使您的代码看起来同步且更具可读性。
const rows = await documentClient.scan(params).promise();
// do something with the rows