Pailot

Elasticsearch

Поиск, индексы и документы Elasticsearch в процессах Pailot

Elasticsearch — распределённый поисковый движок: индексы, документы и аналитика. Блок ходит в API (Application Programming Interface — программный интерфейс) своего кластера или Elastic Cloud.

С Elasticsearch в Pailot вы можете:

  • Искать документы через Query DSL (Domain Specific Language — язык запросов Elasticsearch)
  • Индексировать, читать, частично обновлять и удалять документы
  • Делать bulk (пакет операций в одном запросе) и считать совпадения
  • Создавать и удалять индексы, смотреть здоровье и статистику кластера

Нужны тип развёртывания (self_hosted или cloud) и метод входа (api_key или basic_auth). Блок ставят на холст как отдельный шаг или прикрепляют к агенту. Секреты — в переменных окружения рабочего пространства.

Инструменты

Поиск документов по Query DSL: совпадения, оценки и метаданные.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя индекса
querystringНетQuery DSL — строка JSON
fromnumberНетСмещение страницы (по умолчанию 0)
sizenumberНетЧисло результатов (по умолчанию 10)
sortstringНетСортировка — строка JSON
sourceIncludesstringНетПоля _source через запятую — включить
sourceExcludesstringНетПоля _source через запятую — исключить
trackTotalHitsbooleanНетТочный подсчёт совпадений (по умолчанию true)

Выход

ПараметрТипОписание
tooknumberВремя поиска в миллисекундах
timed_outbooleanПоиск превысил таймаут
hitsobjectРезультаты: число совпадений и документы
aggregationsjsonАгрегации, если были

elasticsearch_index_document

Индексировать документ (создать или обновить).

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаЦелевой индекс
documentIdstringНетID документа (если пусто — сгенерируется)
documentstringДаТело документа — строка JSON
refreshstringНетПолитика refresh: true, false или wait_for

Выход

ПараметрТипОписание
_indexstringИндекс, куда записали документ
_idstringID документа
_versionnumberВерсия документа
resultstringРезультат (created или updated)

elasticsearch_get_document

Прочитать документ по ID.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя индекса
documentIdstringДаID документа
sourceIncludesstringНетПоля через запятую — включить
sourceExcludesstringНетПоля через запятую — исключить

Выход

ПараметрТипОписание
_indexstringИмя индекса
_idstringID документа
_versionnumberВерсия документа
foundbooleanДокумент найден
_sourcejsonСодержимое документа

elasticsearch_update_document

Частично обновить документ слиянием полей.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя индекса
documentIdstringДаID документа
documentstringДаЧастичный документ для слияния — строка JSON
retryOnConflictnumberНетЧисло повторов при конфликте версии

Выход

ПараметрТипОписание
_indexstringИмя индекса
_idstringID документа
_versionnumberНовая версия документа
resultstringРезультат (updated или noop)

elasticsearch_delete_document

Удалить документ по ID.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя индекса
documentIdstringДаID документа
refreshstringНетПолитика refresh: true, false или wait_for

Выход

ПараметрТипОписание
_indexstringИмя индекса
_idstringID документа
_versionnumberВерсия документа
resultstringРезультат (deleted или not_found)

elasticsearch_bulk

Несколько операций index, create, delete или update в одном запросе.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringНетИндекс по умолчанию, если в операции не указан
operationsstringДаОперации bulk — строка NDJSON (JSON по строкам)
refreshstringНетПолитика refresh: true, false или wait_for

Выход

ПараметрТипОписание
tooknumberВремя операции в миллисекундах
errorsbooleanБыли ли ошибки в операциях
itemsarrayРезультат каждой операции

elasticsearch_count

Число документов, подходящих под запрос.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИндекс для подсчёта
querystringНетНеобязательный фильтр — строка JSON

Выход

ПараметрТипОписание
countnumberЧисло документов по запросу
_shardsobjectСтатистика шардов

elasticsearch_create_index

Создать индекс с необязательными settings и mappings.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя нового индекса
settingsstringНетНастройки индекса — строка JSON
mappingsstringНетМаппинги индекса — строка JSON

Выход

ПараметрТипОписание
acknowledgedbooleanЗапрос принят
shards_acknowledgedbooleanШарды подтверждены
indexstringИмя созданного индекса

elasticsearch_delete_index

Удалить индекс и все его документы. Операция необратима.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя индекса

Выход

ПараметрТипОписание
acknowledgedbooleanУдаление подтверждено

elasticsearch_get_index

Информация об индексе: settings, mappings и aliases.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
indexstringДаИмя индекса

Выход

ПараметрТипОписание
indexjsonДанные индекса: aliases, mappings и settings

elasticsearch_cluster_health

Здоровье кластера Elasticsearch.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth
waitForStatusstringНетЖдать статус: green, yellow или red
timeoutstringНетТаймаут ожидания (например, 30s, 1m)

Выход

ПараметрТипОписание
cluster_namestringИмя кластера
statusstringСтатус: green, yellow или red
number_of_nodesnumberВсего узлов
number_of_data_nodesnumberЧисло узлов данных
active_shardsnumberАктивные шарды
unassigned_shardsnumberНеназначенные шарды

elasticsearch_cluster_stats

Сводная статистика кластера.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth

Выход

ПараметрТипОписание
cluster_namestringИмя кластера
statusstringСтатус здоровья
nodesobjectСтатистика узлов: число и версии
indicesobjectСтатистика индексов: документы и размер

elasticsearch_list_indices

Список индексов: здоровье, статус и статистика.

Вход

ПараметрТипОбязательныйОписание
deploymentTypestringДаТип развёртывания: self_hosted или cloud
hoststringНетURL узла Elasticsearch (для self_hosted)
cloudIdstringНетCloud ID Elastic (для cloud)
authMethodstringДаМетод входа: api_key или basic_auth
apiKeystringНетКлюч API Elasticsearch
usernamestringНетИмя пользователя для basic auth
passwordstringНетПароль для basic auth

Выход

ПараметрТипОписание
messagestringКраткое сообщение по индексам
indicesjsonМассив сведений об индексах
На этой странице

На этой странице

Получить доступ
Копилот собирает процесс. Менеджер запускает сам. Можно поставить в контур компании.
Получить доступ