OpenSearch
CertifiedEnterprise EditionTasks that connect to OpenSearch over HTTP for indexing and log export.
Use these tasks to push execution logs or other documents into OpenSearch indices via bulk REST calls. Provide one or more host URLs (with scheme and port) and the target index name; optional basic auth, custom headers, path prefix, and TLS trust-all assist with secured or proxied clusters.
OpenSearch
Tasks that connect to OpenSearch over HTTP for indexing and log export.
Use these tasks to push execution logs or other documents into OpenSearch indices via bulk REST calls. Provide one or more host URLs (with scheme and port) and the target index name; optional basic auth, custom headers, path prefix, and TLS trust-all assist with secured or proxied clusters.
log Exporters
How to use the OpenSearch EE plugin
Ship Kestra execution logs to OpenSearch from Kestra flows.
Authentication
Set connection.hosts (required, list of OpenSearch endpoints including scheme and port, e.g. https://opensearch.com: 9200). Authenticate via connection.basicAuth.username and connection.basicAuth.password, or pass a custom Authorization header via connection.headers. Optionally set connection.pathPrefix (for clusters behind a proxy), connection.trustAllSsl (default false), and connection.strictDeprecationMode (default false). Store secrets in secrets and set connection properties on each task.
Log exporters
LogExporter ships execution logs to OpenSearch via the Bulk API — set connection and indexName (both required). Optionally set chunk (logs per bulk request, default 1000).
