node.js - 如何使用Node.js将数据推送到ElasticSearch中的指定索引

Question

我正在开发聊天应用程序，我需要使用nodejs将聊天信息推送到elasticsearch以获得指定的索引。

我创建了索引，并使用以下代码将数据推送到elasticsearch 。

var elasticsearch = require('elasticsearch');
var client = new elasticsearch.Client({
  host: 'localhost:9200',
  log: 'trace'
});

client.ping({
  requestTimeout: 30000,

  // undocumented params are appended to the query string
  hello: "elasticsearch"
}, function (error) {
  if (error) {
    console.error('elasticsearch cluster is down!');
  } else {
    console.log('All is well');
  }
});



  var result = client.index({
    index: 'chennaiboxchat',
    type: 'posts',
    id: '1',
    body: {
      "glossary": {
        "title": "example Test",
        "GlossDiv": {
          "title": "S",
          "GlossList": {
            "GlossEntry": {
              "ID": "SGML",
              "SortAs": "SGML",
              "GlossTerm": "Standard Generalized Markup Language",
              "Acronym": "SGML",
              "Abbrev": "ISO 8879:1986",
              "GlossDef": {
                "para": "A meta-markup language, used to create markup languages such as DocBook.",
                "GlossSeeAlso": ["GML", "XML"]
              },
              "GlossSee": "mark"
            }
          }
        }
      }
    },
    refresh: true
  });

但是，如果下次运行此代码会覆盖data.so，则需要使用Node.js在elasticsearch中更新同一索引中的数据。建议我如何更新单个索引中的数据。

Answer 1

默认情况下，您必须提供完整的文档。因此，使用get获取文档，更改要更改的字段，然后像以前一样放回文档。有一个更新API仅提供部分文档。这实际上是一样的，但是elasticsearch会为您完成get和put部分。如果确实要执行此操作，则通常需要使用version属性进行操作。更多信息可以在这里找到:
https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html#_updates_with_a_partial_document

node.js使用的javascript驱动程序也支持更新终结点。在此处查看文档:
https://www.elastic.co/guide/en/elasticsearch/client/javascript-api/current/api-reference.html#api-update