Webhook action | Elasticsearch Guide [7.7]

原文地址: https://www.elastic.co/guide/en/elasticsearch/reference/7.7/actions-webhook.html, 原文档版权归 www.elastic.co 所有

IMPORTANT: No additional bug fixes or documentation updates will be released for this version. For the latest information, see the current release documentation.

» » »

« Email action Index action »

Webhook actionedit

Use the webhook action to send a request to any web service. The webhook action supports both HTTP and HTTPS connections. See Webhook action attributes for the supported attributes.

Configuring webhook actionsedit

You configure webhook actions in the actions array. Action-specific attributes are specified using the webhook keyword.

The following snippet shows a simple webhook action definition:

"actions" : {
  "my_webhook" : { 
    "transform" : { ... }, 
    "throttle_period" : "5m", 
    "webhook" : {
      "method" : "POST", 
      "host" : "mylisteningserver", 
      "port" : 9200, 
      "path": ":/{{ctx.watch_id}}", 
      "body" : "{{ctx.watch_id}}:{{ctx.payload.hits.total.value}}" 
    }
  }
}

	The id of the action
	An optional transform to transform the payload before executing the `webhook` action
	An optional throttle period for the action (5 minutes in this example)
	The HTTP method to use when connecting to the host
	The host to connect to
	The port to connect to
	The path (URI) to use in the HTTP request
	The body to send with the request

You can use basic authentication when sending a request to a secured webservice. For example, the following webhook action creates a new issue in GitHub:

"actions" : {
  "create_github_issue" : {
    "transform": {
      "script": "return ['title':'Found errors in \\'contact.html\\'', 'body' : 'Found ' + ctx.payload.hits.total.value + ' errors in the last 5 minutes', 'assignee' : 'web-admin', 'labels' : ['bug','sev2']]"
    },
    "webhook" : {
      "method" : "POST",
      "url" : "https://api.github.com/repos/<owner>/<repo>/issues",
      "body": "{{#toJson}}ctx.payload{{/toJson}}",
      "auth" : {
        "basic" : {
          "username" : "<username>", 
          "password" : "<password>"
        }
      }
    }
  }
}

The username and password for the user creating the issue

By default, both the username and the password are stored in the .watches index in plain text. When the Elasticsearch security features are enabled, Watcher can encrypt the password before storing it.

You can also use PKI-based authentication when submitting requests to a cluster that has Elasticsearch security features enabled. When you use PKI-based authentication instead of HTTP basic auth, you don’t need to store any authentication information in the watch itself. To use PKI-based authentication, you configure the SSL key settings for Watcher in elasticsearch.yml.

Query Parametersedit

You can specify query parameters to send with the request with the params field. This field simply holds an object where the keys serve as the parameter names and the values serve as the parameter values:

"actions" : {
  "my_webhook" : {
    "webhook" : {
      "method" : "POST",
      "host" : "mylisteningserver",
      "port" : 9200,
      "path": ":/alert",
      "params" : {
        "watch_id" : "{{ctx.watch_id}}" 
      }
    }
  }
}

The parameter values can contain templated strings.

Custom Request Headersedit

You can specify request headers to send with the request with the headers field. This field simply holds an object where the keys serve as the header names and the values serve as the header values:

"actions" : {
  "my_webhook" : {
    "webhook" : {
      "method" : "POST",
      "host" : "mylisteningserver",
      "port" : 9200,
      "path": ":/alert/{{ctx.watch_id}}",
      "headers" : {
        "Content-Type" : "application/yaml" 
      },
      "body" : "count: {{ctx.payload.hits.total.value}}"
    }
  }
}

The header values can contain templated strings.

Webhook action attributesedit

Name	Required	Default	Description
`scheme`	no	http	The connection scheme. Valid values are: `http` or `https`.
`host`	yes	-	The host to connect to.
`port`	yes	-	The port the HTTP service is listening on.
`path`	no	-	The URL path. The path can be static text or include Mustache templates. URL query string parameters must be specified via the `request.params` attribute.
`method`	no	get	The HTTP method. Valid values are: `head`, `get`, `post`, `put` and `delete`.
`headers`	no	-	The HTTP request headers. The header values can be static text or include Mustache templates.
`params`	no	-	The URL query string parameters. The parameter values can be static text or include Mustache templates.
`auth`	no	-	Authentication related HTTP headers. Currently, only basic authentication is supported.
`body`	no	-	The HTTP request body. The body can be static text or include Mustache templates. When not specified, an empty body is sent.
`proxy.host`	no	-	The proxy host to use when connecting to the host.
`proxy.port`	no	-	The proxy port to use when connecting to the host.
`connection_timeout`	no	10s	The timeout for setting up the http connection. If the connection could not be set up within this time, the action will timeout and fail.
`read_timeout`	no	10s	The timeout for reading data from http connection. If no response was received within this time, the action will timeout and fail.
`url`	no	-	A shortcut for specifying the request scheme, host, port, and path as a single string. For example, `http://example.org/foo/my-service`.

« Email action Index action »