问题描述
好的,我有一个奇怪的问题,我不确定这是否只是因为它们是函子,而函子对我来说还是很新的(函子的整个概念使我有些恼火)。
我需要调用完全相同的查询两次,因为我需要2个图形/数据集。每个参数一个。因为我不想重复查询,所以我在类中添加了func参数,因此我可以在类中强类型选择正确的属性。
SearchDescriptor<Stats> Query(SearchDescriptor<Stats> qc,Func<Stats,double> field)
{
var query = qc
.Aggregations(aggs => aggs
.DateHistogram("histogram",d => d
.Field(f => f.Timestamp)
.FixedInterval("30m")
.MinimumDocumentCount(1)
.Aggregations(childAggs => childAggs
.Average("3",f => f
.Field(fi => field(fi))
)
)
)
)
.Query(q =>
q.Bool(b =>
b.Filter(
f => f.MatchPhrase(mp => mp
.Field(fi => fi.Name)
.Query(name)
),f => f.Daterange(r => r
.Field(fi => fi.Timestamp)
.GreaterThanorEquals(DateTime.UtcNow.AddDays(-1))
.LessthanorEquals(DateTime.UtcNow)
)
)
)
);
return query;
}
var cpu = await GetByScrolling<Stats>(client,qc => Query(qc,fi => fi.cpuPercent));
var memory = await GetByScrolling<Stats>(client,fi => fi.MemoryUsage));
这可以编译并且可以工作,但是不幸的是,生成的JSON如下所示:
"aggs": {
"3": {
"avg": {
"field": "field"
}
}
}
如您所见,该值为field
,这绝对是错误的。就像nesT的内部部分会对存在的任何参数进行某种.ToString()
一样,这就是为什么它返回field
而不是我放入函数的原因。
知道这应该是这样吗?我的JSON中的aggs
也对应于.Aggregations(aggs => aggs
lambda命名。
解决方法
嗯,就像我说的那样,我是func的新手,也是SearchDescriptor<Stats> Query(SearchDescriptor<Stats> qc,Expression<Func<Stats,double>> field)
{
......
}
的新手,事实证明我是需要的。它实际上并没有评估功能-我需要给它一个表达式。
.Average("3",f => f
.Field(field)
)
,然后为其指定表达式:
library(ggplot2)
library(dplyr)
#Data
dfcsv1 <- read.csv('29899134-80c1-41bf-86cc-340577ab1021.csv',stringsAsFactors = F,encoding = 'UTF-8')
dfcsv2 <- read.csv('dbc2b22c-96a2-4eb2-b4c7-4230c87f26af.csv',encoding = 'UTF-8')
然后它会对其进行评估并完美运行。