API для сброса задач
Принудительно обрабатывает все данные из буфера задачей.
Запрос
POST _ml/anomaly_detectors/<job_id>/_flush
Предварительные условия
Требуется привилегия кластера manage_ml. Эта привилегия включена в встроенную роль machine_learning_admin.
Описание
API сброса задач применим только при отправке данных для анализа с помощью API отправки данных в задачи. В зависимости от содержимого буфера, он также может рассчитывать новые результаты.
Операции сброса и закрытия похожи, однако сброс более эффективен, если ожидается отправка большего количества данных для анализа. При сбросе задача остаётся открытой и доступна для продолжения анализа данных. Операция закрытия дополнительно обрезает и сохраняет состояние модели на диске, и задачу необходимо снова открыть перед анализом дополнительных данных.
Параметры пути
-
<job_id> - (Обязательный, строка) Идентификатор задачи обнаружения аномалий.
Параметры запроса
-
advance_time - (строка) Необязательно. Указывает на продвижение до конкретной временной метки. Результаты генерируются, и модель обновляется для данных из указанного интервала времени.
-
calc_interim - (Булево) Необязательно. Если значение true, рассчитываются промежуточные результаты для самого последнего или всех блоков в период задержки.
-
end - (строка) Необязательно. При использовании в сочетании с
calc_interimиstart, определяет диапазон блоков, для которых необходимо вычислить промежуточные результаты. -
skip_time - (строка) Необязательно. Указывает на пропуск до конкретной временной метки. Результаты не генерируются, и модель не обновляется для данных из указанного интервала времени.
-
start - (строка) Необязательно. При использовании в сочетании с
calc_interim, определяет диапазон блоков, для которых необходимо вычислить промежуточные результаты.
Тело запроса
Вы также можете указать параметры запроса (например, advance_time и calc_interim) в теле запроса.
Примеры
POST _ml/anomaly_detectors/total-requests/_flush
{
"calc_interim": true
} При успешной операции вы получаете следующие результаты:
{
"flushed": true,
"last_finalized_bucket_end": 1455234900000
} last_finalized_bucket_end содержит временную метку (в миллисекундах с начала эпохи) конца последнего обработанного блока.
Если требуется сбросить задачу до определённой временной метки, можно использовать параметры advance_time или skip_time. Например, для перехода к 11:00 по Гринвичу 1 января 2018 года:
POST _ml/anomaly_detectors/total-requests/_flush
{
"advance_time": "1514804400000"
} При успешной операции вы получаете следующие результаты:
{
"flushed": true,
"last_finalized_bucket_end": 1514804400000
}
© 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/ml-flush-job.html
