首页 > 解决方案 > AWS DynamoDB 使用 QueryAsync 而不是 ScanAsync

问题描述

在这里使用 .net core api (c#) 和 dynamodb。我的 dbmanager 类为:

public class DbManager<T> : DynamoDBContext, IDynamoDbManager<T> where T : class
{
    private DynamoDBOperationConfig _config;

    public DbManager(IAmazonDynamoDB client, string tableName) : base(client)
    {
        _config = new DynamoDBOperationConfig()
        {
            OverrideTableName = tableName
        };
    }

    public Task<List<T>> GetAsync(IEnumerable<ScanCondition> conditions)
    {
        return ScanAsync<T>(conditions, _config).GetRemainingAsync();
    }       
}

public interface IDbManager<T> : IDisposable where T : class
{
    Task<List<T>> GetAsync(IEnumerable<ScanCondition> conditions);
}

在我的控制器中:

  public class ValuesController : Controller
  {
      private readonly IDbManager<MyData> _dbManager;
      public ValuesController(IDbManager<MyData> dbManager)
      {
         _dbManager = dbManager;
      }

     [HttpGet()]
     [Route("sets/filter")]
     public async Task<IActionResult> GetAllData(string id, string name)
     {
        List<ScanCondition> conditions = new List<ScanCondition>();
        conditions.Add(new ScanCondition("Id", ScanOperator.Equal, id));
        conditions.Add(new ScanCondition("Name", ScanOperator.Equal, name));

        var response = await _dynamoDbManager.GetAsync(conditions);
        return Ok(response.ToList());           
     }    
  }

我上面的代码工作正常,只是当表中的数据变得太大时,操作变得很慢。有人告诉我要研究 QueryAsync 方法而不是 ScanAsync,因为 Scan 方法会扫描整个表并且速度很慢。

我查看了 QueryAsync 方法并检查它是否将 hashkey 作为参数之一。

我的问题是如何在上面的代码中使用 QueryAsync 而不是 ScanAsync。我正在从我的 UI 调用上述端点,它会将不同的参数传递给那里的扫描条件和过滤器。如何将这些条件传递给 QueryAsync 方法。

将不胜感激投入

标签: c#amazon-dynamodb

解决方案


你不能。Dynamo 查询至少需要您要查询的表或索引的哈希键。您不能查询任意属性。如果您需要支持您的选择是:

  1. 使用 Dynamo 扫描并接受性能和货币成本可能会低于可接受的水平
  2. 使用 Dynamo 作为记录数据库,但将数据复制到 AWS ElasticSearch 之类的东西中以启用随机查询
  3. 抛弃 Dynamo,只使用常规的关系数据库。RDS 支持许多不同的数据库类型
  4. 对您需要执行的常见查询进行分析,并在 Dynamo 中适当地为您的数据建模。这可能需要向表中添加额外的索引并使用不同的键多次复制数据以支持不同的查询类型。

推荐阅读