c# - Elasticsearch.NET 中的复合查询
问题描述
想象一下我有一个索引,里面有一堆Order
对象
class Order
{
int CustomerId { get; set; }
DateTime OrderDate { get; set; }
// Other fields
}
对于特定的客户 ID,我可以通过以下查询找出客户的最后一个订单:
IElasticClient client;
async Task<Order> GetLastOrder(int customerId)
{
var searchResponse = await client.SearchAsync<Order>(s => s
.Query(q => q
.Term(f => f
.Field(e => e.CustomerId)
.Term(customerId)) && q
.DateRange(r => r
.Field(e => e.OrderDate)
.LessThan(DateMath.Now)))
.Sort(o => o
.Descending(e => e.OrderDate))
.Size(1));
return searchResponse.ApiCall.Success
? searchResponse.Documents.First()
: null;
}
但是,为了支持数据加载器模式,我想查询由多个客户发出的最后一个订单,由一组客户 ID 给出。我是这样开始的:
async Task<IDictionary<int, Order>> GetLastOrders(IEnumerable<int> customerIds)
{
var searchResponse = await client.SearchAsync<Order>(s => s
.Query(q => q
.Terms(f => f
.Field(e => e.CustomerId)
.Terms(customerIds)) && q
.DateRange(r => r
.Field(e => e.OrderDate)
.LessThan(DateMath.Now)))
.Sort(o => o
.Descending(e => e.OrderDate))
.Size(1));
return searchResponse.ApiCall.Success
? searchResponse.Documents.ToDictionary(i => i.CustomerId)
: new Dictionary<string, Order>();
}
不幸的是,这不起作用,因为它只返回整个查询的第一条记录,它只会返回一个Order
. 如何修改此查询以针对Order
每个客户 ID 返回一个?
解决方案
折叠可用于返回字段的最高记录
await _client.SearchAsync<Order>(s => s
.Query(q => q
.Terms(f => f
.Field(e => e.CustomerId)
.Terms(cuIds)) && q
.DateRange(r => r
.Field(e => e.OrderDate)
.LessThan(DateMath.Now)))
.Sort(o => o
.Descending(e => e.OrderDate))
.Collapse(c => c.Field(e => e.CustomerId))
.Size(10)
);
DSL中的对应查询
{
"collapse": {
"field": "customerId"
},
"query": {
"bool": {
"must": [
{
"terms": {
"customerId": [
1,
2
]
}
},
{
"range": {
"orderDate": {
"lt": "now"
}
}
}
]
}
},
"size": 10,
"sort": [
{
"orderDate": {
"order": "desc"
}
}
]
}
推荐阅读
- c# - 如何加快 WinForms 中的自动完成
- c# - ASP.NET Core 和 Visual Studio 中的模型类
- javascript - 尝试从 API 解析和存储 JSON 数据时如何知道目标是什么
- docker - 在 GitLab 中使用 ElasticSearch,如果 ES Container 宕机了怎么办?
- android - 无法解析“:app@debug/compileClasspath”的依赖关系:无法解析com.android.volley:volley:1.1.1
- python - Python 2d 数组布尔减少
- ssis - 如何通过 SSIS 将所有表从 ODBC 源移动到 Access?
- postgresql - 有条件地更新 PostgreSQL 中 2 条记录中的值的有效方法
- swift - Swift:识别输入的字符是否按升序/降序排列
- javascript - 如何在 JSX 中重复一个元素?