Dynamodb- Добавление неключевых атрибутов

Question

Я хочу, чтобы вставить данные в DynamoD локальный. Однако у меня есть только один ключевой атрибут и несколько неключевых атрибутов.

{
    'id':'99876983ydbhdu3739',
    'category':'Spa',
    'latitude':'33.498',
    'longitude':'32.332',
    'name':'Studio'
}  

У меня есть несколько таких значений. Это одна запись, пример того, что я хочу вставить. Вот что я пытаюсь сделать:

table = dynamodb.create_table(
    TableName='Trial',
    KeySchema=[
        {
            'AttributeName': 'facebook_id',
            'KeyType': 'HASH'  #Sort key
        },
        {
            'AttributeName': 'latitude',
            'KeyType': 'RANGE'  #Sort key
        },

    ],
    AttributeDefinitions=[
         {
            'AttributeName':'id',
            'AttributeType':'S'
        },
        {
            'AttributeName': 'category',
            'AttributeType': 'S'
        },
        {
            'AttributeName': 'latitude',
            'AttributeType': 'S'
        },
        {
            'AttributeName': 'longitude',
            'AttributeType': 'S'
        },
        {
            'AttributeName': 'name',
            'AttributeType':'S'
        }

    ],
    ProvisionedThroughput={
        'ReadCapacityUnits': 10,
        'WriteCapacityUnits': 10
    }
)

Я получаю следующую ошибку:

Произошла ошибка (ValidationException) при вызове операции CreateTable: количество атрибутов в схеме ключей должно совпадать с количеством атрибутов, определенных в определениях атрибутов.

Answer 1

При создании таблицы вы можете просто создать таблицу только с ключевыми атрибутами HASH и RANGE. DynamoDB не ожидает определения всех других атрибутов, так как DynamoDB - это таблица пар ключ-значение. Пожалуйста, попробуйте следующий код. Вы должны быть в состоянии создать таблицу.

При вставке элемента, вы можете включить любые атрибуты согласно вашему требованию.

Создать таблицу:-

var AWS = require("aws-sdk");

AWS.config.update({
    region : "us-west-2",
    endpoint : "http://localhost:8000"
});

var dynamodb = new AWS.DynamoDB();

var params = {
    TableName : "Trail",
    KeySchema : [ {
        AttributeName : "facebook_id",
        KeyType : "HASH"
    }, //Partition key
    {
        AttributeName : "latitude",
        KeyType : "RANGE"
    } //Sort key
    ],
    AttributeDefinitions : [ {
        AttributeName : "facebook_id",
        AttributeType : "N"
    }, {
        AttributeName : "latitude",
        AttributeType : "S"
    } ],
    ProvisionedThroughput : {
        ReadCapacityUnits : 10,
        WriteCapacityUnits : 10
    }
};

dynamodb.createTable(params, function(err, data) {
    if (err) {
        if (err.code === "ResourceInUseException"
                && err.message === "Cannot create preexisting table") {
            console.log("message ====>" + err.message);
        } else {
            console.error("Unable to create table. Error JSON:", JSON
                    .stringify(err, null, 2));
        }

    } else {
        console.log("Created table. Table description JSON:", JSON.stringify(
                data, null, 2));
    }
});

Создать элемент:-

var AWS = require("aws-sdk");

AWS.config.update({
    region : "us-west-2",
    endpoint : "http://localhost:8000"
});

var docClient = new AWS.DynamoDB.DocumentClient();

var table = "Trail";

var params = {
    TableName : table,
    Item : {
        "facebook_id" : 1,
        "latitude" : 'lat',
        "longitude" : 'long',
        "name" : 'facebook',
        "category" : 'social_media'
    }
};

console.log("Adding a new item...");
docClient.put(params, function(err, data) {
    if (err) {
        console.error("Unable to add item. Error JSON:", JSON.stringify(err,
                null, 2));
    } else {
        console.log("Added item:", JSON.stringify(data, null, 2));
    }
});

Answer 2

Для пользователей Boto3 в Python:

ddb_client.create_table(
    TableName=DDB_TABLE_NAME,
    AttributeDefinitions=[
        {
            'AttributeName': 'id',
            'AttributeType': 'S'
        },
        {
            'AttributeName': 'latitude',
            'AttributeType': 'S'
        },
    ],
    KeySchema=[
        {
            'AttributeName': 'id',
            'KeyType': 'HASH'
        },
        {
            'AttributeName': 'latitude',
            'KeyType': 'RANGE'
        }
    ],
    BillingMode='<your_value>'
)


response = ddb_client.put_item(
    TableName=DDB_TABLE_NAME,
    Item={
        'id': {'S': '1'},
        'latitude': {'S': '33.498'},
        'longitude': {'S': '32.332'},
        'category': {'S': 'Spa'},
        'name': {'S': 'Studio'}
    }
)