es 获取本地文件 语法

在 Elasticsearch 中，可以通过使用 File System 相关的 API 来获取本地文件。

具体的语法如下：

PUT _ingest/pipeline/my-pipeline
{
  "description": "describe pipeline",
  "processors": [
    {
      "attachment": {
        "field": "data",
        "indexed_chars": "-1"
      }
    }
  ]
}

PUT my-index/my-type/my-id?pipeline=my-pipeline
{
  "data": "base64 encoded content of file"
}

其中，_ingest/pipeline API 是指定 Ingest Node Pipeline 的 API，它可以将文档的内容进行处理，然后再进行索引。

my-pipeline 是 Ingest Node Pipeline 的名称，可以自定义。

processors 是 Ingest Node Pipeline 中的处理器列表，这里使用 attachment 处理器来处理文档内容。

attachment 处理器是 Ingest Attachment Processor 插件中的一个处理器，它用于将文档内容转换为 Elasticsearch 中的附件类型。

data 是文档中包含的数据字段名，可以自定义。

在 PUT my-index/my-type/my-id API 中，指定了要将文档索引到的索引名称（my-index）、文档类型名称（my-type）和文档 ID（my-id），pipeline=my-pipeline 表示使用指定名称的 Ingest Node Pipeline 来处理文档内容。

对于要获取的本地文件，可以使用 file processor 将文件内容读取到 data 字段中，具体的语法如下：

PUT _ingest/pipeline/read-file
{
  "description": "read file into data field",
  "processors": [
    {
      "script": {
        "lang": "painless",
        "source": """
          byte[] encoded = java.nio.file.Files.readAllBytes(java.nio.file.Paths.get(ctx.filename));
          ctx.data = Base64.getEncoder().encodeToString(encoded);
        """
      }
    }
  ]
}

其中，_ingest/pipeline API 和 processors 字段的含义与上面相同。

script 处理器是 Ingest Node Pipeline 中的一个处理器，它使用 Painless 脚本来处理文档内容。

ctx.filename 表示获取要读取的文件路径，可以自定义。

java.nio.file.Files.readAllBytes 方法用于读取文件内容到字节数组中。

java.nio.file.Paths.get 方法用于获取文件路径。

Base64.getEncoder().encodeToString 方法用于将字节数组编码为 Base64 字符串，并将结果赋值给 ctx.data 字段。

读取本地文件后，可以使用 PUT my-index/my-type/my-id?pipeline=read-file API 来将文档索引到 Elasticsearch 中。