› › ›

API задач ожидающих выполнения кластера

Возвращает изменения на уровне кластера, которые еще не были выполнены.

Запрос

GET /_cluster/pending_tasks

Предварительные условия

Если включены функции безопасности Elasticsearch, у вас должны быть права monitor или manage права на кластер для использования этого API.

Описание

API задач ожидающих выполнения кластера возвращает список изменений на уровне кластера (например, создание индекса, обновление отображения, выделение или отказ от фрагмента), которые еще не были выполнены.

Этот API возвращает список ожидающих обновлений состояния кластера. Они отличаются от задач, сообщенных API управления задачами, которые включают периодические задачи и задачи, инициированные пользователем, такие как статистика узлов, запросы поиска или запросы создания индекса. Однако, если задача, инициированная пользователем, такая как команда создания индекса, вызывает обновление состояния кластера, активность этой задачи может быть сообщена как API задач, так и API ожидающих задач кластера.

Параметры пути

local: (Необязательно, Булево) Если true, запрос извлекает информацию только с локального узла. По умолчанию false, что означает, что информация извлекается с узла-мастера.
master_timeout: (Необязательно, единицы измерения времени) Период ожидания соединения с узлом-мастером. Если ответ не получен до истечения срока ожидания, запрос завершается ошибкой. По умолчанию 30s.

Тело ответа

tasks: (объект) Список ожидающих задач.
insert_order: (целое число) Число, которое представляет момент вставки задачи в очередь задач.
priority: (строка) Приоритет ожидающей задачи. Действительные приоритеты в порядке убывания приоритета: IMMEDIATE > URGENT > HIGH > NORMAL > LOW > LANGUID.
source: (строка) Общее описание задачи кластера, которое может включать причину и источник.
executing: (булево) True или false, указывающее, выполняется ли в данный момент ожидающая задача.
time_in_queue_millis: (целое число) Время в миллисекундах, прошедшее с момента ожидания выполнения задачи.
time_in_queue: (строка) Время, прошедшее с момента ожидания выполнения задачи.

Примеры

Обычно запрос возвращает пустой список, так как изменения на уровне кластера происходят быстро. Однако, если в очереди есть задачи, ответ будет похож на этот:

{
   "tasks": [
      {
         "insert_order": 101,
         "priority": "URGENT",
         "source": "create-index [foo_9], cause [api]",
         "executing" : true,
         "time_in_queue_millis": 86,
         "time_in_queue": "86ms"
      },
      {
         "insert_order": 46,
         "priority": "HIGH",
         "source": "shard-started ([foo_2][1], node[tMTocMvQQgGCkj7QDHl3OA], [P], s[INITIALIZING]), reason [after recovery from shard_store]",
         "executing" : false,
         "time_in_queue_millis": 842,
         "time_in_queue": "842ms"
      },
      {
         "insert_order": 45,
         "priority": "HIGH",
         "source": "shard-started ([foo_2][0], node[tMTocMvQQgGCkj7QDHl3OA], [P], s[INITIALIZING]), reason [after recovery from shard_store]",
         "executing" : false,
         "time_in_queue_millis": 858,
         "time_in_queue": "858ms"
      }
  ]
}

© 2023-2025 Elasticsearch
As of September 2024, Elasticsearch is available under a choice of three licenses: the Server Side Public License (SSPL), the Elastic License, or the AGPLv3 (OSI approved).
Elasticsearch and the Elasticsearch logo are trademarks of Elasticsearch B.V., registered in the U.S. and in other countries.
https://www.elastic.co/guide/en/elasticsearch/reference/7.17/cluster-pending.html