Elasticsearch

Version: 2.0.0

Elasticsearch is a search engine based on Lucene. It provides a distributed, multitenant-capable full-text search engine with an HTTP web interface and schema-free JSON documents.

Connect Elasticsearch with LogicHub

  1. Navigate to Automations > Integrations.
  2. Search for Elasticsearch.
  3. Click Details, then the + icon. Enter the required information in the following fields.
    • Label: Enter a connection name.
    • Reference Values: Define variables here to templatize integration connections and actions. For example, you can use https://www.{{hostname}}.com where, hostname is a variable defined in this input. For more information on how to add data, see 'Add Data' Input Type for Integrations.
    • Verify SSL: Select option to verify connecting server's SSL certificate (Default is Verify SSL Certificate).
    • Remote Agent: Run this integration using the LogicHub Remote Agent.
    • Server URL: Enter server URL for Elasticsearch.
    • Username: Enter Username for Elasticsearch.
    • Password: Enter Password for Elasticsearch.
  4. After you've entered all the details, click Connect.

Actions for Elasticsearch

Run Query v2

Runs the query on Elasticsearch service.

Input Field

Choose a connection that you have previously created and then fill in the necessary information in the following input fields to complete the connection.

Input NameDescriptionRequired
Index NameSelect column that contains index name to run the ES query on.Required
Query TypeSelect Query Type Basic/Advanced.Required
Jinja Template for QueryTemplate of the elastic search query.
Example:
Basic Query
title:"{{title_column}}" AND text:{{text_column}}

Advanced Query
{"query": { "multi_match" : { "query": "{{search_text}}", "fields": [ "subject", "message" ] }}}
Required
Query TimeoutQuery timeout in seconds (default is 30 seconds).Optional
Stored FieldsSelect column that contains value for Stored Fields.Optional
Records SizeEnter Size for Elastic search records. (default is 10).Optional

Output

A JSON object containing multiple rows of correlated result:

  • has_error: True/False
  • error: message/null
  • other keys of Elasticsearch Query Results
1392

Insert Records

Inserts records in an Elasticsearch index.

Input Field

Choose a connection that you have previously created and then fill in the necessary information in the following input fields to complete the connection.

Input NameDescriptionRequired
Select IndexSelect column that contains the index name where the records are to be inserted.Required
Jinja Template for DocumentEnter jinja-templated document JSON.
Example:
{ "fname": "{{firstname_col}}", "lname": "{{lastname_col}}" }
Required
Batch SizeEnter a number of rows to process in one batch of the bulk insert. (Default is 100).Optional

Output

A JSON object containing multiple rows of correlated result:

  • has_error: True/False
  • error: message/null
  • other keys of insert response per document returned by Elasticsearch.
1392

Release Notes

  • v2.0.0 - Updated architecture to support IO via filesystem

© Devo Technology Inc. All Rights Reserved.