В настоящее время я пытаюсь подключиться к существующей Cosmos DB с помощью Gremlin и Mavin для Java. Моя база данных требует имя пользователя и пароль для подключения. В настоящее время я передаю код с конечной точкой, именем пользователя, паролем и портом для создания кластера. Затем я использую кластер для запуска клиента и использую его для создания корневого обхода, который я могу использовать для запроса БД. Мои запросы возвращают сетевые ошибки, но я подозреваю, что проблема может быть в создании кластера, поскольку при поиске хостов в кластере я получаю результат 0 хостов.
Я уже это сделал. попробовал использовать строку подключения вместо отдельного имени пользователя, пароля и т. д., но это тоже не сработало. Я также попробовал сценарий Python, но он не удался.
Вот код подключения:
private static GraphTraversalSource connect(String endpoint, String username, String password, int port) {
System.out.println("STARTING");
System.out.println("creating cluster");
Cluster cluster = Cluster.build()
.addContactPoint(endpoint)
.port(port)
.credentials(username, password)
.enableSsl(true)
.maxWaitForConnection(100000) // Increase connection timeout
.maxContentLength(65536)
.create();
int numHosts = cluster.availableHosts().size();
System.out.println("Cluster created successfully with the following hosts:");
System.out.println(numHosts);
System.out.println("Connecting");
Client client = cluster.connect();
System.out.println("Determining traversal source");
// Define the source and target graph traversal sources
final GraphTraversalSource G = AnonymousTraversalSource.traversal().withRemote(DriverRemoteConnection.using(client));
System.out.println("Finding count");
try {
long vertexCount = G.V().count().next();
System.out.println("Source count: " + vertexCount);
}
catch(Exception e) {
System.out.println("FAILED TO QUERY");
System.exit(1);
}
return G;
}
Вывод следующий (я заменил фактический адрес и HostUri на конечную точку адреса):
STARTING
creating cluster
Cluster created successfully with the following hosts:
0
Connecting
Determining traversal source
Finding count
09:28:44.187 [gremlin-driver-loop-1] ERROR o.a.t.g.d.Connection - Server closed the Connection on channel 2017caf4 - scheduling removal from ConnectionPool (Host{address=endpoint/internalIP, hostUri=wss://endpoint:port/gremlin})
Connection Pool Status (size=2 max=8 min=2 toCreate=0 bin=0)
==> Connection{channel=2017caf4 isDead=true borrowed=1 pending=1 markedReplaced=false closing=false created=2024-07-23T16:28:43.549866Z thread=gremlin-driver-conn-scheduler-1}
> Connection{channel=83a2625b isDead=false borrowed=0 pending=0 markedReplaced=false closing=false created=2024-07-23T16:28:43.549858Z thread=gremlin-driver-conn-scheduler-2}
-- bin --
FAILED TO QUERY
Process finished with exit code 1
Подробнее здесь: https://stackoverflow.com/questions/787 ... va-failing
