gmakstutis/LightRAG
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update Neo4j database naming in env.example

Browse source
This commit is contained in:
yangdx 2025-08-15 19:14:38 +08:00
parent 3a227e37b8
commit 2a781dfb91
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
env.example
View file

@ -268,7 +268,7 @@ POSTGRES_IVFFLAT_LISTS=100
NEO4J_URI=neo4j+s://xxxxxxxx.databases.neo4j.io NEO4J_URI=neo4j+s://xxxxxxxx.databases.neo4j.io
NEO4J_USERNAME=neo4j NEO4J_USERNAME=neo4j
NEO4J_PASSWORD='your_password' NEO4J_PASSWORD='your_password'
# NEO4J_DATABASE=chunk_entity_relation # NEO4J_DATABASE=chunk-entity-relation
NEO4J_MAX_CONNECTION_POOL_SIZE=100 NEO4J_MAX_CONNECTION_POOL_SIZE=100
NEO4J_CONNECTION_TIMEOUT=30 NEO4J_CONNECTION_TIMEOUT=30
NEO4J_CONNECTION_ACQUISITION_TIMEOUT=30 NEO4J_CONNECTION_ACQUISITION_TIMEOUT=30

6
lightrag/kg/neo4j_impl.py
View file

@ -155,7 +155,7 @@ class Neo4JStorage(BaseGraphStorage):
except neo4jExceptions.ServiceUnavailable as e: except neo4jExceptions.ServiceUnavailable as e:
logger.error( logger.error(
f"[{self.workspace}] " f"[{self.workspace}] "
+ f"{database} at {URI} is not available".capitalize() + f"Database {database} at {URI} is not available"
) )
raise e raise e
except neo4jExceptions.AuthError as e: except neo4jExceptions.AuthError as e:
@ -167,7 +167,7 @@ class Neo4JStorage(BaseGraphStorage):
if e.code == "Neo.ClientError.Database.DatabaseNotFound": if e.code == "Neo.ClientError.Database.DatabaseNotFound":
logger.info( logger.info(
f"[{self.workspace}] " f"[{self.workspace}] "
+ f"{database} at {URI} not found. Try to create specified database.".capitalize() + f"Database {database} at {URI} not found. Try to create specified database."
) )
try: try:
async with self._driver.session() as session: async with self._driver.session() as session:
@ -177,7 +177,7 @@ class Neo4JStorage(BaseGraphStorage):
await result.consume() # Ensure result is consumed await result.consume() # Ensure result is consumed
logger.info( logger.info(
f"[{self.workspace}] " f"[{self.workspace}] "
+ f"{database} at {URI} created".capitalize() + f"Database {database} at {URI} created"
) )
connected = True connected = True
except ( except (