Neo4j 流，结构集成不起作用日志报告“`USE GRAPH` 子句在 Cypher 的这个实现中不可用”

问题描述

将我的流主题集成到结构功能中不起作用。尝试将我的第一个主题放入命名图中产生了以下消息。
我确实按照链接提供的说明操作无济于事。

我错过了什么吗？

Neo4j 日志错误：

ErrorData(originalTopic=twopoly,timestamp=1620757269838,partition=0,offset=1481,exception=org.neo4j.graphdb.QueryExecutionException: 由于缺少支持 USE 图形选择器。（第 1 行，第 29 列（偏移量：28）） "UNWIND $events AS event use integerpolys MERGE (i:IndexedBy {N:event.NN,RowCounter:event.flatFileRowCounterr,MaxN:event.nMaxx,Dimension:"2"} ) MERGE (t:TwoSeqFactor {twoSeq:event.tSeqDB } ) 合并 (v:VertexNode {Vertex:event.vertexDBVertex,Scalar:event.vertexScalarDB,Degree:event.vertexDegreeDB} ) 合并 (e:Evaluate {Value:event.targetEvaluate}) 合并 (i)-[ee:TwoFactor] ->(t) 合并 (i) -[:IndexedByEvaluate]->(e) 合并 (i)-[:VertexIndexedBy]->(v)" ^,key=null,value={"NN":"7","nMaxx":"8","vertexDBVertex":"1 -8 1 0 0","bTermDB":"1","flatFileRowCounterr": "6","targetEvaluate":"128","vertexDB":"1 -8 1 0 0","vertexScalarDB":"-8","tSeqDB":"32","vertexDegreeDB":"1"},executionClass=classstreams.kafka.KafkaAutoCommitEventConsumer)

Neo4j 版本 4.1.0

相关的neo4j.conf：

USE GRAPH

可用数据库 当前用户可用的数据库。单击一个开始使用它：

：使用createbymu

：使用差异图

：使用布料

：使用整数多边形

：使用neo4j

:使用skipmu

：使用系统

参考解决方案：

https://github.com/neo4j/neo4j/issues/12395

https://neo4j.com/docs/operations-manual/current/fabric/configuration/

解决方法

此设置当前不支持 USE 子句（仅当使用 neo4j 驱动程序连接时）。

根据 https://neo4j.com/labs/kafka/4.0/consumer/#_multi_database_support

从查询中删除 use integerpolys，而是直接使用目标数据库配置流插件

streams.sink.enabled.to.integerpolys=true

streams.sink.topic.cypher.twoPoly.to.integerpolys=\
MERGE (i:IndexedBy {N:event.NN,RowCounter:event.RowCounterr,MaxN:event.nMaxx,Dimension:"2"} ) \
MERGE (t:TwoSeqFactor {twoSeq:event.tSeqDB} ) \
MERGE (v:VertexNode        {Vertex:event.vertexDBVertex,Scalar:event.vertexScalarDB,Degree:event.vertexDegreeDB} ) \
MERGE (e:Evaluate {Value:event.targetEvaluate}) \
MERGE  (i)-[ee:TwoFactor]->(t) \
MERGE (i) -[:IndexedByEvaluate]->(e) \
MERGE  (i)-[:VertexIndexedBy]->(v)

neo4j neo4j