spark connetor写入edge成功,但数据库里没有insert进去

提问参考模版:

  • 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()

数据库里没有边数据,请问是哪里的问题

统计不实时的,你试试点击下左边的更新,如果还不是新数据的话,可以看下文档 SHOW STATS - NebulaGraph Database 手册

image
这两个不一样,不确定是否有影响

hash的时候出问题了,已解决