使用Java的Gremlin-是否可以通过启用新的TraversalStrategy从Java客户端覆盖gremlin服务器的'g'

如何解决使用Java的Gremlin-是否可以通过启用新的TraversalStrategy从Java客户端覆盖gremlin服务器的'g'

我们正在尝试根据在顶点上作为属性设置的用户权限应用静态过滤器。

需要一些帮助才能实现＃4 和＃5

方法： 1。。实施gremlin代理服务（Java REST层），使SubgraphStrategy可以创建GraphTraversalSource，即针对每个请求。

2。。提取用户原理并调用我们的权利服务以获取所有权限。

3。。使用这些用户权限使用SubgraphStrategy创建新的GraphTraversalSource（g2）

4。。使用此“ g2”将请求的gremlin查询字符串提交给Gremlin服务器，即client.submit（queryString）。 //有可能吗？我们如何用新的'g2'覆盖queryString中使用的'g'

5。。响应应该采用JSON（GraphSON），与gremlin服务器响应（Http响应）的方式相同。我们如何从ResultSet中产生类似的JSON。

代码段： remote-objects.yaml（用于通过Java远程连接到gremlin服务器）

hosts: [localhost]
port: 8183
serializer: { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerGremlinV2d0,config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}

//我们应该在此序列化程序上进行任何更改吗？为了在GraphSON中序列化服务器响应？

gremlin-server.yaml

host: 0.0.0.0
port: 8183
threadPoolWorker: 1
gremlinPool: 8
scriptEvaluationTimeout: 30000
serializedResponseTimeout: 30000
#channelizer: org.apache.tinkerpop.gremlin.server.channel.HttpChannelizer
channelizer: org.apache.tinkerpop.gremlin.server.channel.WsAndHttpChannelizer
graphs: {
  graph: "H:\\project_work\\Gremlin-Graph\\src\\main\\resources\\janusgraph-cassandra-es.properties" }
scriptEngines: {
 gremlin-groovy: {
      plugins: { org.janusgraph.graphdb.tinkerpop.plugin.JanusGraphGremlinPlugin: {},org.apache.tinkerpop.gremlin.server.jsr223.GremlinServerGremlinPlugin: {},org.apache.tinkerpop.gremlin.tinkergraph.jsr223.TinkerGraphGremlinPlugin: {},org.apache.tinkerpop.gremlin.jsr223.ImportGremlinPlugin: {classImports: [java.lang.Math],methodImports: [java.lang.Math#*]},org.apache.tinkerpop.gremlin.jsr223.ScriptFileGremlinPlugin: {
                 files: ["H:\\project_work\\Gremlin-Graph\\src\\main\\resources\\empty-sample.groovy"]
                 }}
   }
}
serializers:
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0,config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoLiteMessageSerializerV1d0,config: {ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0,config: { serializeResultToString: true }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerGremlinV1d0,config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerGremlinV2d0,config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
processors:
  - { className: org.apache.tinkerpop.gremlin.server.op.session.SessionOpProcessor,config: { sessionTimeout: 28800000 }}
  - { className: org.apache.tinkerpop.gremlin.server.op.traversal.TraversalOpProcessor,config: { cacheExpirationTime: 600000,cacheMaxSize: 1000 }}
metrics: {
  consoleReporter: {enabled: true,interval: 180000},csvReporter: {enabled: true,interval: 180000,fileName: /tmp/gremlin-server-metrics.csv},jmxReporter: {enabled: true},slf4jReporter: {enabled: true,gangliaReporter: {enabled: false,addressingMode: MULTICAST},graphiteReporter: {enabled: false,interval: 180000}}
threadPoolBoss: 1
maxInitialLineLength: 4096
maxHeaderSize: 8192
maxChunkSize: 8192
maxContentLength: 65536
maxAccumulationBufferComponents: 1024
resultIterationBatchSize: 64
writeBufferHighWaterMark: 32768
writeBufferHighWaterMark: 65536
ssl: {
  enabled: false}

janusgraph-cassandra-es.properties

gremlin.graph=org.janusgraph.core.JanusGraphFactory

storage.backend=cql
storage.hostname=1.2.3.4,1.2.3.5,1.2.3.6,1.2.3.7,1.2.3.8,1.2.3.9
storage.username=username
storage.password=password
storage.read-time=20000 ms
storage.cql.keyspace=janusgraph_dev
storage.cql.read-consistency-level=LOCAL_QUORUM
storage.cql.write-consistency-level=LOCAL_QUORUM
storage.cql.local-datacenter=dc1
storage.cql.only-use-local-consistency-for-system-operations=true
storage.cql.replication-strategy-options=dc1,2,dc2,2
storage.cql.replication-strategy-class=NetworkTopologyStrategy
log.tx.key-consistent=true

index.search.backend=elasticsearch
index.search.index-name=graph_search_cs_dev
index.search.hostname=dev.elastic.service.com
index.search.elasticsearch.http.auth.type=custom
index.search.elasticsearch.http.auth.custom.authenticator-class=edu.sample.cassandra.graph.Authenticator
index.search.elasticsearch.http.auth.custom.authenticator-args=keytabUser,H:\\keytabs\\keytab-file.kt

empty-sample.groovy是此处使用的默认值：

https://github.com/JanusGraph/janusgraph/blob/master/janusgraph-dist/src/assembly/static/scripts/empty-sample.groovy

Java REST层（Gremlin代理服务）

GET /gremlin-proxy?gremlin=g.V().has('name','stephane').out()


Cluster cluster = Cluster.open("H:\\project_work\\Gremlin-Graph\\src\\main\\resources\\remote-objects.yaml");
Client client = cluster.connect();
Graph graph = EmptyGraph.instance();
GraphTraversalSource g2 = graph.traversal()
.withRemote(DriverRemoteConnection.using(cluster,"g"))
.withStrategies(SubgraphStrategy.build().vertices(has("p_entitlements",textContains("edu.sample.graph.team2"))).create());


String queryString = "g.V().has('uri','http://sample.com/sample/sample_2').out()"; *// user requested query string. Is it possible to replace this 'g' with the new GraphTraversalSource i.e. 'g2' for the server to use and execute.*

ResultSet rs = client.submit(queryString);

System.out.println(rs);

List<Result> results = rs.all().get();  *// Unsure how we can convert this to GraphSON like gremlin server response in JSON*

System.out.println(results);

g.close();
client.close();
cluster.close();

任何引用或指针都将非常有帮助。

解决方法

您不能用描述的方式覆盖g。我可以想到两个选择：

Use a session，根据需要构造g，然后在该会话中引用该g，或者
使用SubgraphStrategy代码为每个请求构建查询字符串。如果您必须这样做，这在我看来应该不是一个非常昂贵的操作。