c# Elasticsearch统计Nested的数据seo优化

c# Elasticsearch统计Nested的数据

news/2024/10/21 9:45:30

我是直接问百度ai

es统计是nested结构的数据，数据有年份：reportyear，名称：accountnamezh，类型：reportperiodtype，利润：originalvalue，，需要统计：2024年，名称：营业收入,类型：2，的利润合计是多少，利润金额比较大，需要除以100000000

然后生成的es是

POST /your_index/_search
{"query": {"bool": {"must": [{"nested": {"path": "financial_data","query": {"bool": {"must": [{ "term": { "financial_data.reportyear": 2024 } },{ "term": { "financial_data.accountnamezh": "营业收入" } },{ "term": { "financial_data.reportperiodtype": 2 } }]}}}}]}},"aggs": {"total_profit_in_millions": {"nested": {"path": "financial_data"},"aggs": {"sum_profit": {"sum": {"script": {"source": "doc['financial_data.originalvalue'].value / 100000000"}}}}}}
}

　　生成c#代码

using Nest;
using System;
using System.Threading.Tasks;public class ElasticsearchDocument
{public NestedField FinancialData { get; set; }
}public class FinancialData
{public int ReportYear { get; set; }public string AccountNameZh { get; set; }public int ReportPeriodType { get; set; }public double OriginalValue { get; set; }
}// 注意：这里的NestedField和Elasticsearch的嵌套字段类型相对应，
// 但实际上NEST中的NestedField通常用于查询时的映射，而不是文档模型的一部分。
// 在查询时，我们会用到一个与FinancialData结构相似的匿名类型来构建查询。
// 这里的模型主要是为了展示目的。class Program
{private static ElasticClient _client;static async Task Main(string[] args){_client = new ElasticClient(settings: new ConnectionSettings(new Uri("http://localhost:9200")));var response = await _client.SearchAsync<ElasticsearchDocument>(s => s.Index("your_index").Query(q => q.Nested(n => n.Path(p => p.FinancialData).Query(nq => nq.Bool(b => b.Must(m => m.Term(t => t.Field(f => f.FinancialData.ReportYear).Value(2024)).Term(t => t.Field(f => f.FinancialData.AccountNameZh).Value("营业收入")).Term(t => t.Field(f => f.FinancialData.ReportPeriodType).Value(2))))).Aggregations(a => a.Nested("total_profit_in_millions", n => n.Path(p => p.FinancialData).Aggregations(na => na.Sum("sum_profit", s => s.Script(sc => sc.Source("doc['financial_data.original_value'].value / 100000000"))))))).Size(0)); // 我们不需要实际的文档，只需要聚合结果// 处理响应if (response.IsValid){var totalProfitInMillions = response.Aggregations.Nested("total_profit_in_millions")?.Sum("sum_profit")?.Value;Console.WriteLine($"Total Profit in Millions: {totalProfitInMillions}");}else{Console.WriteLine("Search failed: " + response.ServerError.Error.Reason);}}
}