使用 Q.Promises 递归地从 DynamoDB 获取记录

Question

我在使用递归dynamodb调用实现Q承诺时遇到问题，这是nodejs和q的新手，考虑到dynamodb检索结果的限制，我们需要运行递归查询来获得所需的结果。

通常我们使用带有 Q 实现的查询，

如下所示

function getDBResults(){
var q = Q.defer();
var params = {
TableName: mytable,
IndexName: 'mytable-index',
KeyConditionExpression: 'id = :id',
FilterExpression: 'deliveryTime between :startTime and :endTime',
ExpressionAttributeValues: {
':startTime': {
N: startTime.toString()
},
":endTime": {
N: endTime.toString()
},
":id": {
S: id.toString()
}
},
Select: 'ALL_ATTRIBUTES',
ScanIndexForward: false,
};

dynamodb.query(params, function(err, data) {
if (err) {
console.log('Dynamo fail ' + err);
q.reject(err);
} else {
console.log('DATA'+ data);
var results = data.Items;
q.resolve(results);
}
});
return q.promise;
}

getDBResults.then(
function(data) {
// handle data
},
function(err) {
//handle error
}
);

使用递归查询我可以得到结果，但我需要将这些结果用于另一个函数，但由于 nodejs 异步性质，下一个函数调用在递归查询函数完成其工作之前已经发生，现在我希望我从递归查询函数中获取所有结果，然后作为对新函数的承诺，最后处理所有数据。

DynamoDB 的递归查询如下所示。

function getDBResults(){
//var q = Q.defer();
params = {
TableName: mytable,
IndexName: 'mytable-index',
KeyConditionExpression: 'id = :id',
FilterExpression: 'deliveryTime between :startTime and :endTime',
ExpressionAttributeValues: {
':startTime': {
N: startTime.toString()
},
":endTime": {
N: endTime.toString()
},
":id": {
S: id.toString()
}
},
Select: 'ALL_ATTRIBUTES',
ScanIndexForward: false,
};

dynamodb.query(params, onQueryCallBack);

}

function onQueryCallBack(err, data) {
if (err) {
console.log('Dynamo fail ' + err);
console.error("Could not query db" + err);
} else {

if (typeof data.LastEvaluatedKey != "undefined") {
console.log("query for more...");
params.ExclusiveStartKey = data.LastEvaluatedKey;
dynamodb.query(params, onQueryCallBack);
}
data.Items.forEach(function(item) {
allResults.push(item);
});
//console.log('NO:OF Results:' + allResults.length);
//q.resolve(tickets);
//});

}

现在我希望我最终可以得到结果作为承诺，这样我就可以在下一个函数中处理它们。

getDBResults.then(
function(data) {
// handle data
},
function(err) {
//handle error
}
);

请帮助我，对不起，如果这是一个愚蠢的问题，但带有承诺的递归调用对我来说是一个障碍。

谢谢

Answer 1

首先，保留你已经拥有的 promissized 函数。将其用作递归解决方案的构建块，而不是试图更改它！

不过，它可能需要两个小的调整：

function getDBResults(startKey){
//                    ^^^^^^^^
var q = Q.defer();
var params = {
ExclusiveStartKey: startKey,
//      ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
… // rest as before
};
dynamodb.query(params, function(err, data) {
if (err) {
q.reject(err);
} else {
q.resolve(data);
//                   ^^^^ Not `data.Items`
}
});
return q.promise;
}

现在我们可以使用它来简单地实现递归解决方案：

function getRecursiveDBResults(key) {
return getDBResults(key).then(function(data) {
if (typeof data.LastEvaluatedKey != "undefined") {
return getRecursiveDBResults(data.LastEvaluatedKey).then(items) {
return data.Items.concat(items);
});
} else {
return data.Items
}
});
}

Answer 2

这是我解决问题的方法，也感谢Bergi的解决方案

function getDBResults() {
var q = Q.defer();
var dynamodb = core.getDynamoDB();

params = {
TableName: mytable,
IndexName: 'mytable-index',
KeyConditionExpression: 'id = :id',
FilterExpression: 'deliveryTime between :startTime and :endTime',
ExpressionAttributeValues: {
':startTime': {
N: startTime.toString()
},
":endTime": {
N: endTime.toString()
},
":id": {
S: id.toString()
}
},
Select: 'ALL_ATTRIBUTES',
ScanIndexForward: false,
};

var results = [];
var callback = function(err, data) {
if (err) {
console.log('Dynamo fail ' + err);
q.reject(err);
} else if (data.LastEvaluatedKey) {
params.ExclusiveStartKey = data.LastEvaluatedKey;
dynamodb.query(params, callback);
} else {
q.resolve(results);
}
data.Items.forEach(function(item) {
results.push(item);
});
}

dynamodb.query(params, callback);
return q.promise;
}