背景

最近在做订单数据存储到ElasticSearch，考虑到数据量比较大，采用冷热架构来存储，每月建立一个新索引，数据先写入到热索引，通过工具将3个月后的索引自动迁移到冷节点上。

ElasticSearch版本：6.2.4

冷热架构

官方叫法：热暖架构——“Hot-Warm” Architecture。

通俗解读：热节点存放用户最关心的热数据；温节点或者冷节点存放用户不太关心或者关心优先级低的冷数据或者暖数据。

1.1 官方解读冷热架构

为了保证Elasticsearch的读写性能，官方建议磁盘使用SSD固态硬盘。然而Elasticsearch要解决的是海量数据的存储和检索问题，海量的数据就意味需要大量的存储空间，如果都使用SSD固态硬盘成本将成为一个很大的问题，这也是制约许多企业和个人使用Elasticsearch的因素之一。为了解决这个问题，Elasticsearch冷热分离架构应运而生。

冷热架构是一项十分强大的功能，能够让您将 Elasticsearch 部署划分为“热”数据节点和“冷”数据节点。

• 热数据节点处理所有新输入的数据，并且存储速度也较快，以便确保快速地采集和检索数据。
• 冷节点的存储密度则较大，如需在较长保留期限内保留日志数据，不失为一种具有成本效益的方法。

将这两种类型的数据节点结合到一起后，您便能够有效地处理输入数据，并将其用于查询，同时还能在节省成本的前提下在较长时间内保留数据。此架构对日志用例来说尤其大有帮助，因为在日志用例中，人们的大部分精力都会专注于近期的日志（例如最近两周），而较早的日志（由于合规性或者其他原因仍需要保留）则可以接受较慢的查询时间。

1.2 典型应用场景

一句话：在成本有限的前提下，让客户关注的实时数据和历史数据硬件隔离，最大化解决客户反应的响应时间慢的问题。业务场景描述：
每日增量6TB日志数据，高峰时段写入及查询频率都较高，集群压力较大，查询ES时，常出现查询缓慢问题。

• ES集群的索引写入及查询速度主要依赖于磁盘的IO速度，冷热数据分离的关键为使用SSD磁盘存储热数据，提升查询效率。
• 若全部使用SSD，成本过高，且存放冷数据较为浪费，因而使用普通SATA磁盘与SSD磁盘混搭，可做到资源充分利用，性能大幅提升的目标。

node.attr.{attribute}: {value}

node.attr.temperature: hot //热节点
node.attr.temperature: cold //冷节点

index.routing.allocation.include.{attribute} 　　//表示索引可以分配在包含多个值中其中一个的节点上。
index.routing.allocation.require.{attribute}　　 //表示索引要分配在包含索引指定值的节点上（通常一般设置一个值）。
index.routing.allocation.exclude.{attribute}　　 //表示索引只能分配在不包含所有指定值的节点上。

[root@es-master1 ~]# cd /etc/elasticsearch/
[root@es-master1 elasticsearch]# vim elasticsearch.yml
cluster.name: linuxplus
node.name: es-master1.linuxplus.com
node.attr.rack: r6
node.master: true
node.data: false
path.data: /var/lib/elasticsearch
path.logs: /var/log/elasticsearch
network.host: 0.0.0.0
discovery.zen.ping.unicast.hosts: ["es-master1.linuxplus.com:9300","es-master2.linuxplus.com:9300","es-master3.linuxplus.com:9300","es-hot1.linuxplus.com:9300","es-hot2.linuxplus.com:9300","es-hot3.linuxplus.com:9300","es-stale1.linuxplus.com:9300","es-stale2.linuxplus.com:9300"]
discovery.zen.minimum_master_nodes: 1
bootstrap.system_call_filter: false

[root@es-hot1 elasticsearch]# vim elasticsearch.yml
cluster.name: linuxplus
node.name: es-hot1.linuxplus.com     # 提示：自行修改其他节点的名称
node.attr.rack: r1
node.master: false
node.data: true
path.data: /var/lib/elasticsearch
path.logs: /var/log/elasticsearch
network.host: 10.10.10.24           # 提示：自行修改其他节点的IP
discovery.zen.ping.unicast.hosts: ["es-master1.linuxplus.com:9300","es-master2.linuxplus.com:9300","es-master3.linuxplus.com:9300"]
discovery.zen.minimum_master_nodes: 1
bootstrap.system_call_filter: false
node.attr.hotwarm_type: hot　　　　　# 标识为热数据节点　
[root@es-hot1 elasticsearch]# /etc/init.d/elasticsearch start

[root@es-stale1 elasticsearch]# vim elasticsearch.yml
cluster.name: linuxplus
node.name: es-stale1.linuxplus.com　　　　# 提示：自行修改其他节点的名称
node.attr.rack: r1
node.master: false
node.data: true
path.data: /var/lib/elasticsearch
path.logs: /var/log/elasticsearch
network.host: 10.10.10.27　　　　　　　　　# 提示：自行修改其他节点的IP
discovery.zen.ping.unicast.hosts: ["es-master1.linuxplus.com:9300","es-master2.linuxplus.com:9300","es-master3.linuxplus.com:9300"]
discovery.zen.minimum_master_nodes: 1
bootstrap.system_call_filter: false
node.attr.hotwarm_type: cold　　　　　　# 标识为冷数据节点
[root@es-stale1 elasticsearch]# /etc/init.d/elasticsearch start

PUT _template/order_template{"index_patterns": "order_*","settings": {　　　　  "index.routing.allocation.require.hotwarm_type": "hot",　　# 指定默认为热数据节点　　　　         "index.number_of_replicas": "0"}
}

PUT /order_2019-12
{"settings": {"index.routing.allocation.require.hotwarm_type": "hot",　　　# 指定为热数据节点　"number_of_replicas": 0}
}

#在kibana里操作:

#!/bin/bash  hot数据（保留7天）迁移到cold
Time=$(date -d "1 week ago" +"%Y.%m.%d")
Hostname=$(hostname)
arr=("order_stpprdinf" "order_stppayinf")
for var in ${arr[@]}
docurl -H "Content-Type: application/json" -XPUT http://$Hostname:9200/$var_$Time/_settings?pretty -d'{ "settings": { "index.routing.allocation.require.hotwarm_type": "cold"    # 指定数据存放到冷数据节点} }'
done

# Rmember, leave a key empty if there is no value.  None will be a string,
# not a Python "NoneType"
client:hosts: ["10.0.101.100", "10.0.101.101", "10.0.101.102"]port: 9200url_prefix:use_ssl: Falsecertificate:client_cert:client_key:ssl_no_validate: Falsehttp_auth:timeout: 30master_only: False

# Remember, leave a key empty if there is no value.  None will be a string,
# not a Python "NoneType"
#
# Also remember that all examples have 'disable_action' set to True.  If you
# want to use this action as a template, be sure to set this to False after
# copying it.
actions:1:action: allocation　　　　　　　　　# 这里执行操作类型为删除索引description: >-Apply shard allocation routing to 'require' 'tag=cold' for hot/cold nodesetup for logstash- indices older than 3 days, based on index_creation date.options:key: hotwarm_type　　　　　　　　 # 这是es节点中定义的属性value: cold　　　　　　　　　　　　# 这是要更新的值，变为冷节点allocation_type: require　　　　 # 这里alloction的类型disable_action: falsefilters:- filtertype: pattern　　kind: prefix　　　　　　　　　　　 # 这里是指匹配前缀为 “order_” 的索引，还可以支持正则匹配等，详见官方文档value: order_- filtertype: age　　　　　　　　　 # 这里匹配时间source: name　　　　　　　　　　　 # 这里根据索引name来匹配，还可以根据字段等，详见官方文档direction: oldertimestring: "%Y-%m"　　　　　　　 # 用于匹配和提取索引或快照名称中的时间戳unit: months　　　　　　　　　　　　# 这里定义的是months，还有days,weeks等，总时间为unit * unit_countunit_count: 3

cd /opt/elasticsearch-curator
curator --config config.yml action.yml

crontab -e
#添加如下配置,每天0时运行一次
0 0 */1 * * curator --config /opt/elasticsearch-curator/config.yml /opt/elasticsearch-curator/action.yml

    /*** 查询.** @param indexName    索引名稱* @param type         索引類型* @param conditionMap 查询条件Map* @param orderByMap   排序Map* @param page         分页page* @return 查询结果*/@Overridepublic List<Map<String, Object>> query(final String[] indexName, final String type,final Map<String, Object> conditionMap, final Map<String, String> orderByMap,final Page page) {logger.info("查询elasticSearch数据......");logger.info("indexName={}", Arrays.toString(indexName));logger.info("conditionMap={}", conditionMap.toString());logger.info("orderByMap={}", orderByMap.toString());

    final </span><span style="color: rgba(0, 0, 255, 1)">long</span> currentTimeMillis =<span style="color: rgba(0, 0, 0, 1)"> System.currentTimeMillis();RestHighLevelClient client </span>= <span style="color: rgba(0, 0, 255, 1)">null</span><span style="color: rgba(0, 0, 0, 1)">;List</span>&lt;Map&lt;String, Object&gt;&gt; resultList = <span style="color: rgba(0, 0, 255, 1)">new</span> ArrayList&lt;&gt;<span style="color: rgba(0, 0, 0, 1)">();</span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)"> {</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 1、创建连接</span>client =<span style="color: rgba(0, 0, 0, 1)"> createConnect();</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)"> 2、创建search请求</span>SearchRequest searchRequest = <span style="color: rgba(0, 0, 255, 1)">new</span><span style="color: rgba(0, 0, 0, 1)"> SearchRequest(<span style="color: rgba(255, 0, 0, 1)">indexName</span>);searchRequest.types(type);<br><br><br>　　　　　　　这里省略几百行代码................