Skip to content

Instantly share code, notes, and snippets.

@SagarGhagare

SagarGhagare/dynamodb delete all items in table

Forked from jonarddoci/dynamodb delete all items in table
Last active December 18, 2019 15:28
Show Gist options
  • Save SagarGhagare/eefef3726b6ac7423dd408b570c9260d to your computer and use it in GitHub Desktop.
Save SagarGhagare/eefef3726b6ac7423dd408b570c9260d to your computer and use it in GitHub Desktop.
Download ZIP
Raw
dynamodb delete all items in table
var hashKey = "id";
var rangeKey = null;
var tableName = "alert";
var scanParams = {
TableName: tableName,
};
docClient.scan(scanParams, function(err, data) {
if (err) ppJson(err); // an error occurred
else {
data.Items.forEach(function(obj,i){
console.log(i);
console.log(obj);
var params = {
TableName: scanParams.TableName,
Key: buildKey(obj),
ReturnValues: 'NONE', // optional (NONE | ALL_OLD)
ReturnConsumedCapacity: 'NONE', // optional (NONE | TOTAL | INDEXES)
ReturnItemCollectionMetrics: 'NONE', // optional (NONE | SIZE)
};
docClient.delete(params, function(err, data) {
if (err) ppJson(err); // an error occurred
else ppJson(data); // successful response
});
});
}
});
function buildKey(obj){
var key = {};
key[hashKey] = obj[hashKey]
if(rangeKey){
key[rangeKey] = obj[rangeKey];
}
return key;
}
Raw
dynamodb delete all tables
dynamodb.listTables().eachPage(function(err, data) {
if (err) {
ppJson(err); // an error occurred
} else if (data) {
console.log(data);
data["TableNames"].forEach(function(tablename, i) {
console.log(tablename);
var params = {
TableName: tablename,
};
dynamodb.deleteTable(params, function(err, data) {
if (err) ppJson(err); // an error occurred
else ppJson(data); // successful response
});
})
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment