使用Gremlin操作AWS Neptune无法将属性改回旧值的问题求助

根因说明 #

该问题是AWS Neptune属性基数默认规则与Gremlin Node.js驱动序列化逻辑共同导致的：

• Neptune在Schema-less模式下未显式指定属性基数时，对于包含空格等特殊字符的字符串值，会将property()操作默认识别为向Set类型属性追加值，而非覆盖原有单值属性
• 你的操作执行完成后，test属性实际为包含foo、bar foo两个值的Set集合，旧版本Node.js Gremlin驱动序列化多值属性时，默认仅返回最后写入的非重复值，因此最终输出为bar foo
• 当中间值为无空格的单个单词时，Neptune可以正确识别为单值覆盖操作，因此结果符合预期

修复方案 #

方案1：显式指定单值基数（推荐） #

在所有修改顶点属性的property()步骤中，显式声明基数为Cardinality.single，强制每次操作覆盖原有属性值。
修改后的代码如下：

const gremlin = require('gremlin');
const { DriverRemoteConnection } = gremlin.driver;
// 导入基数枚举
const { Cardinality } = gremlin.process;

const dc = new DriverRemoteConnection(process.env.DB_URL, { authenticator, connectOnStartup: false });
await dc.open();
const g = gremlin.process.AnonymousTraversalSource.traversal().withRemote(dc);

await g.V().hasLabel('Wtf').drop().iterate();
// 所有property操作都显式指定Cardinality.single
await g.addV('Wtf').property(Cardinality.single, 'test', 'foo').iterate()
await g.V().hasLabel('Wtf').property(Cardinality.single, 'test', 'bar foo').iterate();
await g.V().hasLabel('Wtf').property(Cardinality.single, 'test', 'foo').iterate();

const wtf = await g.V().hasLabel('Wtf').elementMap().toList();
console.log(wtf);

方案2：修改集群默认基数配置 #

如果你的业务场景中所有顶点属性都是单值，可以直接修改Neptune集群参数组配置：

• 找到你的Neptune集群对应的参数组
• 将参数neptune_default_property_cardinality的值调整为SINGLE
• 重启集群生效后，所有未显式指定基数的property()操作都会默认执行单值覆盖，不需要额外修改代码

内容的提问来源于stack exchange，提问作者Dima Kurilo