将 KQL 转换为 C# 对象语法初始化器

问题描述

我有这个查询想要转换为 C# 嵌套查询，其中包含用于更新查询的术语过滤器和脚本子句，该查询在 Kibana Dev Tools 中运行良好，但无法在嵌套 C# 对象初始值设定项语法中进行转换。

POST acquiringdata/_update_by_query
{
  "script": {
    "inline": "ctx._source.Address = 'FORTRESS STADIUM GROUND FLOOR OPPOSITE_TestasadasD2'","lang": "painless"
  },"query": {
    "bool": {
      "must": [
        {
          "term": {
            "PaymentTransactionID": {
              "value": "58804121"
            }
          }
        }
      ]
    }
  }
}

此代码的结论到此为止

var filterClause = new List<QueryContainer>();
//  var ScriptClause = new List<ScriptQueryContainer>();
filterClause.Add(new TermQuery
        {
            Field = new Field("PaymentTransactionID"),Value = transaction.PaymentTransactionID,});

string _templateString = "ctx._source.Address = 'FORTRESS STADIUM GROUND FLOOR OPPOSITE_TestasadasD2'";

// ScriptClause.Add(new ScriptQuery{
//    Name = "named_query",//    Boost = 1.1,//    Script = new Inlinescript(_templateString)
//    {
//        Params = new Dictionary<string,object> {
//      { "ctx._source.Address","123" }
//        }
//    }
//});

var SearchRequest = new SearchRequest<NewIndexClass>(NewTestingIndex)
        {
            Size = 1000,Query = new BoolQuery
            {
                Must = filterClause,}
        };

var searchResponse = _elasticclient.Search<NewIndexClass>(SearchRequest);

if (searchResponse.ApiCall.ResponseBodyInBytes != null)
{
    var requestJson = System.Text.Encoding.UTF8.GetString(searchResponse.ApiCall.RequestBodyInBytes);
    var JsonFormatQuery = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(requestJson),Formatting.Indented);
}

无需脚本查询即可实现此输出。

GET _search
{
  "query": {
    "bool": {
      "must": [
        {
          "term": {
            "PaymentTransactionID": {
              "value": "58804121"
            }
          }
        }
      ]
    }
  },"size": 1000
}

将其转换为脚本查询的任何帮助将不胜感激。

解决方法

我已经做到了

  transaction.Address = "'" + transaction.Address + "'";

                var scriptParams = new Dictionary<string,object>
                    {
                        { nameof(NewIndexClass.Address),transaction.Address}
                    };
                var script = $"ctx._source.Address=" + transaction.Address;
                var searchResponse = _elasticClient.UpdateByQuery<NewIndexClass>(qd =>
                          qd.Index(NewTestingIndex)
                          .Conflicts(Conflicts.Proceed)
                          .Query(rq => rq.Term("PaymentTransactionID",transaction.PaymentTransactionID))
                          .Script(s => s
                              .Source(script)
                               .Params(scriptParams)
                              )
                             );


                if (searchResponse.ApiCall.ResponseBodyInBytes != null)
                {
                    var requestJson = System.Text.Encoding.UTF8.GetString(searchResponse.ApiCall.RequestBodyInBytes);
                    var JsonFormatQuery = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(requestJson),Formatting.Indented);
                }