提问参考模版:
- nebula 版本:v3.6
- 部署方式:云端
- 安装方式:RPM
- 是否上生产环境:N
问题:
在测试spark connector插入边时,代码运行成功,点能顺利插入,边查不到
插入测试dataframe:
+----------+--------------------+--------------------+-------------+----------+------+--------+--------------------+-------------------+--------------------+
| req_time| req_uri| app_id| src_ip|req_method|status|protocol| user_agent| src_id| dst_id|
+----------+--------------------+--------------------+-------------+----------+------+--------+--------------------+-------------------+--------------------+
|1694171560|uri|appid|src_ip| GET| 200|HTTP/1.1|python-requests/2...|7354203528099693501|-2595427462997883397|
+----------+--------------------+--------------------+-------------+----------+------+--------+--------------------+-------------------+--------------------+
插入代码
# #写入src_vertex
df_src_ip.write.format("com.vesoft.nebula.connector.NebulaDataSource").option(
"type", "vertex").option(
"spaceName", "config_server").option(
"label", "client").option(
"vidPolicy", "").option(
"vertexField", "src_id").option(
"vidAsProp", "false").option(
"metaAddress", "metaip:9559").option(
"graphAddress", "graphip:9669").option(
"passwd", "passwd").option(
"user", "root").option(
"operateType","write").save()
#插入app_id_vertex
df_app_id.write.format("com.vesoft.nebula.connector.NebulaDataSource").option(
"type", "vertex").option(
"spaceName", "config_server").option(
"label", "server").option(
"vidPolicy", "").option(
"vertexField", "dst_id").option(
"vidAsProp", "false").option(
"metaAddress", "metaip:9559").option(
"graphAddress", "graphip:9669").option(
"passwd", "passwd").option(
"user", "root").option(
"operateType","write").save()
#插入edge
df_edge.write.format("com.vesoft.nebula.connector.NebulaDataSource")\
.option("metaAddress", "meta0:9559")\
.option("graphAddress", "graph0:9669")\
.option("user", "root")\
.option("passwd", "passwd")\
.option("type", "edge")\
.option("spaceName", "config_server")\
.option("label", "request")\
.option("srcPolicy", "")\
.option("srcVertexField", "src_id")\
.option("srcAsProp", "false")\
.option("dstPolicy", "")\
.option("dstVertexField", "dst_id")\
.option("dstAsProp", "false")\
.option("rankField", "req_time")\
.option("rankAsProp", "true")\
.option("writeMode", "insert")\
.option("operateType","write").save()
数据库里没有边数据,请问是哪里的问题