fix imports and comments
This commit is contained in:
10
neo4j_etl.py
10
neo4j_etl.py
@@ -5,7 +5,7 @@ import glob
|
||||
import getpass
|
||||
|
||||
|
||||
# Neo4j Connection
|
||||
# neo4j Connection
|
||||
|
||||
NEO4J_URI = "bolt://localhost:7687"
|
||||
NEO4J_USER = input("Neo4j username: ")
|
||||
@@ -17,7 +17,7 @@ driver = GraphDatabase.driver(
|
||||
)
|
||||
|
||||
|
||||
# Helper Functions
|
||||
# helper Functions
|
||||
|
||||
|
||||
def test_connection():
|
||||
@@ -49,15 +49,15 @@ if not test_connection():
|
||||
exit(1)
|
||||
|
||||
|
||||
# Folder for results
|
||||
# folder for results
|
||||
|
||||
output_dir = "query_results"
|
||||
os.makedirs(output_dir, exist_ok=True)
|
||||
|
||||
|
||||
# Run all .cypher files in 'queries/' folder
|
||||
# run all .cypher files in 'queries/' folder
|
||||
|
||||
cypher_files = sorted(glob.glob("analysis_queries/*.cypher"))
|
||||
cypher_files = sorted(glob.glob("./neo4jqueries/analysis_queries/*.cypher"))
|
||||
|
||||
for file in cypher_files:
|
||||
with open(file, "r", encoding="utf-8") as f:
|
||||
|
||||
Reference in New Issue
Block a user