java - 使用 Java API 在 Elasticsearch 中创建 MongoDB River

Question

我正在尝试使用 Java API 在 MongoDB 和 ElasticSearch 之间创建一条新河流。使用 REST API 非常容易使用以下 JSON 发出 PUT 请求

{
  "type": "mongodb",
  "mongodb": {
    "servers": [
      { "host": "127.0.0.1", "port": 27017 }
    ],
    "options": { "secondary_read_preference": true },
    "db": "test",
    "collection": "collectionTest"
  },
  "index": {
    "name": "testIndex",
    "type": "default"
  }
}

但是我在使用 Java API 时遇到了一些问题。我正在尝试使用 CreateIndexRequestBuilder 类，但我不知道如何指定参数。

它们是自定义参数吗？来源呢？我很迷茫...

提前谢谢您!

Answer 1

您需要将 ID 为 _meta 的文档添加到 _river 索引中。类型是您要为索引指定的名称。要发送的文档是一个 json，其中包含您的河流所需的配置。除了依赖于河流的自定义配置之外，json 文档还需要包含属性 type，其中包含河流本身用于注册 RiverModule 的名称。对于 mongodb 河，它是 mongodb。您发布的 json 正是您必须发送的源。

这是您需要的代码:

client.index(Requests.indexRequest("_river").type("my_river").id("_meta").source(source)).actionGet();