Forked from jonarddoci/dynamodb delete all items in table
Created
April 9, 2018 00:37
-
-
Save springfred/ac38a68ae6c20513e141c6fce4e97875 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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; | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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