Request
yaml
type: "io.kestra.plugin.opensearch.request"
Examples
yaml
id: opensearch_request
namespace: company.team
tasks:
- id: request_post
type: io.kestra.plugin.opensearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "POST"
endpoint: "my_index/_doc/john"
body:
name: "john"
yaml
id: opensearch_request
namespace: company.team
tasks:
- id: request_get
type: io.kestra.plugin.opensearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "GET"
endpoint: "my_index/_search"
parameters:
q: "name:"John Doe""
yaml
id: opensearch_request
namespace: company.team
tasks:
- id: request_delete
type: io.kestra.plugin.opensearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "DELETE"
endpoint: "my_index/_doc/<_id>"
Properties
connection *RequiredNon-dynamicOpensearchConnection
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.opensearch.OpensearchConnection
hosts *Requiredarray
SubType string
basicAuth OpensearchConnection-BasicAuth
headers array
SubType string