Elasticsearch学习--script

小咪咪 2024-04-07 13:22 26阅读 0赞

### 一、概念 ###

![4200a612800b4f69b6defb65281bf265.png][]

![94d6f2bf1844484f9ad37d1d49d06b68.png][]

es1.4-5.0，默认脚本语言是Grovvy

es5.0+，默认脚本语言是painless

![68c1b7e777e24c64bf7d5ae115e6a357.png][]

### 二、简单使用 ###

将price减一

# 将id=1的price减一
    POST goods/_update/1
    {
      "script": {
        "source": "ctx._source.price -= 1"
      }
    }
    
    # 简写
    POST goods/_update/1
    {
      "script": "ctx._source.price -= 1"
    }

其中，ctx是一个上下文对象 ，用在对数据的修改上

### 三、CRUD ###

#### 1、数据备份 ####

（数据来源可以查看：[CSDN][]）

#将goods中的数据备份到goods2中
    POST _reindex
    {
      "source": {
        "index": "goods"
      },
      "dest": {
        "index": "goods2"
      }
    }

#### 2. 新增数组中的值 ####

# 将id=1的tags新增一个值
    POST goods/_update/1
    {
      "script": "ctx._source.tags.add('无线充电')"
    }

#### 3. 根据id删除 ####

# 删除id=11的数据
    POST goods/_update/11
    {
      "script": "ctx.op='delete'"
    }

![395eb341761e41f79211f468b3413025.png][]

#### 4. upsert ####

如果数据存在执行script中的updated，如果数据不存在，执行upsert中created

POST goods/_update/15
    {
      "script": {
        "source": "ctx._source.price += 100"
      },
      "upsert": {
        "name":"香蕉",
        "price": 599
      }
    }

第一次执行结果

![361eb5904f894744baed4e490825f49a.png][]

第二次执行结果![752727a079a0492c80765ac5650c273d.png][]

#### 5. 查询 ####

使用expression和painless两种语言进行查询，查询结果相同

GET goods/_search
    {
      "script_fields": {
        "new_price": {
          "script": {
            "lang": "expression",
            "source": "doc['price'].value * 0.9"
          }
        }
      }
    }
    
    GET goods/_search
    {
      "script_fields": {
        "new_price": {
          "script": {
            "lang": "painless",
            "source": "doc['price'] * 0.9"
          }
        }
      }
    }

![c49b511863e34ae69ae39cba4d98a1fc.png][]

**painless**，doc\['age'\].value和doc\['age'\]都能正确输出，但是doc\['age'\] \* 0.9报错  
**expression**，doc\['age'\].value和doc\['age'\]都能正确输出，doc\['age'\] \* 0.9和doc\['age'\].value \* 0.9也都不报错

但是，painless，如果字段为空，\*0.9会报错

expression：只能访问数字、布尔值、日期等，存储的字段不可用

es源数据是map类型的，在取值的时候，要根据doc\['x xx'\]取值

**update用ctx，查询的时候用doc**

#### 6. 参数化查询 ####

给interest加一个值aaa

POST indexname/_update/2
    {
      "script": {
        "lang": "painless",
        "source": "ctx._source.interest.add('aaa')"
      }
    }

es在首次执行脚本的时候，会对执行的脚本进行编译，并且把编译的结果放在缓冲区内。es的缓冲区默认只有100M,编译操作很消耗性能，es每分钟支持的编译次数是15次  
解决方案是：

POST indexname/_update/2
    {
      "script": {
        "lang": "painless",
        "source": "ctx._source.interest.add(params.inserest_name)",
        "params": {
          "inserest_name":"bbb"
        }
      }
    }

**这样，参数是动态传递的，没有硬编码，下次参数内容发生改变，但是脚本没有发生改变，不需要重新编译，节省性能**

同理，也可以这样

GET indexname/_search
    {
      "script_fields": {
        "new_age": {
          "script": {
            "lang": "painless",
            "source":"doc['age'].value * params.num",
            "params": {
              "num": 0.9
            }
          }
        }
      }
    }

如果是expression，就要把params.num改成num

GET indexname/_search
    {
      "script_fields": {
        "new_age": {
          "script": {
            "lang": "expression",
            "source":"doc['age'].value * num",
            "params": {
              "num": 0.9
            }
          }
        }
      }
    }

**结果数组**

GET indexname/_search
    {
      "script_fields": {
        "age": {
          "script": {
            "lang": "painless",
            "source":"doc['age'].value"
          }
        },
        "new_age": {
          "script": {
            "lang": "painless",
            "source":"[doc['age'].value - params.num_1,doc['age'].value - params.num_2,doc['age'].value - params.num_3]",
            "params": {
              "num_1": 1,
              "num_2": 2,
              "num_3": 3
            }
          }
        }
      }
    }

### 四、stored scripts：scripts模板 ###

#### 1. 操作脚本 ####

因为脚本编译比较消耗性能，可以把脚本保存在集群的缓存中

语法

/_scripts/{script_id}

创建脚本

POST _scripts/age_num
    {
      "script":{
         "lang": "painless",
         "source":"doc['age'].value - params.num"
      }
    }

查看脚本

GET _scripts/age_num

使用脚本

GET indexname/_search
    {
      "script_fields": {
        "age": {
          "script": {
            "lang": "painless",
            "source":"doc['age'].value"
          }
        },
        "new_age": {
          "script": {
            "id": "age_num",
            "params": {
              "num": 0.9
            }
          }
        }
      }
    }

#### 2. scripting的函数式编程 ####

在source中加"""，三个双引号

POST indexname/_update/2
    {
      "script": {
        "lang": "painless",
        "source": """
           ctx._source.interest.add(params.inserest_name);
           ctx._source.age-=1;
        """,
        "params": {
          "inserest_name": "bbb"
        }
      }
    }

如果name中包含aa：name+bb；否则，不操作。==~是匹配的意思

POST indexname/_update/2
    {
      "script": {
        "lang": "painless",
        "source": """
          if(ctx._source.name ==~ /[\s\S]*aa[\s\S]*/){
            ctx._source.name+="bb"
          }else{
            ctx.op="noop"
          }
        """
      }
    }

for循环取insterst的总数

GET indexname/_search
    {
      "aggs": {
        "agg_insterst": {
          "sum": {
            "script": {
              "lang": "painless",
              "source": """
                int total=0;
                for(int i=0; i<doc['interest.keyword'].length;i++){
                  total++;
                }
                return total;
              """
            }
          }
        }
      }
    }

**doc\['filed'\]**:会被加载到内存中，效率更高，更消耗内存，只允许简单类型，object和nested属于复杂类型。推荐  
**params\['\_source'\]\['field'\]**：每次都要重新加载，重新解析，可以用于复杂类型

[4200a612800b4f69b6defb65281bf265.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/c33d88575a4649fc8fa611739ac0a046.png
[94d6f2bf1844484f9ad37d1d49d06b68.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/a596a715493c4819b5588fad484fa63f.png
[68c1b7e777e24c64bf7d5ae115e6a357.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/faf9d672d0624fca9465044d89b2e511.png
[CSDN]: https://blog.csdn.net/CelineT/article/details/126570118
[395eb341761e41f79211f468b3413025.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/798396b10f12422ea084606283ad8d37.png
[361eb5904f894744baed4e490825f49a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/1dda033044c040f2a10a4df18d4b7b12.png
[752727a079a0492c80765ac5650c273d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/d0456e7bdf62478f894cc0db87e4c398.png
[c49b511863e34ae69ae39cba4d98a1fc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/8bb472589bf14a6d9dc0a5a8468b8f81.png