:プログラムコードを使用して DynamoDB 互換インスタンスに接続する

準備

DynamoDB 互換 ApsaraDB for MongoDB インスタンスの接続文字列を取得します。

1. [ApsaraDB for MongoDB コンソール] にログインします。

2. 表示されるページの左上隅で、インスタンスが属するリソースグループとリージョンを選択します。

3. 左側のナビゲーションウィンドウで、[シャードクラスターインスタンス] をクリックします。

4. 目的のインスタンスを見つけ、インスタンス ID をクリックします。

5. インスタンス詳細ページの左側のナビゲーションウィンドウで、[データベース接続] をクリックします。

6. [内部接続 - VPC] セクションで、インスタンスの接続文字列を表示します。

AWS CLI を使用してインスタンスに接続する

このセクションでは、AWS CLI を使用して DynamoDB 互換 ApsaraDB for MongoDB インスタンスに接続する方法について説明します。 この例では、Ubuntu 16.04.6 LTS を使用しています。 AWS CLI の詳細については、「AWS Command Line Interface とは」をご参照ください。

1. AWS CLI クライアントをインストールします。

   1. 次のコマンドを実行して、最新バージョンの AWS CLI のインストールパッケージを取得し、パッケージの名前を awscliv2.zip に変更します。

      curl "https://awscli.amazonaws.com/awscli-exe-linux-x86_64.zip" -o "awscliv2.zip"

   2. 次のコマンドを実行して、awscliv2.zip ファイルを解凍します。

      unzip awscliv2.zip

      説明

      unzip ユーティリティをインストールしていない場合は、sudo apt install unzip コマンドを実行して unzip ユーティリティをインストールします。 その後、上記のコマンドを実行して awscliv2.zip パッケージを解凍します。

   3. 次のコマンドを実行して、AWS CLI クライアントをインストールします。

      sudo ./aws/install

   You can now run: /usr/local/bin/aws --version プロンプトが表示されたら、AWS CLI クライアントがインストールされています。 /usr/local/bin/aws --version コマンドを実行して、AWS CLI のバージョン番号を照会できます。

2. /usr/local/bin/aws configure コマンドを実行して AWS CLI を構成し、次の表に示すパラメータを構成します。 パラメータを構成した後、Enter キーを押します。

   パラメータ	説明	例
   AWS Access Key ID	AWS アカウントのアクセスキー ID。 アクセスキー ID がない場合は、ランダムな文字を入力します。	XXXXXXXXXX
   AWS Secret Access Key	AWS アカウントのシークレットアクセスキー。 シークレットアクセスキーがない場合は、ランダムな文字を入力します。	XXXXXXXXXX
   Default region name	AWS DynamoDB データベースが存在するリージョン。 リージョンがない場合は、例に示すリージョンを入力します。	us-west-2
   Default output format	デフォルトの出力フォーマット。 このパラメータは空のままにすることができます。	json

   説明

   AWS CLI の構成の詳細については、「AWS CLI の構成」をご参照ください。

3. 次のコマンドを実行して、DynamoDB 互換 ApsaraDB for MongoDB インスタンスに接続し、コレクションを作成します。

   aws dynamodb --endpoint-url <Connection string of the DynamoDB-compatible ApsaraDB for MongoDB instance> \ 
       create-table --table-name <Name of the collection that you want to create> \
       --attribute-definitions AttributeName=<Attribute name>,AttributeType=<Data type of the attribute> \
       --key-schema AttributeName=<Attribute name of the primary key>,KeyType=<Role of the primary key> \
       --provisioned-throughput ReadCapacityUnits=<Provisioned read throughput>,WriteCapacityUnits=<Provisioned write throughput>

   パラメータ	説明
   --endpoint-url	DynamoDB 互換 ApsaraDB for MongoDB インスタンスの接続文字列。 接続文字列は HTTP:// で始まる必要があります。
   create-table	コレクションを作成するために使用されるコマンド。 説明 詳細については、「create-table」をご参照ください。
   --table-name	作成するコレクションの名前。
   --attribute-definitions	コレクションまたはインデックスのキースキーマを記述する属性の配列。 このパラメータは、次のオプションで構成されます。 AttributeName: 属性の名前。 AttributeType: 属性のデータ型。 説明 詳細については、「create-table」をご参照ください。
   --key-schema	コレクションまたはインデックスのプライマリキー属性。 このパラメータは、次のオプションで構成されます。 AttributeName: --attribute-definitions パラメータを使用して作成されたプライマリキー属性の名前。 KeyType: プライマリキーのロール。 説明 詳細については、「create-table」をご参照ください。
   --provisioned-throughput	コレクションまたはインデックスのプロビジョニングスループット。 このパラメータは、次のオプションで構成されます。 ReadCapacityUnits: プロビジョニングされた読み取りスループット。 WriteCapacityUnits: プロビジョニングされた書き込みスループット。 説明 詳細については、「create-table」をご参照ください。

   サンプルコード:

   /usr/local/bin/aws dynamodb --endpoint-url http://dds-xxxx.mongodb.rds.aliyuncs.com:3717 # DynamoDB 互換 ApsaraDB for MongoDB インスタンスに接続するために使用される接続文字列を指定します。 \
       create-table --table-name student # student という名前のコレクションを作成します。 \
       --attribute-definitions AttributeName=name,AttributeType=S AttributeName=age,AttributeType=N # コレクションに STRING 型の name 属性と NUMBER 型の age 属性を指定します。 \
       --key-schema AttributeName=name,KeyType=HASH AttributeName=age,KeyType=RANGE # name 属性をパーティションキーとして、age 属性をソートキーとして指定します。 \
       --provisioned-throughput ReadCapacityUnits=5,WriteCapacityUnits=5 # プロビジョニングされた読み取りスループットと書き込みスループットを 5 に設定します。

   次のコンテンツが表示された場合は、DynamoDB 互換 ApsaraDB for MongoDB インスタンスに接続され、コレクションが作成されています。

   {
       "TableDescription": {
           "TableName": "student",
           "KeySchema": [
               {
                   "AttributeName": "name",
                   "KeyType": "HASH"
               },
               {
                   "AttributeName": "age",
                   "KeyType": "RANGE"
               }
           ],
           "TableStatus": "CREATING",
           "TableSizeBytes": 0,
           "ItemCount": 0
       }
   }
                           

Python を使用してインスタンスに接続する

• Python 2.6 以降がインストールされていること。 詳細については、Python の公式 Web サイトをご覧ください。

• Boto3 がインストールされていること。 詳細については、「Boto3 ドキュメント」をご参照ください。

import boto3

def create_book_table(dynamodb=None):
 if not dynamodb:
 dynamodb = boto3.resource('dynamodb', endpoint_url="http://dds-xxxx.mongodb.rds.aliyuncs.com:3717")
 table = dynamodb.create_table(
 TableName='Book',
 KeySchema=[
 {
 'AttributeName':'title',
 'KeyType':'HASH'
 },
 {
 'AttributeName':'year',
 'KeyType':'RANGE'
 }
 ],
 AttributeDefinitions=[
 {
 'AttributeName':'title',
 'AttributeType':'S'
 },
 {
 'AttributeName':'year',
 'AttributeType':'N'
 },
 ],
 ProvisionedThroughput={
 'ReadCapacityUnits':5,
 'WriteCapacityUnits':5
 }
 )
 return table

if __name__ == '__main__':
 book_table =create_book_table()
 print("Tablestatus:", book_table.table_status)

Java を使用してインスタンスに接続する

AWS SDK for Java をインストールします。 詳細については、「AWS SDK for Java 2.x のセットアップ」をご参照ください。

package com.amazonaws.codesamples.gsg;

import java.util.Arrays;
import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.document.DynamoDB;
import com.amazonaws.services.dynamodbv2.document.Table;
import com.amazonaws.services.dynamodbv2.model.AttributeDefinition;
import com.amazonaws.services.dynamodbv2.model.KeySchemaElement;
import com.amazonaws.services.dynamodbv2.model.KeyType;
import com.amazonaws.services.dynamodbv2.model.ProvisionedThroughput;
import com.amazonaws.services.dynamodbv2.model.ScalarAttributeType;

public class MoviesCreateTable {
 public static void main(String[] args) throws Exception {
 
        AmazonDynamoDB client =AmazonDynamoDBClientBuilder.standard()
            .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration("http://dds-xxxx.mongodb.rds.aliyuncs.com:3717",
"us-east-1"))
            .build();

 DynamoDB dynamoDB = new DynamoDB(client);

 String tableName ="Book";

 try {
 System.out.println("Creating table...");
 Table table =dynamoDB.createTable(tableName,
 Arrays.asList(new
KeySchemaElement("title", KeyType.HASH), // Partition key
 new KeySchemaElement("year", KeyType.RANGE)), // Sort key
 Arrays.asList(new AttributeDefinition("title", ScalarAttributeType.S),
 new AttributeDefinition("year", ScalarAttributeType.N)),
 new ProvisionedThroughput(5L, 5L));
 table.waitForActive();
System.out.println("OK. Table status: " + table.getDescription().getTableStatus());
 }
 catch (Exception e) {
System.err.println("Unable to create table: ");
System.err.println(e.getMessage());
 }
 }
}

他のプログラミング言語用 SDK を使用してインスタンスに接続する

詳細については、「DynamoDB と AWS SDK の使用開始」をご参照ください。