elasticsearch实现数据存储

### 使用Elasticsearch实现数据存储

#### 创建索引
为了在Elasticsearch中存储文档，首先需要创建一个索引。索引类似于关系型数据库中的表格。可以通过发送HTTP PUT请求来创建新索引。

PUT /my-index-000001
{
  "settings": {
    "number_of_shards": 1,
    "number_of_replicas": 1
  },
  "mappings": {
    "properties": {
      "title": { "type": "text" },
      "content": { "type": "text" }
    }
  }
}

此命令定义了一个名为`my-index-000001`的新索引，并指定了分片数量和副本数[^4]。

#### 插入单个文档
一旦建立了索引，则可以开始向其中添加文档。每条记录都是一个JSON对象形式的文档：

POST /my-index-000001/_doc/1
{
  "title": "Elasticsearch Basics",
  "content": "An introduction to using Elasticsearch..."
}

这里通过指定ID `1` 向索引内插入了一篇关于Elasticsearch基础知识的文章。

#### 批量导入多条记录
对于大量数据加载场景，推荐采用批量操作方式提高效率。Bulk API允许一次性提交多个动作（如创建、更新或删除）给集群处理。

POST _bulk
{ "index" : { "_index" : "my-index-000001", "_id" : "2" } }
{ "title" : "Advanced Topics", "content":"Dive deeper into advanced features..." }
{ "create" : { "_index" : "my-index-000001", "_id" : "3" } }
{ "title" : "Best Practices Guide", "content":"Learn best practices for optimal performance." }

上述例子展示了如何利用_bulk接口连续上传两条不同类型的指令——一条用于新增，另一条则是强制创建模式下的写入。

#### 数据刷新机制
当文档被成功加入后，默认情况下它们并不会立即可见于搜索结果之中；这是因为Elasticsearch采用了周期性的refresh过程将最近的变化同步到可查询状态。通常这个间隔设定为一秒，在某些特殊需求下可通过调整参数改变这一行为[^5]。