Added Elasticsearch Vector Store

src/backend/langflow/config.yaml

@@ -274,6 +274,8 @@ vectorstores:
     documentation: "https://python.langchain.com/docs/modules/data_connection/vectorstores/integrations/faiss"
   Pinecone:
     documentation: "https://python.langchain.com/docs/modules/data_connection/vectorstores/integrations/pinecone"
+  ElasticsearchStore:
+    documentation: "https://python.langchain.com/docs/modules/data_connection/vectorstores/integrations/elasticsearch"
   SupabaseVectorStore:
     documentation: "https://python.langchain.com/docs/modules/data_connection/vectorstores/integrations/supabase"
   MongoDBAtlasVectorSearch:

src/backend/langflow/interface/initialize/vector_store.py

@@ -1,6 +1,7 @@
 from typing import Any, Callable, Dict, Type
 from langchain.vectorstores import (
     Pinecone,
+    ElasticsearchStore,
     Qdrant,
     Chroma,
     FAISS,
@@ -226,11 +227,34 @@ def initialize_qdrant(class_object: Type[Qdrant], params: dict):
     return class_object.from_documents(**params)
 
 
+def initialize_elasticsearch(class_object: Type[ElasticsearchStore], params: dict):
+    """Initialize elastic and return the class object"""
+    if "index_name" not in params:
+        raise ValueError("Elasticsearch Index must be provided in the params")
+    if "es_url" not in params:
+        raise ValueError("Elasticsearch URL must be provided in the params")
+    if not docs_in_params(params):
+        existing_index_params = {
+            "embedding": params.pop("embedding"),
+        }
+        if "index_name" in params:
+            existing_index_params["index_name"] = params.pop("index_name")
+        if "es_url" in params:
+            existing_index_params["es_url"] = params.pop("es_url")
+
+        return class_object.from_existing_index(**existing_index_params)
+    # If there are docs in the params, create a new index
+    if "texts" in params:
+        params["documents"] = params.pop("texts")
+    return class_object.from_documents(**params)
+
+
 vecstore_initializer: Dict[str, Callable[[Type[Any], dict], Any]] = {
     "Pinecone": initialize_pinecone,
     "Chroma": initialize_chroma,
     "Qdrant": initialize_qdrant,
     "Weaviate": initialize_weaviate,
+    "ElasticsearchStore": initialize_elasticsearch,
     "FAISS": initialize_faiss,
     "SupabaseVectorStore": initialize_supabase,
     "MongoDBAtlasVectorSearch": initialize_mongodb,

src/backend/langflow/template/frontend_node/vectorstores.py

@@ -11,6 +11,7 @@ BASIC_FIELDS = [
     "persist_directory",
     "persist",
     "weaviate_url",
+    "es_url",
     "index_name",
     "namespace",
     "folder_path",
@@ -170,6 +171,33 @@ class VectorStoreFrontendNode(FrontendNode):
                 value="",
             )
             extra_fields.extend((extra_field, extra_field2))
+
+        elif self.template.type_name == "ElasticsearchStore":
+            # add elastic and elastic credentials
+            extra_field = TemplateField(
+                name="es_url",
+                field_type="str",
+                required=True,
+                placeholder="http://localhost:9200",
+                show=True,
+                advanced=False,
+                multiline=False,
+                value="http://localhost:9200",
+                display_name="Elasticsearch URL",
+            )
+            extra_field2 = TemplateField(
+                name="index_name",
+                field_type="str",
+                required=True,
+                placeholder="test-index",
+                show=True,
+                advanced=False,
+                multiline=False,
+                value="test-index",
+                display_name="Index Name",
+            )
+            extra_fields.extend((extra_field, extra_field2))
+
         elif self.template.type_name == "FAISS":
             extra_field = TemplateField(
                 name="folder_path",