Добавление записи

Статья создана

Yandex Cloud

Обновлена 4 октября 2024 г.

Чтобы добавить новую запись в таблицу Series:

Java

Python

PHP

Node.js

Ruby

Создайте проект SeriesItemOps01:
```
mvn -B archetype:generate \
  -DarchetypeGroupId=org.apache.maven.archetypes \
  -DgroupId=com.mycompany.app \
  -DartifactId=SeriesItemOps01
```
В результате выполнения команды в текущем рабочем каталоге будет создан каталог проекта с именем SeriesItemOps01, структурой подкаталогов и файлом описания проекта pom.xml.
Перейдите в каталог проекта:
```
cd SeriesItemOps01
```

Отредактируйте описание проекта в файле pom.xml, например с помощью редактора nano:

nano pom.xml

Пример файла pom.xml:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.mycompany.app</groupId>
  <artifactId>SeriesItemOps01</artifactId>
  <packaging>jar</packaging>
  <version>1.0-SNAPSHOT</version>
  <name>SeriesItemOps01</name>
  <url>http://maven.apache.org</url>
  <build>
      <plugins>
          <plugin>
              <groupId>org.apache.maven.plugins</groupId>
              <artifactId>maven-jar-plugin</artifactId>
              <configuration>
                  <archive>
                      <manifest>
                          <addClasspath>true</addClasspath>
                          <classpathPrefix>lib/</classpathPrefix>
                          <mainClass>com.mycompany.app.SeriesItemOps01</mainClass>
                      </manifest>
                      <manifestEntries>
                          <Class-Path>.</Class-Path>
                      </manifestEntries>
                  </archive>
                  <finalName>release/SeriesItemOps01</finalName>
              </configuration>
          </plugin>
          <plugin>
              <groupId>org.apache.maven.plugins</groupId>
              <artifactId>maven-dependency-plugin</artifactId>
              <executions>
                  <execution>
                      <id>copy-dependencies</id>
                      <phase>prepare-package</phase>
                      <goals>
                          <goal>copy-dependencies</goal>
                      </goals>
                      <configuration>
                          <outputDirectory>${project.build.directory}/release/lib</outputDirectory>
                          <overWriteReleases>false</overWriteReleases>
                          <overWriteSnapshots>false</overWriteSnapshots>
                          <overWriteIfNewer>true</overWriteIfNewer>
                      </configuration>
                  </execution>
              </executions>
          </plugin>
      </plugins>
  </build>
  <dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.13.1</version>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-java-sdk-dynamodb</artifactId>
      <version>1.11.1012</version>
    </dependency>
  </dependencies>
  <properties>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
  </properties>
</project>

Посмотрите актуальные версии junit и aws-java-sdk-dynamodb.

В каталоге src/main/java/com/mycompany/app/ создайте файл SeriesItemOps01.java, например с помощью редактора nano:

nano src/main/java/com/mycompany/app/SeriesItemOps01.java

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

Важно

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

package com.mycompany.app;

import java.util.HashMap;
import java.util.Map;

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.Item;
import com.amazonaws.services.dynamodbv2.document.PutItemOutcome;
import com.amazonaws.services.dynamodbv2.document.Table;

public class SeriesItemOps01 {

    public static void main(String[] args) throws Exception {

        AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard()
            .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration("<Document_API_эндпоинт>", "ru-central1"))
            .build();

        DynamoDB dynamoDB = new DynamoDB(client);

        Table table = dynamoDB.getTable("Series");

        int series_id = 3;
        String title = "Supernatural";

        final Map<String, Object> infoMap = new HashMap<String, Object>();
        infoMap.put("release_date", "2015-09-13");
        infoMap.put("series_info", "Supernatural is an American television series created by Eric Kripke");

        try {
            System.out.println("Добавление новой записи...");
            PutItemOutcome outcome = table
              .putItem(new Item().withPrimaryKey("series_id", series_id, "title", title).withMap("info", infoMap));

            System.out.println("Сериал успешно добавлен:\n" + outcome.getPutItemResult());

        }
        catch (Exception e) {
            System.err.println("Невозможно добавить запись: " + series_id + " " + title);
            System.err.println(e.getMessage());
        }

    }
}

Этот код добавляет запись с первичным ключом (series_id, title) и дополнительной информацией в поле info. Первичный ключ обязателен.

Соберите проект:
```
mvn package
```
В результате выполнения команды в каталоге target/release/ будет сгенерирован файл SeriesItemOps01.jar.

Запустите приложение:

java -jar target/release/SeriesItemOps01.jar

Результат:

Добавление новой записи...
Сериал успешно добавлен:
{}

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

nano SeriesItemOps01.py

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

Важно

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

from pprint import pprint
import boto3

def put_serie(series_id, title, release_date, series_info):
    ydb_docapi_client = boto3.resource('dynamodb', endpoint_url = "<Document_API_эндпоинт>")

    table = ydb_docapi_client.Table('Series')
    response = table.put_item(
      Item = {
            'series_id': series_id,
            'title': title,
            'info': {
                'release_date': release_date,
                'series_info': series_info
            }
        }
    )
    return response

if __name__ == '__main__':
    serie_resp = put_serie(3, "Supernatural", "2015-09-13",
                          "Supernatural is an American television series created by Eric Kripke")
    print("Сериал успешно добавлен:")
    pprint(serie_resp, sort_dicts = False)

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

python SeriesItemOps01.py

Результат:

Сериал успешно добавлен:
{'ResponseMetadata': {'HTTPStatusCode': 200,
                      'HTTPHeaders': {'content-type': 'application/x-amz-json-1.0',
                                      'x-amz-crc32': '2745614147',
                                      'x-request-id': '92a5fafe-169c-48e8-8071-4f8c8cca7004',
                                      'date': 'Sat, 26 Dec 2020 17:21:01 GMT',
                                      'content-length': '2'},
                      'RetryAttempts': 0}}

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

nano SeriesItemOps01.php

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

Важно

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

<?php

require 'vendor/autoload.php';

date_default_timezone_set('UTC');

use Aws\DynamoDb\Exception\DynamoDbException;
use Aws\DynamoDb\Marshaler;

$sdk = new Aws\Sdk([
    'endpoint' => '<Document_API_эндпоинт>',
    'region'   => 'ru-central1',
    'version'  => 'latest'
]);

$dynamodb = $sdk->createDynamoDb();
$marshaler = new Marshaler();

$tableName = 'Series';

$series_id = 3;
$title = 'Supernatural';

$item = $marshaler->marshalJson('
    {
        "series_id": ' . $series_id . ',
        "title": "' . $title . '",
        "info": {
            "release_date": "2015-09-13",
            "series_info": "Supernatural is an American television series created by Eric Kripke"
        }
    }
');

$params = [
    'TableName' => 'Series',
    'Item' => $item
];


try {
    $result = $dynamodb->putItem($params);
    echo "Сериал успешно добавлен: $series_id - $title\n";

} catch (DynamoDbException $e) {
    echo "Невозможно добавить запись:\n";
    echo $e->getMessage() . "\n";
}

?>

Этот код добавляет запись с первичным ключом (series_id, title) и атрибутом info. Атрибут info содержит запись JSON с дополнительной информацию о фильме. Первичный ключ обязателен.

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

php SeriesItemOps01.php

Результат:

Сериал успешно добавлен: 3 - Supernatural

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

nano SeriesItemOps01.js

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

Важно

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

const AWS = require("@aws-sdk/client-dynamodb");
const { marshall } = require("@aws-sdk/util-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_эндпоинт>",
});

const table = "Series";
const series_id = 3;
const title = "Supernatural";

const params = {
    TableName: table,
    Item: marshall({
        "series_id": series_id,
        "title": title,
        "info":{
            "release_date": "2015-09-13",
            "series_info": "Supernatural is an American television series created by Eric Kripke"
        }
    })
};

console.log("Добавление новой записи...");

dynamodb.send(new AWS.PutItemCommand(params))
    .then(data => {
        console.log("Сериал успешно добавлен:", JSON.stringify(data, null, 2));
    })
    .catch(err => {
        console.error("Не удалось добавить запись. Ошибка JSON:", JSON.stringify(err, null, 2));
    })

Первичный ключ обязателен. Этот код добавляет запись, которая имеет первичный ключ (series_id, title) и атрибуты внутри info. Блок info хранит JSON, который предоставляет дополнительную информацию о сериале.

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

node SeriesItemOps01.js

Результат:

Добавление новой записи...
Сериал успешно добавлен: {}

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

nano SeriesItemOps01.rb

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

Важно

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

require 'aws-sdk-dynamodb'

def add_item_to_table(dynamodb_client, table_item)
  dynamodb_client.put_item(table_item)
  puts "Загружен '#{table_item[:item][:title]} " \
    "(#{table_item[:item][:series_id]})'."
rescue StandardError => e
  puts "Ошибка загрузки сериала '#{table_item[:item][:title]} " \
    "(#{table_item[:item][:series_id]})': #{e.message}"
end

def run_me
  region = 'ru-central1'
  table_name = 'Series'
  title = 'Supernatural'
  series_id = 3

  Aws.config.update(
    endpoint: '<Document_API_эндпоинт>',
    region: region
  )

  dynamodb_client = Aws::DynamoDB::Client.new

  item = {
    series_id: series_id,
    title: title,
    info: {
      release_date: '2015-09-13',
      series_info: "Supernatural is an American television series created by Eric Kripke"
    }
  }

  table_item = {
    table_name: table_name,
    item: item
  }

  puts "Загрузка сериала '#{item[:title]} (#{item[:series_id]})' " \
    "в таблицу '#{table_name}'..."
  add_item_to_table(dynamodb_client, table_item)
end

run_me if $PROGRAM_NAME == __FILE__

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

ruby SeriesItemOps01.rb

Результат:

Загрузка сериала 'Supernatural (3)' в таблицу 'Series'...
Загружен 'Supernatural (3)'.

Добавление записи

Была ли статья полезна?