Получение нечеткого сообщения об ошибке в Neo4j с пакетным загрузчиком APO C - PullRequest
Новая
       91

Получение нечеткого сообщения об ошибке в Neo4j с пакетным загрузчиком APO C

0 голосов
/ 11 июля 2020

Я загружаю в систему большое количество узлов Neo4j из файла json. Это сообщение об ошибке «Не удалось вызвать процедуру apoc.merge.node: вызвано: java .lang.NullPointerException» - я не вижу достаточно информации, чтобы выяснить, что я делаю неправильно, и поскольку это первый раз, когда я использовал это, я просто не вижу этого. Это последние 7 или около того ошибок в стеке ошибок. Похоже, ошибка возникает при вызове merge_node. 

  File "F:\ClientSide\current\testload1.py", line 104, in <lambda>
    nodes.apply(lambda h: merge_node(h), axis=1)
  File "F:\ClientSide\current\testload1.py", line 61, in merge_node
    ses.run("UNWIND $batch AS row CALL apoc.merge.node(['ProgNode', row.nodetype], {node:row.node}, apoc.map.removeKeys(properties(row), ['nodetype', 'node'])) YIELD node RETURN 1", batch=BATCH["batch"])
  File "C:\Users\Bill Dickenson\AppData\Local\Programs\Python\Python37\lib\site-packages\neo4j\work\simple.py", line 217, in run
    self._autoResult._run(query, parameters, self._config.database, self._config.default_access_mode, self._bookmarks, **kwparameters)
  File "C:\Users\Bill Dickenson\AppData\Local\Programs\Python\Python37\lib\site-packages\neo4j\work\result.py", line 101, in _run
    self._attach()
  File "C:\Users\Bill Dickenson\AppData\Local\Programs\Python\Python37\lib\site-packages\neo4j\work\result.py", line 202, in _attach
    self._connection.fetch_message()
  File "C:\Users\Bill Dickenson\AppData\Local\Programs\Python\Python37\lib\site-packages\neo4j\io\_bolt3.py", line 326, in fetch_message
    response.on_failure(summary_metadata or {})
  File "C:\Users\Bill Dickenson\AppData\Local\Programs\Python\Python37\lib\site-packages\neo4j\io\_bolt3.py", line 512, in on_failure
    raise Neo4jError.hydrate(**metadata)
neo4j.exceptions.ClientError: Failed to invoke procedure `apoc.merge.node`: Caused by: java.lang.NullPointerException

«Пакетная» структура данных содержит списки переменных, подобных этой 

{'EIEO': True, 'FILECOUNT': 1, 'KDM': 'data:Writes', 'changed': False, 'ctx': '113540257', 'level': 'code', 'location': [55, 8, 55, 94], 'node': 100, 'quvioDensity': 1.0, 'quviolations': 2, 'szAFP': '', 'szaep': 17, 'szlocs': 2, 'text': 'FilemavenWrapperPropertyFile=newFile(baseDirectory,MAVEN_WRAPPER_PROPERTIES_PATH);', 'type': 'localVariableDeclarationStatement'}

, и код, который ее обрабатывает, выглядит как это, включая оператор печати, который сгенерировал данные выше. 

def merge_node(args):
    global INNODE, NODECOUNT
    """
    Function to create nodes from a batch.
    """
    INNODE += 1
    if (INNODE % 10000) == 0:
        print("...Sent %s of %s for processing" % (INNODE, NODECOUNT))
    if len(BATCH['batch']) == 4:
        print(BATCH['batch'][3])
    if (len(BATCH['batch']) > 1000) or (INNODE == NODECOUNT):
        if INNODE == NODECOUNT:
            print("...Final Record (%s) added and transmitted" % INNODE)
            BATCH['batch'].append(args.to_dict())            
        with graphDB_Driver.session() as ses:
            ses.run("UNWIND $batch AS row CALL apoc.merge.node(['ProgNode', row.nodetype], {node:row.node}, apoc.map.removeKeys(properties(row), ['nodetype', 'node'])) YIELD node RETURN 1", batch=BATCH["batch"])
        reset_batch()
    BATCH['batch'].append(args.to_dict())

Как ни странно, это выполняется локально с этой ошибкой. Когда он работает с моей удаленной базой данных Neo4j, он обрабатывает нормально (без ошибок), но НЕ генерирует ничего на сервере. Итак, я предполагаю, что это не так, но APO C перенаправляет консоль и просто движется дальше.

Кто-нибудь видит, что я делаю неправильно?

1 Ответ

1 голос
/ 11 июля 2020

"batch" data structure в вашем вопросе не содержит свойств, требуемых вашим кодом Cypher: 

nodetype
node

Вы должны убедиться, что все элементы в списке $batch имеют как минимум эти 2 properties, если вы хотите использовать этот код Cypher.

...