Trigger a flow based on an HTTP response
type: "io.kestra.plugin.core.http.Trigger"Send a Slack alert if the price is below a certain threshold. The flow will be triggered every 30 seconds until the condition is met. Then, the stopAfter property will disable the trigger to avoid unnecessary API calls and alerts.
id: http_price_alert
namespace: company.team
tasks:
- id: send_slack_alert
type: io.kestra.plugin.notifications.slack.SlackIncomingWebhook
url: "{{ secret('SLACK_WEBHOOK') }}"
payload: |
{
"channel": "#price-alerts",
"text": "The price is now: {{ json(trigger.body).price }}"
}
triggers:
- id: http
type: io.kestra.plugin.core.http.Trigger
uri: https://fakestoreapi.com/products/1
responseCondition: "{{ json(response.body).price <= 110 }}"
interval: PT30S
stopAfter:
- SUCCESS
Trigger a flow if an HTTP endpoint returns a status code equals to 200
id: http_trigger
namespace: company.team
tasks:
- id: log_response
type: io.kestra.plugin.core.log.Log
message: '{{ trigger.body }}'
triggers:
- id: http
type: io.kestra.plugin.core.http.Trigger
uri: https://api.chucknorris.io/jokes/random
responseCondition: "{{ response.statusCode == 200 }}"
stopAfter:
- SUCCESS
The condition on the HTTP response to trigger a flow which can be any expression that evaluates to a boolean value.
The condition will be evaluated after calling the HTTP endpoint, it can use the response itself to determine whether to start a flow or not. The following variables are available when evaluating the condition:
response.statusCode: the response HTTP status coderesponse.body: the response body as a stringresponse.headers: the response headers
Boolean coercion allows 0, -0, null and '' to evaluate to false, all other values will evaluate to true.
The condition will be evaluated before any 'generic trigger conditions' that can be configured via the conditions property.
The fully-qualified URI that points to the HTTP destination
The full body as a string
The request content type
The form data to be send
The headers to pass to the request
Interval between polling.
The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.
The HTTP method to use
The HTTP request options
The SSL request options
List of execution states after which a trigger should be stopped (a.k.a. disabled).
The body of the response.
Kestra will by default store the task output using this property. However, if the encryptBody property is set to true, kestra will instead encrypt the output and store it using the encryptedBody output property.
The status code of the response.
The encrypted body of the response.
If the encryptBody property is set to true, kestra will automatically encrypt the output before storing it, and decrypt it when the output is retrieved in a downstream task.
The form data to be sent in the request body
When sending a file, you can pass a list of maps (i.e. a list of key-value pairs) with a key 'name' and value of the filename, as well as 'content' key with the file's content as value (e.g. passed from flow inputs or outputs from another task).
The headers of the response.
The URL of the current request.
The time allowed to establish a connection to the server before failing.
The time allowed for a read connection to remain idle before closing it.
The password for HTTP basic authentication.
The username for HTTP basic authentication.
The password for HTTP basic authentication.
The username for HTTP basic authentication.
The time allowed to establish a connection to the server before failing.
The time an idle connection can remain in the client's connection pool before being closed.
The log level for the HTTP client.
The enabled log.
The proxy configuration.
The address of the proxy server.
The password for proxy authentication.
The type of proxy to use.
The username for proxy authentication.
The time allowed for a read connection to remain idle before closing it.
The maximum time allowed for reading data from the server before failing.
The SSL request options
The timeout configuration.
The address of the proxy server.
The password for proxy authentication.
The username for proxy authentication.
The token for bearer token authentication.