關(guān)閉限流方式

7.10最新版本

其他版本

將限流參數(shù)設(shè)置為false

PUT _cluster/settings
{
  "persistent": {
    "apack.qos.limiter.enabled": false
  }
}

PUT _cluster/settings
{
   "persistent" : {
      "apack.qos.ratelimit.enabled":"false"
   }
}

將限流參數(shù)設(shè)置為null

PUT _cluster/settings
{
  "persistent": {
    "apack.qos.limiter.enabled": null
  }
}

PUT _cluster/settings
{
   "persistent" : {
      "apack.qos.ratelimit.enabled":null
   }
}

參數(shù)

說明

可選值

action

限流的action，用于限制不同類型的請求。

• write：doc寫入請求，包含index和create。

• update：doc更新請求。

• delete：doc刪除請求

• search：查詢請求。

• search_shards：查詢索引的shard總數(shù)請求。

limiter_type

限流類型。支持三大類：

• 速率

• 并發(fā)度

• 單請求限制

• rate：速率，只支持整數(shù)。

• qps：查詢速率，只支持整數(shù)。

• tps：寫入速率，只支持整數(shù)。

• throughput：吞吐量，只支持action為write、update和delete。支持的單位包含GB、MB、KB等，最大支持2 GB。

• thread_count：請求并發(fā)度，一個請求為一個并發(fā)。

• concurrent_count：請求并發(fā)度，按照請求中的具體操作計算并發(fā)數(shù)。例如設(shè)置search_shards.concurrent_count:20，表示允許最大20個shard并發(fā)查詢。

• max_per_request：單請求中包含的某類操作個數(shù)的上限。例如設(shè)置update.max_per_request:10，表示一個寫入請求最多有10個update。

• max_size_per_request：單請求個數(shù)上限。只支持action為write、update和delete。

threshold

限流閾值。

int范圍內(nèi)的整數(shù)，>=-1。

tagName

tag名稱。

• node：當前節(jié)點名。

• is_master：當前節(jié)點是否為master，對應的tag值為true或false。

• index：索引名。如果有多個索引名，則為數(shù)組。如果傳入的是別名，此處也是解析的實際索引名。僅IndicesRequest的子類請求才有此tag。

• shard：shard名，即index[id]，例如test[0]。僅ReplicationRequest的子類請求才有此tag。

• index_in_url：URL中的index字符串，如果傳入的是別名，則此處就是別名。僅IndicesRequest的子類請求才有此tag。

tagValue

tag的值。

字符串，可為數(shù)組。如果為數(shù)組，則對應tag匹配數(shù)組中任意一個value即可。支持精確匹配、模糊匹配和任意值，例如：

• 精確匹配："abc"

• 模糊匹配："ab*"

• 任意值："**"

  說明

  如果為任意值，則為默認限流器。即對這個tag的任意值都會生成一個精確的限流器，例如設(shè)置為index:"**",search.tps:1，表示默認情況下，限制每個索引的search速率為1，而不是總search速率為1。

priority

優(yōu)先級。

int整數(shù)，默認為0。

params

高級參數(shù)。

watchMode：是否啟用觀察模式，支持true和false（默認）。如果為true，Elasticsearch只會在metric中記錄拒絕數(shù)，但不會實際限流。您可以通過API查看指標監(jiān)控信息，用于提前驗證限流效果，避免由于配置錯誤造成錯誤的限流。API的詳細信息，請參見常見問題。

操作

7.10最新版本

其他版本

設(shè)置單個索引的查詢QPS限流

PUT /_qos/limiter/<limiterName>
{
  "limiters": {
    "search.qps": "1000"
  },
  "tags": {
    "index": "twitter"
  }
}

PUT _qos/_ratelimit/<limiterName>
{
   "search.index_patterns" : "twitter",
   "search.max_queries_per_sec" : 1000
}

設(shè)置指定名稱前綴的索引的查詢QPS限流

PUT /_qos/limiter/<limiterName>
{
  "limiters": {
    "search.qps": "1000"
  },
  "tags": {
    "index": "nginx-log-*"
  }
}

PUT _qos/_ratelimit/<limiterName>
{
   "search.index_patterns" : "nginx-log-*",
   "search.max_queries_per_sec" : 1000
}

設(shè)置任意索引的查詢QPS限流

PUT /_qos/limiter/<limiterName>
{
  "limiters": {
    "search.qps": "1000"
  },
  "tags": {
    "index": "**"
  }
}

不支持。

設(shè)置所有索引的查詢總QPS限流

PUT /_qos/limiter/<limiterName>
{
  "limiters": {
    "search.qps": "1000"
  },
  "tags": {
    "index": "*"
  }
}

PUT _qos/_ratelimit/<limiterName>
{
   "search.index_patterns" : "*",
   "search.max_queries_per_sec" : 1000
}

操作

7.10最新版本

其他版本

獲取所有限流配置

GET _qos/limiter

GET _qos/_ratelimit

獲取單個指定的限流配置

GET _qos/limiter/<limiterName>

GET _qos/_ratelimit/<limiterName>

獲取多個指定的限流配置

GET _qos/limiter/<limiterName1,limiterName2>

GET _qos/_ratelimit/<limiterName1,limiterName2>

操作

7.10最新版本

其他版本

刪除單個指定的限流配置

DELETE _qos/limiter/<limiterName>

DELETE _qos/_ratelimit/<limiterName>

刪除多個指定的限流配置

DELETE _qos/limiter/<limiterName1,limiterName2>

DELETE _qos/_ratelimit/<limiterName1,limiterName2>