Neo4j 流，结构集成不起作用。日志报告 "The `USE GRAPH` clause is not available in this implementation of Cypher"

Question

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

我是不是错过了什么？

Neo4j日志错误：

ErrorData(originalTopic=twoPoly, timestamp=1620757269838, partition=0, offset=1481, exception=org.neo4j.graphdb.QueryExecutionException: USE GRAPH 子句在此 Cypher 实现中不可用，因为缺少对 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} ) MERGE (v:VertexNode {Vertex:event.vertexDBVertex,Scalar:event.vertexScalarDB,Degree:event.vertexDegreeDB}) MERGE (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=class streams.kafka.KafkaAutoCommitEventConsumer)

Neo4j 版本 4.1.0

相关neo4j.conf:

fabric.database.name=differences

streams.source.enabled=false

kafka.max.poll.records=1000

kafka.zookeeper.connect=localhost:2181

kafka.bootstrap.servers=localhost:9092

streams.procedures.enabled=<true/false, default=true>

streams.sink.enabled=true

streams.sink.topic.cypher.twoPoly=use 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)

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

:使用createbymu

:使用差异图

:使用面料

:使用整数多边形

:使用neo4j

:使用skipmu

:使用系统

参考方案：

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

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

Answer 1

此设置当前不支持 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 流，结构集成不起作用。日志报告 "The `USE GRAPH` clause is not available in this implementation of Cypher"

Neo4j streams, fabric integration not working. Log reports "The `USE GRAPH` clause is not available in this implementation of Cypher"

neo4j