多边数据导入后点与点只存在一条边

[chenfengzhou]

分支：
master 775b7f6
镜像：
spg-registry.cn-hangzhou.cr.aliyuncs.com/spg/openspg-server
镜像id：
sha256:c47fd267361672d2e1cb16500cd34e4c2667dd53d3061d0049fe8c494b06caf8
在riskmining样例中，Person_fundTrans_Person构建了person之间的边，在文件中person之间有多条记录，但是在neo4j中只有最后一条记录的边，而不是多条记录的多条边。在我自己构建的实例中也出现同样的问题，我需要多条边来展示/抓取两个点之间的潜在关系，但是他只记录了最后一条数据的边
例子如下：
Person_fundTrans_Person部分数据
src,dst,transDate,transAmt
10,0,20230906,6282
10,0,20230918,33643
10,0,20230826,3078
10,0,20230827,2763
10,0,20230905,13180
在neo4j中id为10和0的节点只有一条边
elementId: 5:777217b9-bd85-4add-8e7f-ab2db8919382:1123
id: 1123
transAmt: "13180"
transDate: "20230905"
作为交易记录，每一条边都应该存在的，但是他的在点对之间边会直接覆盖上一条边的数据，这与预期不符？

[Jthan7]

请问您要的是这样的结果吗？

[chenfengzhou]

请问您想要这样的结果吗？
是的，之前分析是因为KGWriter中使用了更新而不是写入

[chenfengzhou]

在kg_writer中仅有两种写入方式？点对间插入默认调用upsert
class AlterOperationEnum(str, Enum):
Upsert = "UPSERT"
Delete = "DELETE"
if upsert_nodes:
query = (
"UNWIND $relations AS relationship "
f"MERGE (a:{self._escape_neo4j(start_node_label)} {{{self._escape_neo4j(start_node_id_key)}: relationship.start_node_id}}) "
f"MERGE (b:{self._escape_neo4j(end_node_label)} {{{self._escape_neo4j(end_node_id_key)}: relationship.end_node_id}}) "
f"MERGE (a)-[r:{self._escape_neo4j(rel_type)}]->(b) SET r += relationship.properties RETURN r"
)
else:
query = (
"UNWIND $relations AS relationship "
f"MATCH (a:{self._escape_neo4j(start_node_label)} {{{self._escape_neo4j(start_node_id_key)}: relationship.start_node_id}}) "
f"MATCH (b:{self._escape_neo4j(end_node_label)} {{{self._escape_neo4j(end_node_id_key)}: relationship.end_node_id}}) "
f"MERGE (a)-[r:{self._escape_neo4j(rel_type)}]->(b) SET r += relationship.properties RETURN r"
)

[thundax-lyp]

试试 knowledge_unit_extractor。或者在KGWrite的时候，SubGraph的边设置为 KnowledgeUnit