Request
yaml
type: "io.kestra.plugin.elasticsearch.request"
Examples
yaml
id: elasticsearch_request
namespace: company.team
tasks:
- id: request_post
type: io.kestra.plugin.elasticsearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "POST"
endpoint: "my_index/_doc/john"
body:
name: "john"
yaml
id: elasticsearch_request
namespace: company.team
tasks:
- id: request_get
type: io.kestra.plugin.elasticsearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "GET"
endpoint: "my_index/_search"
parameters:
q: "name:"John Doe""
yaml
id: elasticsearch_request
namespace: company.team
tasks:
- id: request_delete
type: io.kestra.plugin.elasticsearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "DELETE"
endpoint: "my_index/_doc/<_id>"
Properties
connection *RequiredNon-dynamicElasticsearchConnection
endpoint *Requiredstring
body object
method string
Default
GET
Possible Values
CONNECT
CUSTOM
DELETE
GET
HEAD
OPTIONS
PATCH
POST
PUT
TRACE
parameters object
SubType string
routing string
Outputs
response object
status integer
Definitions
io.kestra.plugin.elasticsearch.ElasticsearchConnection
hosts *Requiredarray
SubType string
Min items
1
basicAuth ElasticsearchConnection-BasicAuth
headers array
SubType string