Portal Community

When to Use

Configuration

Connection

FieldRequiredDescription
HostRequiredElasticsearch cluster URL, e.g. https://localhost:9200.
UsernameOptionalElasticsearch username (required if security is enabled).
PasswordOptionalPassword for the specified username.
IgnoreSSLOptionalDefault false. Skip TLS validation. Development use only.

Operation

FieldRequiredDescription
IndexNameRequiredThe index containing the document.
DocumentIdRequiredThe exact _id of the document to retrieve. Supports BizFirst expressions, e.g. {{ $json.orderId }}.

Validation Errors

Error CodeCause
VAL_MISSING_INDEXIndexName is empty.
VAL_MISSING_DOC_IDDocumentId is empty.

Output

Success Port

Returns the Elasticsearch get response object via ElasticsearchOperationResult.Data:

FieldTypeDescription
_idstringThe document ID.
_indexstringThe index the document belongs to.
_versionintegerCurrent version of the document. Increments on each update.
_sourceobjectThe full document body — all indexed fields and their current values.
foundbooleantrue when the document exists. A false value routes to the error port.

Error Port

Fires when the document does not exist (404), authentication fails, or a network error occurs. The error output contains errorCode and message fields.

Access the document body downstream with {{ $output.nodeName._source.fieldName }}. For example, if the node is called getOrder, use {{ $output.getOrder._source.status }} to read the order status.

Example

Retrieve an Order by ID

{
  "resource": "document",
  "operation": "get",
  "IndexName": "orders",
  "DocumentId": "{{ $json.orderId }}"
}

On the success port, access fields with {{ $output.getOrder._source.customerEmail }}. On the error port, handle the not-found case — for example, send a "order not found" response or trigger a fallback database lookup.

Existence Check — Branch Pattern

{
  "resource": "document",
  "operation": "get",
  "IndexName": "product-cache",
  "DocumentId": "{{ $json.productId }}"
}

Connect the success port to a "cache hit" branch and the error port to a "cache miss" branch that calls the source API and then indexes the result with document/create.