ElasticSearch如何存储组织与用户级别的上下文文档字段？

Elasticsearch没有原生的"上下文文档字段"功能，但可以通过嵌套对象存储层级自定义数据结合Runtime字段动态计算有效内容的方式，完美实现你需求的多组织、多用户层级的图书名称和笔记自定义与检索逻辑。

一、修改文档映射 #

首先扩展原有的映射，添加两个嵌套字段分别存储组织级和用户级的自定义内容：

PUT /books
{
  "mappings": {
    "properties": {
      "id":  { "type": "binary" },
      "title":  { "type": "keyword" },
      "notes":     { "type": "text" },
      "fulltext": { "type": "text" },
      "org_customizations": {
        "type": "nested",
        "properties": {
          "org_id": { "type": "keyword" },
          "custom_title": { "type": "keyword" },
          "custom_notes": { "type": "text" }
        }
      },
      "user_customizations": {
        "type": "nested",
        "properties": {
          "user_id": { "type": "keyword" },
          "custom_title": { "type": "keyword" },
          "custom_notes": { "type": "text" }
        }
      }
    }
  }
}

• org_customizations：存储各组织对图书的自定义标题和笔记，每个元素对应一个组织的修改
• user_customizations：存储各用户对图书的自定义标题和笔记，每个元素对应一个用户的修改

二、存储示例数据 #

以你给出的示例场景为例，存储图书数据：

PUT /books/_doc/1
{
  "id": "book_123",
  "title": "Eragon",
  "notes": "",
  "fulltext": "全书讲述了伊拉贡与龙的奇幻冒险...",
  "org_customizations": [
    {
      "org_id": "org1",
      "custom_title": "",
      "custom_notes": "contains dragons"
    }
  ],
  "user_customizations": [
    {
      "user_id": "user1",
      "custom_title": "Blue book",
      "custom_notes": ""
    }
  ]
}

三、检索时动态计算上下文内容 #

通过Runtime字段在检索阶段动态计算当前用户应看到的有效标题和有效笔记，优先级为：用户自定义 > 组织自定义 > 全局默认值。

1. 用户1（属于组织1）的检索示例 #

GET /books/_search
{
  "runtime_mappings": {
    "effective_title": {
      "type": "keyword",
      "script": """
        // 优先获取用户自定义标题
        def userCustom = doc['user_customizations'].stream().filter(c -> c.user_id == params.user_id).findFirst();
        if (userCustom.isPresent() && userCustom.get().custom_title != "") {
          emit(userCustom.get().custom_title);
        } else {
          // 其次获取组织自定义标题
          def orgCustom = doc['org_customizations'].stream().filter(c -> c.org_id == params.org_id).findFirst();
          if (orgCustom.isPresent() && orgCustom.get().custom_title != "") {
            emit(orgCustom.get().custom_title);
          } else {
            // 最后用全局默认标题
            emit(doc['title'].value);
          }
        }
      """,
      "params": {
        "user_id": "user1",
        "org_id": "org1"
      }
    },
    "effective_notes": {
      "type": "text",
      "script": """
        def userCustom = doc['user_customizations'].stream().filter(c -> c.user_id == params.user_id).findFirst();
        if (userCustom.isPresent() && userCustom.get().custom_notes != "") {
          emit(userCustom.get().custom_notes);
        } else {
          def orgCustom = doc['org_customizations'].stream().filter(c -> c.org_id == params.org_id).findFirst();
          if (orgCustom.isPresent() && orgCustom.get().custom_notes != "") {
            emit(orgCustom.get().custom_notes);
          } else {
            emit(doc['notes'].value);
          }
        }
      """,
      "params": {
        "user_id": "user1",
        "org_id": "org1"
      }
    }
  },
  "query": {
    "bool": {
      "should": [
        {"match": {"effective_title": "Blue book"}},
        {"match": {"effective_notes": "contains dragons"}}
      ]
    }
  },
  "_source": ["effective_title", "effective_notes", "fulltext"]
}

这个查询会返回该图书，且返回的标题是"Blue book"，笔记是"contains dragons"，符合需求。

2. 组织1其他用户的检索示例 #

只需将params中的user_id替换为该用户ID，effective_title会取组织自定义（无则全局），effective_notes取组织自定义的"contains dragons"，搜索该笔记内容会命中图书。

3. 非组织1用户的检索示例 #

将params中的org_id替换为对应组织ID（或留空处理），此时effective_notes只会取全局空值，effective_title取全局的"Eragon"，只有搜索"Eragon"才会命中该图书。

四、关键注意事项 #

1. 嵌套字段性能：嵌套字段的查询会增加一定开销，需控制每个图书的组织/用户自定义条目数量，避免过度膨胀。
2. 脚本优化：Runtime脚本尽量简化逻辑，可提前在业务层过滤无效的自定义条目（比如只保留最新的修改），减少脚本内的遍历次数。
3. 权限控制：结合Elasticsearch Security插件的文档级权限，可进一步确保用户只能访问所属组织的自定义内容，避免在脚本中处理复杂的权限判断。

内容的提问来源于stack exchange，提问作者Moffen