AWS SDK .NET DynamoDB ASYNC - PullRequest
Новая
       22

AWS SDK .NET DynamoDB ASYNC

0 голосов
/ 13 сентября 2018

Я пытаюсь использовать AWS SDK для .NET Core.

  • Создание таблицы для подсчета просмотров видео.
  • Добавление количества просмотров за день.
  • Увеличить существующий счет за день.
  • Запрос количества видео между двумя датами для видео.

.NET Core AWS SDK использует асинхронные методы, которые не описаны в AWS. На их странице github есть запрос на добавление функций, но он датирован прошлым годом. (https://github.com/aws/aws-sdk-net/issues/787)

СОЗДАТЬ СТОЛ

Это работает и создает таблицу на консоли AWS. 

var ctRequest = new CreateTableRequest
{
    AttributeDefinitions = new List<AttributeDefinition>()
    {
        new AttributeDefinition
        {
            AttributeName = "ViewUid",
            AttributeType = ScalarAttributeType.S
        },
        new AttributeDefinition
        {
            AttributeName = "ViewDate",
            AttributeType = ScalarAttributeType.S
        }
    },
    KeySchema = new List<KeySchemaElement>
    {
        new KeySchemaElement
        {
            AttributeName = "ViewUid",
            KeyType = KeyType.HASH //Partition key
        },
        new KeySchemaElement
        {
            AttributeName = "ViewDate",
            KeyType = KeyType.RANGE
        }
    },
    ProvisionedThroughput = new ProvisionedThroughput
    {
        ReadCapacityUnits = 5,
        WriteCapacityUnits = 6
    },
    TableName = _settings.AWSDynamoDBViewCountTable
};

var response = _client.CreateTableAsync(ctRequest).Result;

ОБНОВЛЕНИЕ И ПУНКТ С АВТО-УВЕЛИЧЕНИЕМ ПОЛЯ

К сожалению, именно здесь я сталкиваюсь с проблемами. Старые документы находятся здесь, в разделе «Атомный счетчик». (https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/LowLevelDotNetItemCRUD.html)

Неверное выражение условия: синтаксическая ошибка; токен: \ "SET \", рядом: \ "SET VC \ "

var viewData = new Document();
viewData["ViewUid"] = videoUid; //Table entry UID
viewData["VideoId"] = videoId;  // Video ID
viewData["ViewDate"] = date;
viewData["ViewCount"] = 0;
//Document result = await _viewCountTable.PutItemAsync(viewData);

Expression expr = new Expression();
expr.ExpressionStatement = "SET #VC = #VC + :val";
expr.ExpressionAttributeValues[":val"] = 1;
expr.ExpressionAttributeNames["#VC"] = "ViewCount";
var updateConfig = new UpdateItemOperationConfig() { 
    ConditionalExpression = expr,
    ReturnValues = ReturnValues.UpdatedNewAttributes
};

var result = await _viewCountTable.UpdateItemAsync(viewData, updateConfig);
return result;

ЗАПРОС НА ДИАПАЗОН ДАТЫ

Получить количество просмотров одного видео для диапазона дат. 

string queryTimeSpanStartString = dateFrom.ToString(AWSSDKUtils.ISO8601DateFormat);
string queryTimeSpanEndString = dateTo.ToString(AWSSDKUtils.ISO8601DateFormat);
var request = new QueryRequest
{
    TableName = _settings.AWSDynamoDBViewCountTable,
    KeyConditions = new Dictionary<string, Condition>()
    {
        {
            "VideoId",  new Condition()
            {
                ComparisonOperator = "EQ",
                AttributeValueList = new List<AttributeValue>()
                {
                    new AttributeValue { S = videoId }
                }
            }
        },
        {
            "ViewDate",
            new Condition
            {
                ComparisonOperator = "BETWEEN",
                AttributeValueList = new List<AttributeValue>()
                {
                    new AttributeValue { S = queryTimeSpanStartString },
                    new AttributeValue { S = queryTimeSpanEndString }
                }
            }
        }
    }
};

var response = await _client.QueryAsync(request);

Любая помощь будет оценена.

1 Ответ

0 голосов
/ 14 сентября 2018

Мне удалось обновить ViewCount с помощью следующего кода:

string tableName = "videos"; 

        var request = new UpdateItemRequest
        {
            Key = new Dictionary<string, AttributeValue>() { { "ViewUid", new AttributeValue { S = "replaceVideoIdhere" } } },
            ExpressionAttributeNames = new Dictionary<string, string>()
            {
                {"#Q", "ViewCount"}
            },
            ExpressionAttributeValues = new Dictionary<string, AttributeValue>()
            {
                {":incr", new AttributeValue {N = "1"}}
            },
            UpdateExpression = "SET #Q = #Q + :incr",
            TableName = tableName
        };

        var response = await _dynamoDbClient.UpdateItemAsync(request);

Я создал таблицу под названием "videos" с ключом раздела с именем"ViewUid" в виде строки.Дайте мне знать, если это работает для вас.

...