Gremlin Python - подключение к многоузловому кластеру JanusGraph - PullRequest
Новая
       9

Gremlin Python - подключение к многоузловому кластеру JanusGraph

0 голосов
/ 18 января 2019

Мы собираемся построить многоузловой кластер JanusGraph

10.74.19.32 (например, IP)

10.74.19.33 (например, IP)

Наше приложение написано на python и использует драйвер python от gremlin 

session = client.Client('ws://10.74.19.32:8182/gremlin', 'g',
message_serializer=GraphSONSerializersV3d0(), 
username=remote_graph_user, 
password=remote_graph_password, pool_size=8)

нам не удалось найти примеры того, как подключить циклический перебор между двумя серверами JanusGraph 10.74.19.32 и 10.74.19.33

Должны ли мы указать это через URL-адрес балансировщика нагрузки, и после открытия соединения приложение python будет оставаться на том же сервере, пока соединение не будет закрыто или прервано?

мы должны сделать 

session = client.Client('ws://vanity_url:8182/gremlin', 'g',
    message_serializer=GraphSONSerializersV3d0(), 
    username=remote_graph_user, 
    password=remote_graph_password, pool_size=8)

Ответы [ 2 ]

0 голосов
/ 28 февраля 2019

Я использую org.apache.tinkerpop.gremlin.driver.cluster на языке Java, что позволяет мне подключаться к двум серверам janus (gremlin) без балансировщика нагрузки

Надеюсь, это поможет! 

GryoMapper.Builder mapBuilder = GryoMapper.build().addRegistry(JanusGraphIoRegistry.getInstance());
Cluster cluster = Cluster.build().serializer(new GryoMessageSerializerV1d0(mapBuilder)).addContactPoints(url, url2).port(Integer.parseInt(port)).create();
Client client = cluster.connect();
Graph graph = EmptyGraph.instance();
g=graph.traversal().withRemote(DriverRemoteConnection.using(client.getCluster()));
0 голосов
/ 26 января 2019

Вы уже на правильном пути. Вы захотите настроить балансировщик нагрузки перед серверами gremlin. Это не то, что gremlin-сервер будет обрабатывать.

...