c# - 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 方法。
将不胜感激投入
解决方案
你不能。Dynamo 查询至少需要您要查询的表或索引的哈希键。您不能查询任意属性。如果您需要支持您的选择是:
- 使用 Dynamo 扫描并接受性能和货币成本可能会低于可接受的水平
- 使用 Dynamo 作为记录数据库,但将数据复制到 AWS ElasticSearch 之类的东西中以启用随机查询
- 抛弃 Dynamo,只使用常规的关系数据库。RDS 支持许多不同的数据库类型
- 对您需要执行的常见查询进行分析,并在 Dynamo 中适当地为您的数据建模。这可能需要向表中添加额外的索引并使用不同的键多次复制数据以支持不同的查询类型。
推荐阅读
- c - 如何使用 Ethernet Shield 将数据从 Arduino Uno 发送到 MySQL 数据库
- laravel - Laravel 刀片:第一次加载页面时获取未定义的变量,刷新时它工作正常
- django - 通过传递字段名称而不是主 ID 获取模型实例
- php - 如何用 PHP 替换 SQL Server 显示的输出
- presto - Presto:如何填补空白并从前几行复制值
- react-native - React Native Expo 锁定屏幕方向但仍检测方向变化
- java - 如何将 postgresSql 查询重写为 Spring-data jpa 查询
- reactjs - 创建自定义钩子时反应 TypeError
- android - 使用 startActivityForResult() 时,我们是否还必须在后台保存资源清理的先前活动状态?
- python - 我是否需要刷新 sqlalchemy 连接对象才能将数据插入到新创建的表中?