5d415dc1a0
<!-- .github/pull_request_template.md --> ## Description This PR adds support for the Memgraph graph database following the [graph database integration guide](https://docs.cognee.ai/contributing/adding-providers/graph-db/graph-database-integration): - Implemented `MemgraphAdapter` for interfacing with Memgraph. - Updated `get_graph_engine.py` to return MemgraphAdapter when appropriate. - Added a test script:` test_memgraph.py.` - Created a dedicated test workflow: `.github/workflows/test_memgraph.yml.` ## DCO Affirmation I affirm that all code in every commit of this pull request conforms to the terms of the Topoteretes Developer Certificate of Origin. --------- Co-authored-by: Vasilije <8619304+Vasilije1990@users.noreply.github.com> Co-authored-by: Boris <boris@topoteretes.com>
86 lines
3 KiB
Python
86 lines
3 KiB
Python
"""Factory function to get the appropriate graph client based on the graph type."""
|
|
|
|
from functools import lru_cache
|
|
|
|
from .config import get_graph_config
|
|
from .graph_db_interface import GraphDBInterface
|
|
|
|
|
|
async def get_graph_engine() -> GraphDBInterface:
|
|
"""Factory function to get the appropriate graph client based on the graph type."""
|
|
config = get_graph_config()
|
|
|
|
graph_client = create_graph_engine(**get_graph_config().to_hashable_dict())
|
|
|
|
# Async functions can't be cached. After creating and caching the graph engine
|
|
# handle all necessary async operations for different graph types bellow.
|
|
# Handle loading of graph for NetworkX
|
|
if config.graph_database_provider.lower() == "networkx" and graph_client.graph is None:
|
|
await graph_client.load_graph_from_file()
|
|
|
|
return graph_client
|
|
|
|
|
|
@lru_cache
|
|
def create_graph_engine(
|
|
graph_database_provider,
|
|
graph_database_url,
|
|
graph_database_username,
|
|
graph_database_password,
|
|
graph_database_port,
|
|
graph_file_path,
|
|
):
|
|
"""Factory function to create the appropriate graph client based on the graph type."""
|
|
|
|
if graph_database_provider == "neo4j":
|
|
if not (graph_database_url and graph_database_username and graph_database_password):
|
|
raise EnvironmentError("Missing required Neo4j credentials.")
|
|
|
|
from .neo4j_driver.adapter import Neo4jAdapter
|
|
|
|
return Neo4jAdapter(
|
|
graph_database_url=graph_database_url,
|
|
graph_database_username=graph_database_username,
|
|
graph_database_password=graph_database_password,
|
|
)
|
|
|
|
elif graph_database_provider == "falkordb":
|
|
if not (graph_database_url and graph_database_port):
|
|
raise EnvironmentError("Missing required FalkorDB credentials.")
|
|
|
|
from cognee.infrastructure.databases.vector.embeddings import get_embedding_engine
|
|
from cognee.infrastructure.databases.hybrid.falkordb.FalkorDBAdapter import FalkorDBAdapter
|
|
|
|
embedding_engine = get_embedding_engine()
|
|
|
|
return FalkorDBAdapter(
|
|
database_url=graph_database_url,
|
|
database_port=graph_database_port,
|
|
embedding_engine=embedding_engine,
|
|
)
|
|
|
|
elif graph_database_provider == "kuzu":
|
|
if not graph_file_path:
|
|
raise EnvironmentError("Missing required Kuzu database path.")
|
|
|
|
from .kuzu.adapter import KuzuAdapter
|
|
|
|
return KuzuAdapter(db_path=graph_file_path)
|
|
|
|
elif graph_database_provider == "memgraph":
|
|
if not (graph_database_url and graph_database_username and graph_database_password):
|
|
raise EnvironmentError("Missing required Memgraph credentials.")
|
|
|
|
from .memgraph.memgraph_adapter import MemgraphAdapter
|
|
|
|
return MemgraphAdapter(
|
|
graph_database_url=graph_database_url,
|
|
graph_database_username=graph_database_username,
|
|
graph_database_password=graph_database_password,
|
|
)
|
|
|
|
from .networkx.adapter import NetworkXAdapter
|
|
|
|
graph_client = NetworkXAdapter(filename=graph_file_path)
|
|
|
|
return graph_client
|