Создание таблицы в AWS SDK

В коде ниже используется функция print из Python 3. Для использования этой функции в версиях Python 2.6 и старше добавьте в начало файла строку from __future__ import print_function.

1. Создайте файл SeriesCreateTable.py, например с помощью редактора nano:

   nano SeriesCreateTable.py
   

   Скопируйте в созданный файл следующий код:

   Важно

   Вместо <Document_API_эндпоинт> укажите подготовленное ранее значение.

   import boto3
   
   def create_series_table():
       ydb_docapi_client = boto3.resource('dynamodb', endpoint_url = "<Document_API_эндпоинт>")
   
       table = ydb_docapi_client.create_table(
           TableName = 'Series', # Series — имя таблицы 
           KeySchema = [
               {
                   'AttributeName': 'series_id',
                   'KeyType': 'HASH'  # Ключ партицирования
               },
               {
                   'AttributeName': 'title',
                   'KeyType': 'RANGE'  # Ключ сортировки
               }
           ],
           AttributeDefinitions = [
               {
                   'AttributeName': 'series_id',
                   'AttributeType': 'N'  # Целое число
               },
               {
                   'AttributeName': 'title',
                   'AttributeType': 'S'  # Строка
               },
   
           ]
       )
       return table
   
   if __name__ == '__main__':
       series_table = create_series_table()
       print("Статус таблицы:", series_table.table_status)
   

2. Запустите программу:

   python SeriesCreateTable.py
   

   Результат:

   Статус таблицы: ACTIVE
   

1. Создайте файл SeriesCreateTable.php, например с помощью редактора nano:

   nano SeriesCreateTable.php
   

   Скопируйте в созданный файл следующий код:

   Важно

   Вместо <Document_API_эндпоинт> укажите подготовленное ранее значение.

   <?php
   
   require 'vendor/autoload.php';
   
   date_default_timezone_set('UTC');
   
   use Aws\DynamoDb\Exception\DynamoDbException;
   
   $sdk = new Aws\Sdk([
       'endpoint' => '<Document_API_эндпоинт>',
       'region'   => 'ru-central1',
       'version'  => 'latest'
   ]);
   
   $dynamodb = $sdk->createDynamoDb();
   
   $params = [
       'TableName' => 'Series',
       'KeySchema' => [
           [
               'AttributeName' => 'series_id',
               'KeyType' => 'HASH'
           ],
           [
               'AttributeName' => 'title',
               'KeyType' => 'RANGE'
           ]
       ],
       'AttributeDefinitions' => [
           [
               'AttributeName' => 'series_id',
               'AttributeType' => 'N'
           ],
           [
               'AttributeName' => 'title',
               'AttributeType' => 'S'
           ],
       ]
   ];
   
   try {
       $result = $dynamodb->createTable($params);
       echo 'Статус таблицы: ' . 
           $result['TableDescription']['TableStatus'] ."\n";
   
   } catch (DynamoDbException $e) {
       echo "Невозможно создать таблицу:\n";
       echo $e->getMessage() . "\n";
   }
   
   ?>
   

2. Запустите программу:

   php SeriesCreateTable.php
   

   Результат:

   Статус таблицы: ACTIVE
   

1. Создайте файл SeriesCreateTable.js, например с помощью редактора nano:

   nano SeriesCreateTable.js
   

   Скопируйте в созданный файл следующий код:

   Важно

   Вместо <Document_API_эндпоинт> укажите подготовленное ранее значение.

   const AWS = require("@aws-sdk/client-dynamodb");
   
   // Credentials should be defined via environment variables AWS_SECRET_ACCESS_KEY and AWS_ACCESS_KEY_ID
   const dynamodb = new AWS.DynamoDBClient({
       region: "ru-central1",
       endpoint: "<Document_API_эндпоинт>",
   });
   
   dynamodb.send(new AWS.CreateTableCommand({
       TableName : "Series",
       KeySchema: [
           { AttributeName: "series_id", KeyType: "HASH"},
           { AttributeName: "title", KeyType: "RANGE" }
       ],
       AttributeDefinitions: [
           { AttributeName: "series_id", AttributeType: "N" },
           { AttributeName: "title", AttributeType: "S" }
       ]
   }))
       .then(data => {
           console.log("Таблица создана. Схема таблицы JSON:", JSON.stringify(data, null, 2));
       })
       .catch(err => {
           console.error("Не удалось создать таблицу. Ошибка JSON:", JSON.stringify(err, null, 2));
       })
   

2. Запустите программу:

   node SeriesCreateTable.js
   

   Результат:

   Таблица создана. Схема таблицы JSON: {
     "TableDescription": {
       "AttributeDefinitions": [
         {
           "AttributeName": "series_id",
           "AttributeType": "N"
         },
         {
           "AttributeName": "title",
           "AttributeType": "S"
         }
       ],
       "TableName": "Series",
       "KeySchema": [
         {
           "AttributeName": "series_id",
           "KeyType": "HASH"
         },
         {
           "AttributeName": "title",
           "KeyType": "RANGE"
         }
       ],
       "TableStatus": "ACTIVE",
       "CreationDateTime": "2021-06-14T19:34:32.000Z",
       "TableSizeBytes": 0,
       "ItemCount": 0
     }
   }
   

1. Создайте файл SeriesCreateTable.rb, например с помощью редактора nano:

   nano SeriesCreateTable.rb
   

   Скопируйте в созданный файл следующий код:

   Важно

   Вместо <Document_API_эндпоинт> укажите подготовленное ранее значение.

   require 'aws-sdk-dynamodb'
   
   def create_table(dynamodb_client, table_definition)
     response = dynamodb_client.create_table(table_definition)
     response.table_description.table_status
   rescue StandardError => e
     puts "Ошибка создания таблицы: #{e.message}"
     'Error'
   end
   
   def run_me
     region = 'ru-central1'
   
     Aws.config.update(
       endpoint: '<Document_API_эндпоинт>',
       region: region
     )
   
     dynamodb_client = Aws::DynamoDB::Client.new
   
     table_definition = {
       table_name: 'Series',
       key_schema: [
         {
           attribute_name: 'series_id',
           key_type: 'HASH'  # Ключ раздела.
         },
         {
           attribute_name: 'title',
           key_type: 'RANGE' # Ключ сортировки.
         }
       ],
       attribute_definitions: [
         {
           attribute_name: 'series_id',
           attribute_type: 'N'
         },
         {
           attribute_name: 'title',
           attribute_type: 'S'
         }
       ]
     }
   
     puts "Создание таблицы 'Series'..."
     create_table_result = create_table(dynamodb_client, table_definition)
   
     if create_table_result == 'Ошибка'
       puts 'Не удалось создать таблицу.'
     else
       puts "Таблица создана. Статус: '#{create_table_result}'."
     end
   end
   
   run_me if $PROGRAM_NAME == __FILE__
   

2. Запустите программу:

   ruby SeriesCreateTable.rb
   

   Результат:

   Создание таблицы 'Series'...
   Таблица создана. Статус: 'ACTIVE'.