elasticsearch 上传 csv

Elasticsearch 是一个强大的分布式搜索和分析引擎，主要用于实时的数据检索。如果你想通过 CSV 文件上传数据到 Elasticsearch，可以按照以下步骤操作：

1. **安装 Elasticsearch**：首先确保你已经下载并安装了 Elasticsearch，可以从其官方网站下载适合你的版本。

2. **创建索引**：在 Elasticsearch 中，你需要为数据创建一个索引（Index）。你可以使用 REST API 或者客户端工具（如 `curl`、Elasticsearch Head 插件或专门的客户端库）来创建索引，例如：

   curl -XPUT 'http://localhost:9200/my_index' -H 'Content-Type: application/json'

3. **配置 CSV 导入**：可以使用 Elasticsearch 的 Ingest Node（管道插件）中的 `csv` 管道处理器来导入 CSV 文件。你需要先启动一个有 ingest 功能的节点，然后准备一个 CSV 分析器配置文件，例如：

   {
     "description": "Reads a CSV file and loads it into an index",
     "processors": [
       {
         "csv": {
           "path": "data.csv",      // 指定CSV文件路径
           "field_map" : {          // 字段映射
             "my_field": "@value"
           }
         }
       },
       {"date_detection": {}},   // 如果需要日期解析
       {"doc_values_dynamic": true}  // 对动态字段启用文档值
     ]
   }

4. **执行导入**：将配置文件作为 JSON 传递给 `/_ingest/pipeline/import` 端点来运行 CSV 导入：

   curl -XPOST 'http://localhost:9200/_ingest/pipeline/import' -d @pipeline.json -H 'Content-Type: application/json'

5. **实际上传**：一旦管道设置好，你可以将 CSV 文件上传到指定索引，例如：

   curl -XPOST 'http://localhost:9200/my_index/_bulk?pretty' --data-binary @"data.csv" -H 'Content-Type: application/x-ndjson'

记得替换上述命令中的 `localhost:9200`, `my_index`, 和文件路径为你的实际情况。