factory.py 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. from open_webui.retrieval.vector.main import VectorDBBase
  2. from open_webui.retrieval.vector.type import VectorType
  3. from open_webui.config import VECTOR_DB
  4. class Vector:
  5. @staticmethod
  6. def get_vector(vector_type: str) -> VectorDBBase:
  7. """
  8. get vector db instance by vector type
  9. """
  10. match vector_type:
  11. case VectorType.MILVUS:
  12. from open_webui.retrieval.vector.dbs.milvus import MilvusClient
  13. return MilvusClient()
  14. case VectorType.QDRANT:
  15. from open_webui.retrieval.vector.dbs.qdrant import QdrantClient
  16. return QdrantClient()
  17. case VectorType.PINECONE:
  18. from open_webui.retrieval.vector.dbs.pinecone import PineconeClient
  19. return PineconeClient()
  20. case VectorType.OPENSEARCH:
  21. from open_webui.retrieval.vector.dbs.opensearch import OpenSearchClient
  22. return OpenSearchClient()
  23. case VectorType.PGVECTOR:
  24. from open_webui.retrieval.vector.dbs.pgvector import PgvectorClient
  25. return PgvectorClient()
  26. case VectorType.ELASTICSEARCH:
  27. from open_webui.retrieval.vector.dbs.elasticsearch import (
  28. ElasticsearchClient,
  29. )
  30. return ElasticsearchClient()
  31. case VectorType.CHROMA:
  32. from open_webui.retrieval.vector.dbs.chroma import ChromaClient
  33. return ChromaClient()
  34. case _:
  35. raise ValueError(f"Unsupported vector type: {vector_type}")
  36. VECTOR_DB_CLIENT = Vector.get_vector(VECTOR_DB)