Skip to main content

Native Qdrant implementation for Thoth Vector Database

Project description

Thoth Qdrant

A native Qdrant implementation for the Thoth Vector Database system, providing high-performance vector storage and similarity search capabilities without Haystack dependencies.

Features

  • Native Qdrant Integration: Direct use of Qdrant client without Haystack
  • Full API Compatibility: Same interface as thoth_vdb2 for seamless integration
  • External Embeddings: Support for OpenAI, Cohere, Mistral, and HuggingFace
  • Document Types: EvidenceDocument, SqlDocument, ColumnNameDocument
  • Similarity Search: Native Qdrant search with document type filtering
  • Batch Operations: Efficient bulk document insertion
  • Caching: Intelligent embedding cache for performance

Installation

# Basic installation
pip install thoth-qdrant

# With OpenAI embeddings support
pip install thoth-qdrant[openai]

# With all embedding providers
pip install thoth-qdrant[all-providers]

Configuration

Environment Variables

# Embedding provider configuration
export EMBEDDING_PROVIDER=openai
export EMBEDDING_MODEL=text-embedding-3-small
export OPENAI_API_KEY=your-api-key

# Or use provider-specific keys
export OPENAI_API_KEY=sk-...
export COHERE_API_KEY=...
export MISTRAL_API_KEY=...

Qdrant Setup

Ensure Qdrant is running locally:

docker run -p 6333:6333 qdrant/qdrant

Usage

from thoth_qdrant import VectorStoreFactory
from thoth_qdrant.core.base import (
    ColumnNameDocument,
    SqlDocument,
    EvidenceDocument,
    ThothType,
)

# Create vector store
store = VectorStoreFactory.create(
    backend="qdrant",
    collection="my_collection",
    host="localhost",
    port=6333,
    embedding_provider="openai",
    embedding_model="text-embedding-3-small"
)

# Add documents
column_doc = ColumnNameDocument(
    table_name="users",
    column_name="email",
    original_column_name="email_address",
    column_description="User email for authentication",
    value_description="Valid email format"
)
doc_id = store.add_column_description(column_doc)

sql_doc = SqlDocument(
    question="How to find recent users?",
    sql="SELECT * FROM users WHERE created_at > NOW() - INTERVAL '30 days'",
    evidence="Filter by date using interval"
)
store.add_sql(sql_doc)

# Search similar documents
results = store.search_similar(
    query="user email authentication",
    doc_type=ThothType.COLUMN_NAME,
    top_k=5,
    score_threshold=0.7
)

# Bulk operations
documents = [column_doc, sql_doc]
doc_ids = store.bulk_add_documents(documents)

# Get document by ID
doc = store.get_document(doc_id)

# Delete document
store.delete_document(doc_id)

# Get all documents by type
all_columns = store.get_all_column_documents()
all_sql = store.get_all_sql_documents()

# Collection info
info = store.get_collection_info()
print(info)

API Reference

VectorStoreInterface Methods

  • add_column_description(doc: ColumnNameDocument) -> str
  • add_sql(doc: SqlDocument) -> str
  • add_evidence(doc: EvidenceDocument) -> str
  • search_similar(query: str, doc_type: ThothType, top_k: int = 5, score_threshold: float = 0.7) -> List[BaseThothDocument]
  • get_document(doc_id: str) -> Optional[BaseThothDocument]
  • delete_document(doc_id: str) -> None
  • bulk_add_documents(documents: List[BaseThothDocument]) -> List[str]
  • delete_collection(thoth_type: ThothType) -> None
  • get_all_column_documents() -> List[ColumnNameDocument]
  • get_all_sql_documents() -> List[SqlDocument]
  • get_all_evidence_documents() -> List[EvidenceDocument]
  • get_collection_info() -> Dict[str, Any]

Testing

# Run tests with local Qdrant
pytest tests/

# Run specific test
pytest tests/test_qdrant_adapter.py -v

# With coverage
pytest --cov=thoth_qdrant tests/

Development

# Install development dependencies
pip install -e .[dev,test]

# Format code
black thoth_qdrant tests
isort thoth_qdrant tests

# Type checking
mypy thoth_qdrant

# Linting
ruff thoth_qdrant

License

MIT License - See LICENSE.md for details

Compatibility

This library is fully compatible with thoth_vdb2 API, allowing seamless migration from Haystack-based implementations to native Qdrant.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

thoth_qdrant-0.1.0.tar.gz (19.1 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

thoth_qdrant-0.1.0-py3-none-any.whl (17.2 kB view details)

Uploaded Python 3

File details

Details for the file thoth_qdrant-0.1.0.tar.gz.

File metadata

  • Download URL: thoth_qdrant-0.1.0.tar.gz
  • Upload date:
  • Size: 19.1 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.13.2

File hashes

Hashes for thoth_qdrant-0.1.0.tar.gz
Algorithm Hash digest
SHA256 ad8133880fd932de8d6cf204a53939883a2556550b60d5d934f76f9e44efcd81
MD5 6b4c3300a63ab8c0d62d4d00d5d4665c
BLAKE2b-256 bcf9af5ffb298355bba286d5d71eb01419e35f1543ed7e865b160f823c330e4e

See more details on using hashes here.

File details

Details for the file thoth_qdrant-0.1.0-py3-none-any.whl.

File metadata

  • Download URL: thoth_qdrant-0.1.0-py3-none-any.whl
  • Upload date:
  • Size: 17.2 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.13.2

File hashes

Hashes for thoth_qdrant-0.1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 9deed900d650852abceb96532458cf645079e39ff86a5f86a96b1afce0b3d671
MD5 31f2d13dd634bf1b5547cb74d33db644
BLAKE2b-256 0d26b34da8df4919374468cd1b82ead9cfe245f009e9caa8e490fc48a4d1a0a6

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page