使用nodejs搜索elasticsearch（DSL）

心已赠人 2022-11-17 05:23 286阅读 0赞

使用nodejs搜索elasticsearch  
一、npm 安装elasticsearch模块  
二、启动elasticsearch  
三、elasticsearch查询语句（query DSL）  
四、查询、删除内容、删除索引demo  
查询  
删除索引中日志的内容  
删除索引  
一、npm 安装elasticsearch模块  
npm install elasticsearch  
1  
二、启动elasticsearch  
启动的的elasticsearch服务，而非步骤一中安装的npm模块。对elasticsearch的介绍，我后面的博客会单独做介绍。  
单击elasticsearch.bat，或者在cmd命令行输入以下命令

.\\bin\\elasticsearch.bat  
1  
三、elasticsearch查询语句（query DSL）  
Elasticsearch提供了一种json风格的查询语言，称为Query DSL（Query domain-specific language）。查询语言功能很全面。  
以下几篇博客，给大家参考

1.elasticsearch查询语句（query DSL）  
2.ES 22 - Elasticsearch中如何进行日期(数值)范围查询  
3.Elastic Search之Search API(Query DSL)、字段类查询、复合查询  
4.Elasticsearch查询方法  
5.Elasticsearch DSL 常用语法介绍  
四、查询、删除内容、删除索引demo  
查询  
关于tags可以参考我的filebeat的配置filebeat重载配置文件：reload功能,添加的tags是为了搜索时方便，比如在此处，在此会只查询tags为"GUID"的日志信息。

(function () \{  
  'use strict';

const elasticsearch = require('elasticsearch');  
  const esClient = new elasticsearch.Client(\{  
    host: '127.0.0.1:9200',  
    log: 'error'

\});

console.log(\`retrieving documents with a combined bool query (displaying $\{body.size\} items at a time)...\`);  
    //search('opslog-systemlog-2020.08.10', body)  
    search('ops\*', body)  
      .then(results => \{  
        console.log(\`found $\{results.hits.total\} items in $\{results.took\}ms\`);  
        if (results.hits.total > 0) console.log(\`returned article titles:\`);  
        results.hits.hits.forEach((hit, index) => console.log(\`\\t$\{body.from + ++index\} - $\{hit.\_source.title\} (score: $\{hit.\_score\})\`));  
      \})  
      .catch(console.error);  
  \};

test();

module.exports = \{  
    search  
  \};  
\}());  
  
删除索引中日志的内容  
删除索引“opslog-systemlog-2020.08.10”在此时间段内message带有10的内容

(function () \{  
  'use strict';

// only for testing purposes  
  // all calls should be initiated through the module  
  const test = function test() \{  
    let body = \{  
      size: 100,  
      // from: 0,  
      query: \{  
        bool: \{  
          must: \[  
            \{  
              query\_string: \{  
                query: '(message:\*10)'  
              \}  
            \}  
          \],  
          filter: \[  
            \{  
              range: \{  
                '@timestamp': \{  
                  gte: '2020-08-10T08:34:15.960Z' ,  
                  lte: '2020-08-10T08:38:54.281Z'  
                \}  
              \}  
            \}  
          \]  
        \}  
      \}  
    \};

console.log(\`retrieving documents with a combined bool query (displaying $\{body.size\} items at a time)...\`);  
    deletecontent('opslog-systemlog-2020.08.10', body)  
    .then(results => \{  
      console.log(\`found $\{results.hits.total\} items in $\{results.took\}ms\`);  
      if (results.hits.total > 0) console.log(\`returned article titles:\`);  
      results.hits.hits.forEach((hit, index) => console.log(\`\\t$\{body.from + ++index\} - $\{hit.\_source.title\} (score: $\{hit.\_score\})\`));  
    \})  
    .catch(console.error);  
  \};

test();

module.exports = \{  
    deletecontent  
  \};  
\} ());  
  
删除索引  
删除索引“ops-systemlog-2020.08.05”，至于自动清理索引的功能，我会单独写一篇博客介绍。elasticsearch定时删除过期索引index