Aigenthix/Graph_RAG
0
1�
2 �d;j � �z � S r SSKJrJrJr SSKrSSKrSSKrSSKJ r \R " \ 5 r " S S\ 5 r
g)�%Chroma vector database implementation� )�List�Dict�AnyN� )�VectorDBProviderc 3 �� � \ rS rSrSrS rS\\\4 SS4S jr S\4\5\ S \6\ S7\8\\\4 S\ 4S jr
SS \9\ S
\S\10\\\4 4S jjrS\S\ 4S jrS\ 4S jrS\\\4 4S jrSrg)�ChromaDB�
r c � � S U l S U l g )N��client�11collection)�selfs �]/Users/ssp/Downloads/SSP7/Claude folder/KnowledgeHut/POC1/backend/app/vector_dbs/chroma_db.py�__init__�ChromaDB.__init__ s � ��� � ��� �config�returnNc �N � UR SS5 n[ R " USS9 [ R " US9U l U R12 R
SSS0S 9U l [ R S13U 35 g ! [ a n[ R S U 35 e S nAff = f)
zInitialize Chroma database� storage_pathz./data/chroma_dataT)�exist_ok)�path�
rag_documentsz14hnsw:space�cosine)�name�metadataz Chroma database initialized at z Failed to initialize Chroma: N) �get�os�makedirs�chromadb�PersistentClientr �get_or_create_collectionr �logger�info� Exception�error)r r r �es r �15initialize�ChromaDB.initialize s� � �
��:�:�n�.B�C�D� �K�K��t� ,�"�3�3��>�D�K� "�k�k� B� B�$�&��1� C� �D�O�16
�K�K�9�$��@� A��� � �L�L�8���<� =� �� �s �A9A< �<17B$�B � B$�vectors�idsr c �� � U R R UUUS9 [ R S[ U5 S35 g! [18 a" n[ R
SU 35 SnAgSnAff = f)z Add vectors to Chroma collection)r- �19embeddings� metadataszAdded z vectors to ChromaTz!Failed to add vectors to Chroma: NF)r �upsertr% r& �lenr' r( )r r, r- r r) s r � add_vectors�ChromaDB.add_vectors% sm � �20 � �O�O� "� "��"�"�
#�
�21
�K�K�&��S��22�*<�=� >���� � �L�L�<�Q�C�@� A��� �s �=A � 23A,�24A'�'A,� query_vector�top_kc � � U R R U/U/ SQS9n/ nU( aw US ( am [ US 5 S:� a[ [ US S 5 HF u pVUS S U nSU-25 nUS S U n UR UU R SS 5 U US26.5 MH U$ ! [ a$ n27[ R S U28 35 / s S n29A30$ S n31A32ff = f)
z$Search for similar vectors in Chroma)r/ r0 � distances)�query_embeddings� n_results�includer- r r8 r r0 �text� )�id�contentr �similarity_scorezSearch failed in Chroma: N) r �queryr2 � enumerate�appendr r' r% r( ) r r5 r6 �results�search_results�idx�doc_id�distance�33similarityr r) s r �search�ChromaDB.search8 s� � � ��o�o�+�+�".� � �@� ,� �G� �N��7�5�>�c�'�%�.�.A�A�.E�#,�W�U�^�A�->�#?�K�C� &�{� 3�A� 6�s� ;�H�!"�X� �J� &�{� 3�A� 6�s� ;�H�"�)�)� $�#+�<�<���#;�$,�,6� +� �
$@� "� !��� � �L�L�4�Q�C�8� 9��I�� �s �B B" �"34C�,C �C� CrG c �� � U R R U/S9 [ R SU S35 g! [ a" n[ R SU 35 SnAgSnAff = f)zDelete document from Chroma)r- zDeleted z from ChromaTz Failed to delete from Chroma: NF)r �deleter% r& r' r( )r rG r) s r rM �ChromaDB.deleteY s] � � � �O�O� "� "��x� "� 0� �K�K�(�6�(�,�7� 8���� � �L�L�9�!��=� >��� �s �36 �35A"� A � A"c � � U R c gU R R 5 ng! [ a" n[ R SU 35 SnAgSnAff = f)z Check Chroma database healthNFTz Chroma health check failed: �r �countr' r% r( �r rQ r) s r � health_check�ChromaDB.health_checkc sP � � ����&� ��O�O�)�)�+�E���� � �L�L�7��s�;� <��� �s �
+ �+ �36A�A�Ac � � U R R 5 nSUSS.$ ! [ a$ n[ R SU 35 0 s SnA$ SnAff = f)z Get Chroma database statistics�chromar )�type� documents�collection_namez Failed to get Chroma stats: NrP rR s r � get_stats�ChromaDB.get_statsn sW � � ��O�O�)�)�+�E� � "�#2��
��37 � � �L�L�7��s�;� <��I�� �s � " �38A�A �A� Ar
)� )�__name__�39__module__� __qualname__�__firstlineno__�__doc__r r �strr r* r �float�boolr3 �intrJ rM rS rZ �__static_attributes__� r r r40 r41
s� � �/� ���c�3�h� � �D� �"��d�5�k�"�� �#�Y�� �t�C��H�~�&� �42 43� �, � ��5�k� � � � 44�d�3��8�n� � �B�S� �T� � �d� � �4��S��>� r r45 )ra �typingr r r r" �loggingr �baser � getLoggerr] r% r46 rg r r �<module>rl s9 �� +� "� "� � � � "� � � �8� $��l� � lr