npm install aws-sdk --save-dev

const aws = require('aws-sdk');
const docClient = new aws.DynamoDB.DocumentClient({
	region: 'ap-northeast-1'  // 東京リージョン
});

before(async function() {
	this.timeout(20000);
	
	// 項目を作成
	await docClient.put({
		TableName: 'MyTable',
		Item: {
			MyId: 111,
			MyNumber: 12345,                           // Number型
			MyString: 'strrr',                         // String型
			MyBoolean: true,                           // Boolean型
			MyBinary: new Buffer([0x00, 0x01, 0x02]),  // Binary型
			MyNull: null                               // Null型
			MyList: [1,2,3],                           // List型 (中身はNumber型)
			MyMap: { a: 1, b: 2, c: 3 },               // Map型 (中身はNumber型)
		}
	}).promise();
});

const aws = require('aws-sdk');
const docClient = new aws.DynamoDB.DocumentClient({
	region: 'ap-northeast-1'  // 東京リージョン
});

after(async function() {
	this.timeout(20000);
	
	// 項目を削除
	await docClient.delete({
		TableName: 'MyTable',
		Key: {
			MyId: 111,
		}
	}).promise();
});

const aws = require('aws-sdk');
const docClient = new aws.DynamoDB.DocumentClient({
	region: 'ap-northeast-1'  // 東京リージョン
});

before(async function() {
	this.timeout(20000);
	
	const tableName = 'MyTable';
	const targetPartitionKey = 'hogehoge';
	let exclusiveStartKey = null;
	for (;;) {
		// まとめてプライマリキーを取得
		const res = await docClient.query({
			TableName: tableName,
			KeyConditionExpression: '#MyPartitionKey = :MyPartitionKey',
			ExpressionAttributeNames:{
				'#MyPartitionKey': 'MyPartitionKey'
			},
			ExpressionAttributeValues:{
				':MyPartitionKey': targetPartitionKey
			},
			AttributesToGet: ['MyPartitionKey', 'MySortKey'],  // プライマリキー属性のみ取得する
			ExclusiveStartKey: exclusiveStartKey,              // ExclusiveStartKey以降を取得する
		}).promise();
		
		// プライマリキーで項目を削除
		if (res.Items) {
			for (let item of res.Items) {
				await docClient.delete({	
					TableName: tableName,
					Key: {
						MyPartitionKey: item.MyPartitionKey,
						MySortKey: item.MySortKey,
					}
				}).promise();
			}
		}
		// 読んでないデータが無ければ抜ける、残っていれば続ける
		if (res.LastEvaluatedKey === undefined) {
			break;
		}
		exclusiveStartKey = res.LastEvaluatedKey;
	}
});

const res = await docClient.scan({
	TableName: tableName,
	AttributesToGet: ['MyPartitionKey', 'MySortKey'],
	ExclusiveStartKey: exclusiveStartKey,
}).promise();

const expect = require('chai').expect;
const aws = require('aws-sdk');
const docClient = new aws.DynamoDB.DocumentClient({
	region: 'ap-northeast-1'
});

describe('DynamoDB', function() {
	this.timeout(20000);
	
	it('項目が存在し、想定通りの内容である', async function() {
		// ※テスト対象モジュールを実行した体で項目を作成
		await docClient.put({
			TableName: 'MyTable',
			Item: {
				MyId: 111,
				MyNumber: 12345,
				MyString: 'strrr',
				MyBoolean: true,
				MyBinary: new Buffer([0x00, 0x01, 0x02]),
				MyNull: null,
				MyList: [1,2,3],
				MyMap: { a: 1, b: 2, c: 3 },
			}
		}).promise();
		
		// 作成された項目を取得
		const res = await docClient.get({
			TableName: 'MyTable',
			Key: {
				MyId: 111,
			},
			ConsistentRead: true  // 確実に最新のデータを取得する (強力な整合性のある読み込み)
		}).promise();

		// 項目が存在する場合、戻りのオブジェクトにItemキーがあるはず
		expect(res).to.include.all.keys('Item');
		
		// 項目の内容を検証
		expect(res.Item).to.deep.equal({
			MyId: 111,
			MyNumber: 12345,
			MyString: 'strrr',
			MyBoolean: true,
			MyBinary: new Buffer([0x00, 0x01, 0x02]),
			MyNull: null,
			MyList: [1,2,3],
			MyMap: { a: 1, b: 2, c: 3 },
		});
	});
});

// 項目が存在する場合、戻りのオブジェクトにItemキーがあるはず
expect(res).to.include.all.keys('Item');
const item = res.Item;

// MyId は数値型で、値が 111 であるか
expect(item.MyId).to.equal(111);

// MyNumber は数値型で、値が 12345 であるか
expect(item.MyNumber).to.equal(12345);

// MyString は文字列型で、値が strrr であるか
expect(item.MyString).to.equal('strrr');

// MyBoolean は真偽値で、値が true であるか
expect(item.MyBoolean).to.be.true;

// MyBinary はBuffer型で、中身が 0x00, 0x01, 0x02 であるか
expect(item.MyBinary).to.deep.equal(new Buffer([0x00, 0x01, 0x02]));

// MyNull は null であるか
expect(item.MyNull).to.be.null;

// MyList は配列で、中身が 1, 2, 3 であるか
expect(item.MyList).to.deep.equal([1,2,3]);

// MyMap はオブジェクトで、中身が a: 1, b: 2, c: 3 であるか
expect(item.MyMap).to.deep.equal({ a: 1, b: 2, c: 3 });

// キーに過不足は無いか
expect(item).to.have.all.keys('Id', 'MyNumber', 'MyString', 'MyBoolean', 'MyBinary', 'MyNull', 'MyList', 'MyMap');

const expect = require('chai').expect;
const aws = require('aws-sdk');
const docClient = new aws.DynamoDB.DocumentClient({
	region: 'ap-northeast-1'
});

describe('DynamoDB', function() {
	this.timeout(20000);
	
	it('項目が存在しない', async function() {
		// 存在しない項目を取得
		const res = await docClient.get({
			TableName: 'MyTable',
			Key: {
				Id: 999,
			},
			ConsistentRead: true  // 確実に最新のデータを取得する (強力な整合性のある読み込み)
		}).promise();

		// 項目が存在しない場合、戻りのオブジェクトにItemキーは含まれてないはず
		expect(res).to.not.include.keys('Item');
	});
});