Elastic Search
Kubemq aws-elasticsearch target connector allows services using kubemq server to access aws elasticsearch service.

Prerequisites

The following required to run the aws-elasticsearch target connector:
  • kubemq cluster
  • aws account with elasticsearch active service -elastic service with an active domain
  • kubemq-source deployment

Configuration

aws-elasticsearch target connector configuration properties:
Properties Key
Required
Description
Example
aws_key
yes
aws key
aws key supplied by aws
aws_secret_key
yes
aws secret key
aws secret key supplied by aws
token
no
aws token ("default" empty string
aws token
Example:
1
bindings:
2
- name: kubemq-query-aws-elasticsearch
3
source:
4
kind: kubemq.query
5
name: kubemq-query
6
properties:
7
address: "kubemq-cluster:50000"
8
client_id: "kubemq-query-aws-elasticsearch-connector"
9
auth_token: ""
10
channel: "query.aws.elasticsearch"
11
group: ""
12
auto_reconnect: "true"
13
reconnect_interval_seconds: "1"
14
max_reconnects: "0"
15
target:
16
kind: aws.elasticsearch
17
name: aws-elasticsearch
18
properties:
19
aws_key: "id"
20
aws_secret_key: 'json'
21
token: ""
Copied!

Usage

Sign Message

Sign Message :
Metadata Key
Required
Description
Possible values
method
yes
type of HTTP method
"GET", "POST","PUT","DELETE","OPTIONS"
region
yes
aws region associated with domain
"region"
json
yes (unless "GET")
json body to send with the http request
"list"
domain
yes
elastic domain to assign the request
"list"
index
yes
name of the elastic index
"list"
endpoint
yes
aws domain end point
"list"
service
no(Default "es"
type of service
"list"
id
yes
Message ID
"list"
Example:
1
{
2
"metadata": {
3
"method": "GET",
4
"region": "us-west-2",
5
"domain": "https://my-domain-12345asdfg.us-west-2.es.amazonaws.com",
6
"index": "myindex",
7
"endpoint": "https://my-domain-12345asdfg.us-west-2.es.amazonaws.com/my/end_point",
8
"service": "es",
9
"id": "123124"
10
},
11
"data": null
12
}
Copied!
Last modified 11mo ago