作者:ScilenceBill | 来源:互联网 | 2023-02-01 09:12
如何从AWS dynamodb
使用中获取/扫描所有项目node.js
.我在这里发布我的代码.
var docClient = new aws.DynamoDB.DocumentClient();
var params = {
TableName:"users",
KeyConditionExpression:"user_status=:status",
ExpressionAttributeValues: {
":status": "Y"
}
};
var queryExecute = function(callback) {
docClient.query(params,function(err,result) {
if(err) {
console.log(err)
callback(err);
} else {
console.log(result);
if(result.LastEvaluatedKey) {
params.ExclusiveStartKey = result.LastEvaluatedKey;
queryExecute(callback);
} else {
callback(err,items);
}
}
});
}
queryExecute(callback);
这给了我以下错误.
ValidationException: Query condition missed key schema element: `user_id`.
这里的主键是user_id.我不想在查询条件中使用它,因为如果我提到主键,我需要设置一个值KeyConditionExpression
.可能是我错了.但是请建议我一个很好的方法来获取所有项目dynamodb
,这是有的user_status = "Y"
1> notionquest..:
如果您想在不使用Hash密钥值的情况下从DynamoDB获取数据,则需要使用Scan API
.
注意: Scan API会读取表中的所有项目以获取结果.因此,这在DynamoDB中是一项代价高昂的操作.
替代方法:使用GSI
上述情景的扫描码: -
var docClient = new AWS.DynamoDB.DocumentClient();
var params = {
TableName: "users",
FilterExpression: "#user_status = :user_status_val",
ExpressionAttributeNames: {
"#user_status": "user_status",
},
ExpressionAttributeValues: { ":user_status_val": 'somestatus' }
};
docClient.scan(params, onScan);
var count = 0;
function onScan(err, data) {
if (err) {
console.error("Unable to scan the table. Error JSON:", JSON.stringify(err, null, 2));
} else {
console.log("Scan succeeded.");
data.Items.forEach(function(itemdata) {
console.log("Item :", ++count,JSON.stringify(itemdata));
});
// continue scanning if we have more items
if (typeof data.LastEvaluatedKey != "undefined") {
console.log("Scanning for more...");
params.ExclusiveStartKey = data.LastEvaluatedKey;
docClient.scan(params, onScan);
}
}
}
尽管这似乎可行,但我认为如果此答案实际上返回数据,而不是仅仅将其打印到控制台,那就更好了。对于刚接触JS或函数式编程的人来说,从此处提出一个解决方案(实际上将数据(通过callbak)返回给调用函数)的解决方案并不一定很容易。
2> 小智..:
这为我工作:
export const scanTable = async (tableName) => {
const params = {
TableName: tableName,
};
let scanResults = [];
let items;
do{
items = await documentClient.scan(params).promise();
items.Items.forEach((item) => scanResults.push(item));
params.ExclusiveStartKey = items.LastEvaluatedKey;
}while(typeof items.LastEvaluatedKey != "undefined");
return scanResults;
};