elasticsearch #

描述 #

elasticsearch 过滤器是一个用于请求转发给后端 Elasticsearch 集群的过滤器。

配置示例 #

使用 elasticsearch 过滤器之前，需要提前定义一个 Elasticsearch 的集群配置节点，如下：

elasticsearch:
- name: prod
  enabled: true
  endpoint: http://192.168.3.201:9200

流程的配置示例如下：

flow:
  - name: cache_first
    filter:
      - elasticsearch:
          elasticsearch: prod  

上面的例子即将请求转发给 prod 集群。

自动更新 #

对于一个大规模的集群，可能存在很多的节点，不可能一一配置后端的所有节点，只需要先指定 Elasticsearch 模块允许自动发现后端节点，如下：

elasticsearch:
- name: prod
  enabled: true
  endpoint: http://192.168.3.201:9200
  discovery:
    enabled: true
    refresh:
      enabled: true
  basic_auth:
    username: elastic
    password: pass

然后过滤器这边的配置也开启刷新，即可访问后端所有节点，且节点上下线也会自动更新，示例如下：

flow:
  - name: cache_first
    filter:
      - elasticsearch:
          elasticsearch: prod  
          refresh: 
            enabled: true
            interval: 30s

设置权重 #

如果后端集群很多，极限网关支持对不同的节点设置不同的访问权重，配置示例如下：

flow:
  - name: cache_first
    filter:
      - elasticsearch:
          elasticsearch: prod  
          balancer: weight
          refresh: 
            enabled: true
            interval: 30s
          weights:
            - host: 192.168.3.201:9200 
              weight: 10
            - host: 192.168.3.202:9200
              weight: 20
            - host: 192.168.3.203:9200
              weight: 30

上面的例子中，发往 Elasticsearch 集群的流量，将以 3：2：1 的比例分别发给 203、202 和 201 这三个节点。

过滤节点 #

极限网关还支持按照节点的 IP、标签、角色来进行过滤，可以用来将请求避免发送给特定的节点，如 Master、冷节点等，配置示例如下：

flow:
  - name: cache_first
    filter:
      - elasticsearch:
          elasticsearch: prod  
          balancer: weight
          refresh: 
            enabled: true
            interval: 30s
          filter:
            hosts:
              exclude:
                - 192.168.3.201:9200
              include:
                - 192.168.3.202:9200
                - 192.168.3.203:9200
            tags:
              exclude:
                - temp: cold
              include:
                - disk: ssd
            roles:
              exclude:
                - master
              include:
                - data
                - ingest

参数说明 #