Elasticsearch — это мощный распределенный поисковый и аналитический движок, который позволяет индексировать, искать и анализировать большие объемы данных в реальном времени. Он широко используется для обеспечения функций поиска, аналитики логов и данных событий, наблюдаемости и многого другого.
С Elasticsearch в AACFlow вы получаете программный доступ к основным возможностям Elasticsearch, включая:
- Поиск документов: Выполняйте расширенный поиск по структурированному или неструктурированному тексту с использованием Запрос DSL, с поддержкой сортировки, пагинации и выбора полей.
- Индексация документов: Добавляйте новые документы или обновляйте существующие в любом индексе Elasticsearch для немедленного извлечения и анализа.
- Получение, обновление или удаление документов: Извлекайте, изменяйте или удаляйте конкретные документы по ID.
- Массовые операции: Выполняйте несколько действий индексации или обновления в одном запросе для обработки данных с высокой пропускной способностью.
- Управление индексами: Создавайте, удаляйте или получайте детали об индексах как часть автоматизации ваших рабочих процессов.
- Мониторинг кластера: Проверяйте состояние и статистику вашего развертывания Elasticsearch.
Инструменты Elasticsearch в AACFlow работают как с самостоятельно размещенными средами, так и с Elastic Cloud. Интегрируйте Elasticsearch в рабочие процессы ваших агентов для автоматизации приема данных, поиска по обширным наборам данных, запуска отчетов или создания пользовательских приложений на основе поиска — все без ручного вмешательства.
Инструкции по использованию
Интегрируйте Elasticsearch в рабочие процессы для мощного поиска, индексации и управления данными. Поддерживает операции CRUD с документами, расширенные поисковые запросы, массовые операции, управление индексами и мониторинг кластера. Работает как с самостоятельно размещенными развертываниями, так и с Elastic Cloud.
Инструменты
elasticsearch_search
Поиск документов в Elasticsearch с использованием Запрос DSL. Возвращает соответствующие документы с оценками и метаданными.
Входные параметры
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
deploymentType | string | Да | Тип развертывания: self_hosted или cloud |
host | string | Нет | URL хоста Elasticsearch (для самостоятельно размещенных) |
cloudId | string | Нет | ID Elastic Cloud (для облачных развертываний) |
authMethod | string | Да | Метод аутентификации: api_key или basic_auth |
apiKey | string | Нет | Ключ API Elasticsearch |
username | string | Нет | Имя пользователя для базовой аутентификации |
password | string | Нет | Пароль для базовой аутентификации |
index | string | Да | Имя индекса для поиска (например, "products", "logs-2024") |
query | string | Нет | Query DSL в виде строки JSON. Пример: {"match":{"title":"search term"}} или {"bool":{"must":[...]}} |
from | number | Нет | Начальное смещение для пагинации (например, 0, 10, 20). По умолчанию: 0 |
size | number | Нет | Количество результатов для возврата (например, 10, 25, 100). По умолчанию: 10 |
sort | string | Нет | Спецификация сортировки в виде строки JSON. Пример: [{"created_at":"desc"}] или [{"_score":"desc"},{"name":"asc"}] |
sourceIncludes | string | Нет | Список полей, разделенных запятыми, для включения в _source |
sourceExcludes | string | Нет | Список полей, разделенных запятыми, для исключения из _source |
trackTotalHits | boolean | Нет | Отслеживать точное общее количество совпадений (по умолчанию: true) |
Выходные данные
| Параметр | Тип | Описание |
|---|---|---|
took | number | Время в миллисекундах, затраченное на поиск |
timed_out | boolean | Истекло ли время поиска |
hits | object | Результаты поиска с общим количеством и соответствующими документами |
aggregations | json | Результаты агрегации, если есть |
elasticsearch_index_document
Индексировать (создать или обновить) документ в Elasticsearch.
Входные параметры
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
deploymentType | string | Да | Тип развертывания: self_hosted или cloud |
host | string | Нет | URL хоста Elasticsearch (для самостоятельно размещенных) |
cloudId | string | Нет | ID Elastic Cloud (для облачных развертываний) |
authMethod | string | Да | Метод аутентификации: api_key или basic_auth |
apiKey | string | Нет | Ключ API Elasticsearch |
username | string | Нет | Имя пользователя для базовой аутентификации |
password | string | Нет | Пароль для базовой аутентификации |
index | string | Да | Имя целевого индекса (например, "products", "logs-2024") |
documentId | string | Нет | ID документа (например, "abc123", "user_456"). Автоматически генерируется, если не предоставлен |
document | string | Да | Тело документа в виде строки JSON |
refresh | string | Нет | Политика обновления: true, false или wait_for |
Выходные данные
| Параметр | Тип | Описание |
|---|---|---|
_index | string | Индекс, где был сохранен документ |
_id | string | ID документа |
_version | number | Версия документа |
result | string | Результат операции (created или updated) |
elasticsearch_get_document
Получить документ по ID из Elasticsearch.
Входные параметры
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
deploymentType | string | Да | Тип развертывания: self_hosted или cloud |
host | string | Нет | URL хоста Elasticsearch (для самостоятельно размещенных) |
cloudId | string | Нет | ID Elastic Cloud (для облачных развертываний) |
authMethod | string | Да | Метод аутентификации: api_key или basic_auth |
apiKey | string | Нет | Ключ API Elasticsearch |
username | string | Нет | Имя пользователя для базовой аутентификации |
password | string | Нет | Пароль для базовой аутентификации |
index | string | Да | Имя индекса (например, "products", "logs-2024") |
documentId | string | Да | ID документа для получения (например, "abc123", "user_456") |
sourceIncludes | string | Нет | Список полей, разделенных запятыми, для включения |
sourceExcludes | string | Нет | Список полей, разделенных запятыми, для исключения |
Выходные данные
| Параметр | Тип | Описание |
|---|---|---|
_index | string | Имя индекса |
_id | string | ID документа |
_version | number | Версия документа |
found | boolean | Был ли найден документ |
_source | json | Содержимое документа |
elasticsearch_update_document
Частично обновить документ в Elasticsearch с использованием слияния doc.
Входные параметры
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
deploymentType | string | Да | Тип развертывания: self_hosted или cloud |
host | string | Нет | URL хоста Elasticsearch (для самостоятельно размещенных) |
cloudId | string | Нет | ID Elastic Cloud (для облачных развертываний) |
authMethod | string | Да | Метод аутентификации: api_key или basic_auth |
apiKey | string | Нет | Ключ API Elasticsearch |
username | string | Нет | Имя пользователя для базовой аутентификации |
password | string | Нет | Пароль для базовой аутентификации |
index | string | Да | Имя индекса (например, "products", "logs-2024") |
documentId | string | Да | ID документа для обновления (например, "abc123", "user_456") |
document | string | Да | Частичный документ для слияния в виде строки JSON |
retryOnConflict | number | Нет | Количество повторных попыток при конфликте версий |