Как получить данные из AWS Dynamodb с использованием только ключа раздела?

Я использую библиотеку aws-sdk-go для подключения к DynamoDb в Голанге.

Моя таблица DynamoDb имеет ключ разделения DeviceId (строка) и время ключа сортировки (число). Как я могу написать GetItemInput, чтобы получить все данные с определенным DeviceId?

params := &dynamodb.GetItemInput{

    Key:    map[string]*dynamodb.AttributeValue {
        "DeviceId": {
            S: aws.String("item_1"),
        },
    },
    ExpressionAttributeNames: map[string]*string{
        "DeviceId": "DeviceId",
    },
    TableName:  aws.String("DbName"), 
}

list, err := svc.GetItem(params)

3 ответа

Решение

Вы должны использовать операцию Query или Scan, это простой пример, но вы можете прочитать больше о документации Amazon здесь

В частности, операция Query

Операция Query находит элементы в таблице или вторичном индексе, используя только значения атрибутов первичного ключа

var queryInput = &dynamodb.QueryInput{
    TableName: aws.String(dynamoRestDataTableName),
    KeyConditions: map[string]*dynamodb.Condition{
        "DeviceId": {
            ComparisonOperator: aws.String("EQ"),
            AttributeValueList: []*dynamodb.AttributeValue{
                {
                    S: aws.String("aDeviceId"),
                },
            },
        },
    },
}

var resp, err = dynamoSvc.Query(queryInput)
if err != nil {
    return nil, err
}

В этом случае можно использовать операцию запроса.
Ниже приводится общий пример того же

      compositeKey := entity.GetPrimaryKey(inputVar)
expressionAttributeValues := map[string]*dynamodb.AttributeValue{
    ":v1": {
        S: aws.String(compositeKey.PartitionKey.Data.(string)),
    },
}
queryInput := dynamodb.QueryInput{
    TableName:                 &d.TableName,
    KeyConditionExpression:    aws.String("id = :v1"),
    ExpressionAttributeValues: expressionAttributeValues,
}
queryOutput, err := d.DdbSession.Query(&queryInput)
if err != nil {
    log.Error("error in fetching records ", err)
    return nil, err
}

// unmarshal the query output - items to interface

err = dynamodbattribute.UnmarshalListOfMaps(queryOutput.Items, &yourInterface)

Вы можете использовать getItem в JavaScript SDK v2, как это

      const params = {
    TableName: 'tableName',
    Key: {
        id: { S: id },
    },
};

const result = await dynamoDb.getItem(params).promise();
if (result.Item === undefined) {
    throw new Error('not found');
}
const item = AWS.DynamoDB.Converter.unmarshall(result.Item)

Если JavaScript SDK может это сделать, я предполагаю, что golang SDK тоже может. Если нет, значит, AWS не поддерживает все языки одинаково?

Другие вопросы по тегам