mem0/embedchain/vectordb/chroma_db.py

import chromadb
import os

from chromadb.utils import embedding_functions

from embedchain.vectordb.base_vector_db import BaseVectorDB


class ChromaDB(BaseVectorDB):
    ''' Vector database using ChromaDB. '''
    
    def __init__(self, db_dir=None, ef=None):
        if ef:
            self.ef = ef
        else:
            self.ef = embedding_functions.OpenAIEmbeddingFunction(
                api_key=os.getenv("OPENAI_API_KEY"),
                organization_id=os.getenv("OPENAI_ORGANIZATION"),
                model_name="text-embedding-ada-002"
            )
        if db_dir is None:
            db_dir = "db"
        self.client_settings = chromadb.config.Settings(
            chroma_db_impl="duckdb+parquet",
            persist_directory=db_dir,
            anonymized_telemetry=False
        )
        super().__init__()

    def _get_or_create_db(self):
        ''' Get or create the database. '''
        return chromadb.Client(self.client_settings)

    def _get_or_create_collection(self):
        ''' Get or create the collection. '''
        return self.client.get_or_create_collection(
            'embedchain_store', embedding_function=self.ef,
        )