Bulk load documents in ElasticSearch using bulk elastic files.
Read more about Elastic bulk files in their official documentation.
type: "io.kestra.plugin.elasticsearch.bulk"Examples
id: elasticsearch_bulk_load
namespace: company.team
inputs:
- id: file
type: FILE
tasks:
- id: bulk_load
type: io.kestra.plugin.elasticsearch.Bulk
connection:
hosts:
- "http://localhost:9200"
from: "{{ inputs.file }}"
Properties
connection*RequiredNon-dynamic
The connection properties.
io.kestra.plugin.elasticsearch.ElasticsearchConnection
1List of HTTP ElasticSearch servers.
Must be an URI like https://elasticsearch.com: 9200 with scheme and port.
Basic auth configuration.
io.kestra.plugin.elasticsearch.ElasticsearchConnection-BasicAuth
Basic auth password.
Basic auth username.
List of HTTP headers to be send on every request.
Must be a string with key value separated with : , ex: Authorization: Token XYZ.
Sets the path's prefix for every request used by the HTTP client.
For example, if this is set to /my/path, then any client request will become /my/path/ + endpoint.
In essence, every request's endpoint is prefixed by this pathPrefix.
The path prefix is useful for when ElasticSearch is behind a proxy that provides a base path or a proxy that requires all paths to start with '/'; it is not intended for other purposes and it should not be supplied in other scenarios.
Whether the REST client should return any response containing at least one warning header as a failure.
Trust all SSL CA certificates.
Use this if the server is using a self signed SSL certificate.
from*Requiredstring
The source file.
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.
chunkintegerstring
1000The chunk size for every bulk request.
routingstring
Controls the shard routing of the request.
Using this value to hash the shard and not the id.
Outputs
sizeinteger
The size of the rows fetched.
Metrics
recordscounter
recordsNumber of records loaded
requests.countcounter
Number of bulk requests sent
requests.durationtimer
Duration of bulk requests
