Elasticsearch 数据读取过程

Posted 2023-05-02

参考技术A ES数据的读取是通过文档id来进行查询获取的。
1、客户端构建请求发送到任意node，该节点成为协调节点coordinate node。
2、协调节点根据文档id进行hash，根据公式 shard_num = hash(\routing) % num_primary_shards，确定数据存储到哪个shard，从元数据信息获取分片对应的node信息。
3、使用 round-robin 随机轮询算法，在 primary shard 以及其所有 replica 中随机选择一个，让读请求负载均衡。
4、接收请求的分片返回document给协调节点 coordinate node。
5、协调节点coordinate node返回document给客户端。

Python读取多个excel文件（删除字段数据格式转换dataframe多表合并）并写入ElasticSearch实战（自动创建索引写入ElasticSearch探索性数据分析）

Python读取多个excel文件（删除字段、数据格式转换、dataframe多表合并）并写入ElasticSearch实战（自动创建索引、写入ElasticSearch、探索性数据分析）

目录