scala - 如何在elastic4s中使用父ID进行更新

Question

我正在使用 elastic4s 在 ElasticSearch 中创建索引。我的代码如下：

var seqBulkDef = SeqBulkCompatibleDefinition
seqBulkDef=seqBulkDef:+request(sha256, parentId, indexMap, ES_INDEX, ES_INDEX_TYPE)
val resp = client.execute (bulk (seqBulkDef)).await(duration)

def request(sha: String, parentId: String, indexMap: Map, index: String, indexType: String): BulkCompatibleDefinition = {
  update(sha) in index / indexType docAsUpsert indexMap parent parentId
}

但它不适用于parentId. 请问我应该如何修改语法。

Answer 1

您需要先添加一个映射来建立关系并指定哪个文档类型应该是子类型的父级。

在 scala4s 中，您需要执行以下操作：

client.execute {
  put mapping "places" / "city" parent ("country") 
}

然后你可以打电话

client.execute {
  update("5") in "places" / "cities" docAsUpsert Map("name" -> "São Paulo") parent "2"
}

Answer 2

update(id).in("places/city").docAsUpsert(write(json)) refresh (RefreshPolicy.IMMEDIATE)