Dynamodb получает от 10 000 до 30 000 записей nodejs

getDBResults(id,
startDate_Timestamp,
endDate_Timestamp).then(data, 
err)=>  {
if (err) console.log("EE", err);
console.log("DD",data);
if (data.length != 0) {
 res.json({ "Status": 200, "Data": data });
 }
 })

 function getDBResults(id, startDate_Timestamp, 
 endDate_Timestamp) {
 var q = Q.defer();
 const params = {
 TableName: 'TableName',
 KeyConditionExpression: '#Id=:Id AND #Timestamp BETWEEN  
:start_date AND :end_date',
ExpressionAttributeNames: {
  "#Timestamp": "Timestamp",
  "#Id": "Id"
},
ExpressionAttributeValues: {
  ":Id": id,
  ":start_date": startDate_Timestamp,
  ":end_date": endDate_Timestamp
}
};
var results = [];
var callback = function (err, data) {
console.log("DD", data);
if (err) {
  console.log('Dynamo fail ' + err);
  q.reject(err);
} else if (data.LastEvaluatedKey) {
  params.ExclusiveStartKey = data.LastEvaluatedKey;
  docclient.query(params, callback);
} else {
  console.log("RR",results);
  q.resolve(results);
}
data.Items.forEach(function (item) {
  results.push(item);
});
}
docclient.query(params, callback);
return q.promise;
}

с этим кодом я не получаю никаких результатов, а результат этого идентификатора содержит почти 20 000–30 000 записей. Я хочу получить все эти записи, но они ничего не регистрируют в консоли aws. Пожалуйста, помогите мне разобраться.


node.js amazon-dynamodb
person Aditya Sharma    schedule 08.12.2018    source источник
comment
Это поможет очистить ваш код, теперь его трудно читать. Начните с отступа и размещения на одной строке кода, который должен быть на одной строке.   -  person Costin    schedule 10.12.2018

Ответы (1)


arrow_upward
0
arrow_downward

Не уверен, что это решение, но я бы попытался вставить results перед вызовом нового запроса:

} else if (data.LastEvaluatedKey) {
    // save items
    data.Items.forEach(function (item) { results.push(item); });        
    params.ExclusiveStartKey = data.LastEvaluatedKey;
    docclient.query(params, callback);
}

Совет: подумайте об использовании промисов, с ними проще работать. Ваш код - "ад обратного вызова" :)

person Costin    schedule 09.12.2018
comment
Используйте больше. Все, что я вижу, это функция callback :) - person Costin; 10.12.2018
comment
Можете ли вы иметь какой-либо код обещания, который я хочу реализовать, где будет Foreach, где одну за другой я хочу получить все записи и остановить цикл, пока все данные одного идентификатора не поступят из dynamodb. Если вы можете помочь - person Aditya Sharma; 10.12.2018