Болтовое соединение выборочно медленно с запросами шифра, в то время как веб-интерфейс всегда быстрый - PullRequest
Новая
       42

Болтовое соединение выборочно медленно с запросами шифра, в то время как веб-интерфейс всегда быстрый

0 голосов
/ 29 мая 2018

У меня есть два запроса: q1 и q2.Я использую код ниже, чтобы запросить мою базу данных neo4j.

driver = GraphDatabase.driver("bolt://localhost:7687",auth= neo4j_user,neo4j_password))
neo4j_session = driver.session()

t = time.time()
neo4j_session.run(q1,q1_parameters) 
print(time.time()-t)

t = time.time()
neo4j_session.run(q2,q2_parameters) 
print(time.time()-t)

и q1, и q2 выполняются neo4j примерно за 10 мс в веб-интерфейсе (http://localhost:7474/browser/). Приведенный выше код также выполняет q1 примерно за 10 мс, а q2 выполняется за 1 с.

Почему болтовое соединение neo4j не похоже на конкретный запрос (q2), даже если веб-интерфейс выполняет его в 100 раз быстрее? Я считаю, что это не накладные расходы на соединение, так как q1 выполняется почти так же быстро в любом случае

1 Ответ

0 голосов
/ 30 мая 2018

Не следует создавать новый драйвер и сеанс для каждого запроса.

README для драйвера Python Bolt содержит следующий «Быстрый пример», как выполнить 4 запроса (в 3 транзакциях записи и 1 чтения) с одинаковыми driver и session: 

from neo4j.v1 import GraphDatabase

driver = GraphDatabase.driver("bolt://localhost:7687", auth=("neo4j", "password"))

def add_friends(tx, name, friend_name):
    tx.run("MERGE (a:Person {name: $name}) "
           "MERGE (a)-[:KNOWS]->(friend:Person {name: $friend_name})",
           name=name, friend_name=friend_name)

def print_friends(tx, name):
    for record in tx.run("MATCH (a:Person)-[:KNOWS]->(friend) WHERE a.name = $name "
                         "RETURN friend.name ORDER BY friend.name", name=name):
        print(record["friend.name"])

with driver.session() as session:
    session.write_transaction(add_friends, "Arthur", "Guinevere")
    session.write_transaction(add_friends, "Arthur", "Lancelot")
    session.write_transaction(add_friends, "Arthur", "Merlin")
    session.read_transaction(print_friends, "Arthur")
...