ElasticSearch DSL Script使用案例分享-阿里云开发者社区

开发者社区> bboss> 正文

ElasticSearch DSL Script使用案例分享

简介: the best elasticsearch highlevel java rest api-----bboss       ElasticSearch DSL Script使用案例分享,涉及到的功能点: 脚本片段使用 多行文本使用 添加属性字段 1前言 先看看elastics...
+关注继续查看
the best elasticsearch highlevel java rest api-----bboss      

ElasticSearch DSL Script使用案例分享,涉及到的功能点:

  • 脚本片段使用
  • 多行文本使用
  • 添加属性字段

1前言
先看看elasticsearch官方的script dsl块文本的写法:通过一对"""   """来包含块文本
{
  "query": {
    "function_score": {
      "script_score": {
        "script": {
          "lang": "painless",
          "source": """
            int total = 0;
            for (int i = 0; i < doc['goals'].length; ++i) {
              total += doc['goals'][i];
            }
            return total;
          """
        }
      }
    }
  }
}

对应的bboss script dsl块文本的写法:通过一对@"""   """来包含块文本

{
  "query": {
    "function_score": {
      "script_score": {
        "script": {
          "lang": "painless",
          "source": @"""
            int total = 0;
            for (int i = 0; i < doc['goals'].length; ++i) {
              total += doc['goals'][i];
            }
            return total;
          """
        }
      }
    }
  }
}

bboss中管理的dsl块文本和elasticsearch官方的dsl中的块文本唯一的区别就是在开头的"""前面加了个@符号

2.定义dsl配置
在demo.xml文件中增加以下配置
    <property name="scriptPianduan">
        <![CDATA[
            "params": {
              "last": #[last],
              "nick": #[nick]
            }
        ]]>
    </property>
    <property name="scriptDsl">
        <![CDATA[{
          "script": {
            "lang": "painless",
            "source": @"""  ##块文本开始
              ctx._source.last = params.last;
              ctx._source.nick = params.nick
            """,##块文本结束
            @{scriptPianduan}
          }
        }]]>
    </property>

2.执行脚本处理
定义类ScriptImpl,增加方法updateDocumentByScriptPath来执行脚本
package org.bboss.elasticsearchtest.script;
/*
 *  Copyright 2008 biaoping.yin
 *
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */

import org.bboss.elasticsearchtest.crud.DocumentCRUD;
import org.frameworkset.elasticsearch.ElasticSearchHelper;
import org.frameworkset.elasticsearch.client.ClientInterface;

import java.util.HashMap;
import java.util.Map;

public class ScriptImpl {
	private String mappath = "esmapper/demo.xml";

	public void updateDocumentByScriptPath(){
		//初始化数据,会创建type为demo的indice demo,并添加docid为2的文档
		DocumentCRUD documentCRUD = new DocumentCRUD();
		documentCRUD.testCreateIndice();
		documentCRUD.testBulkAddDocument();
		//创建加载配置文件的客户端工具,用来检索文档,单实例多线程安全
		ClientInterface clientUtil = ElasticSearchHelper.getConfigRestClientUtil(mappath);
		Map<String,Object> params = new HashMap<String,Object>();
		//为id为2的文档增加last和nick两个属性
		params.put("last","gaudreau");
		params.put("nick","hockey");
        //通过script脚本为文档id为2的文档增加last和nick两个属性,为了演示效果强制refresh,实际环境慎用
		clientUtil.updateByPath("demo/demo/2/_update?refresh","scriptDsl",params);
        //获取更新后的文档,会看到新加的2个字段属性
		String doc = clientUtil.getDocument("demo","demo","2");
		System.out.println(doc);

	}
}


3.一个比较复杂Script的案例
<property name="updateStoreProductDynamicTemplate">
        <![CDATA[
        {
          "query": {
            "bool": {
              "must": [
                {
                  "term": {
                    "_id": #[id]
                  }
                }
              ]
            }
          },
          "script": {
            "lang": "painless",
            "source": @"""
                ctx._source.is_expired_dynamic_price=params.is_expired_dynamic_price;
                ctx._source.dynamic_price_template_id=params.dynamic_price_template_id;
                ctx._source.dynamic_price_template.id=params.dynamic_price_template_id;
                ctx._source.dynamic_price_template.code=params.dynamic_price_template_code;
                ctx._source.dynamic_price_template.name=params.dynamic_price_template.name;
                ctx._source.dynamic_price_template.count_products=params.dynamic_price_template.count_products;
                ctx._source.dynamic_price_template.is_deleted=params.dynamic_price_template.is_deleted;
                ctx._source.dynamic_price_template.user_id_update=params.dynamic_price_template.user_id_update;
                ctx._source.dynamic_price_template.rules=params.ctx._source.dynamic_price_template.rules;
                """,
            "params": {
              "is_expired_dynamic_price": #[isExpiredDynamicPrice],
              "dynamic_price_template_id": #[dynamicPriceTemplateId],
              "dynamic_price_template_code":#[dynamicPriceTemplate->code],
              "dynamic_price_template.name":#[dynamicPriceTemplate->name],
              "dynamic_price_template.count_products":#[dynamicPriceTemplate->countProducts],
              "dynamic_price_template.is_deleted":#[dynamicPriceTemplate->isDeleted],
              "dynamic_price_template.user_id_update":#[dynamicPriceTemplate->userIdUpdate],
              "dynamic_price_template.rules":
              [
                   #foreach($rule in $dynamicPriceTemplate.rules)
                       #if($velocityCount > 0),#end
                   {
                        "id": #[dynamicPriceTemplate->rules[$velocityCount].id],
                        "sort_num": #[dynamicPriceTemplate->rules[$velocityCount]->sortNum],
                        "act_expired_time_tick": #[dynamicPriceTemplate->rules[$velocityCount]->actExpiredTimeTick],
                        "act_expired_time_value": #[dynamicPriceTemplate->rules[$velocityCount]->actExpiredTimeValue],
                        "act_expired_time_unit": #[dynamicPriceTemplate->rules[$velocityCount]->actExpiredTimeUnit],
                        "price_new_type": #[dynamicPriceTemplate->rules[$velocityCount]->priceNewType],
                        "price_new_coefficient": #[dynamicPriceTemplate->rules[$velocityCount]->priceNewCoefficient],
                        "price_new_custom": #[dynamicPriceTemplate->rules[$velocityCount]->priceNewCustom],
                        "auto_set_commend": #[dynamicPriceTemplate->rules[$velocityCount].autoSetCommend],
                        "auto_set_tag": #[dynamicPriceTemplate->rules[$velocityCount]->autoSetTag]
                    }
                   #end
              ]
            }
          }
        }
        ]]>
    </property>

4 参考资料
https://my.oschina.net/bboss/blog/1556866#h3_37

https://www.elastic.co/guide/en/elasticsearch/painless/6.3/painless-examples.html

elasticsearch技术交流群:166471282

elasticsearch微信公众号:
img_a21db47cf20ac4820026d60bcb2b9470.jpe

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
小tips: 使用&#x3000;等空格实现最小成本中文对齐
一、重见天日第二春 11年的时候,写了篇文章“web页面相关的一些常见可用字符介绍”,这篇文章里面藏了个好东西,就是使用一些空格实现个数不等的中文对齐或等宽。见下表: 字符以及HTML实体 描述以及说明   &nbsp; 这是我们使用最多的空格,也就是按下space键产生的空格。
880 0
我的使用Esc体验
总体而言,在这个过程中,我体验到了服务器的神奇,也学习到了许多相关的知识,也希望在接下去的时间中继续进行相关的知识学习。
100 0
Observability:使用 Elastic Stack 分析地理空间数据
在今天的文章中,我们将参考之前的文章 “如何使用 Elasticsearch ingest 节点来丰富日志和指标”。我们可以利用 Elasticsearch ingest 节点来更加丰富我们的数据,并对这些数据做更进一步的的分析。
1291 0
【最佳实践】使用 Elasticsearch SQL 实现数据查询
如何使用 Elasticsearch SQL 来对我们的数据进行查询。
2372 0
JavaScript使用原型判断对象类型
1. constructor属性 在JavaScript创建对象(二)——构造函数模式中,我们说过可以使用对象的constructor属性判断对象的类型:p1.constructor === Person,可能当时就有细心的读者会想,我们并没有给这个对象添加过constructor,这个属性是从哪儿来的呢?讲过原型之后,我们知道这个属性是原型中的,所以一般重写原型时也都会把constructor补上。
1131 0
+关注
bboss
热衷开源,主要开源作品:开源框架bboss,bboss session,bboss 序列化等 bboss特色:http://yin-bp.iteye.com/blog/1080824
328
文章
1
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载