Elasticsearch

Overview

The Elasticsearch connector allows you to sync data from Elasticsearch into Graffo, making it available for search and retrieval by your agents.

Configuration

ElasticsearchSource

Elasticsearch source implementation.

Connects to an Elasticsearch cluster, retrieves index metadata and documents for configured indices using the scroll API.

Source Code: View on GitHub

Authentication

This connector uses a custom authentication configuration class: ElasticsearchAuthConfig.

Entities

The following data models are available for this connector:

ElasticsearchIndexEntity

Schema for Elasticsearch index entities.

Field	Type	Description
index	str	Name of the Elasticsearch index
health	Optional[str]	Health status of the index
status	Optional[str]	Status of the index
docs_count	Optional[int]	Number of documents in the index
docs_deleted	Optional[int]	Number of deleted documents in index
store_size	Optional[str]	Store size of the index

ElasticsearchDocumentEntity

Schema for Elasticsearch document entities.

Field	Type	Description
index	str	Name of the index this document belongs to
doc_id	str	Document ID
source	Dict[str, Any]	Source document content