Azure Data Factory Self Hosted IR Cannot Connect To MongoDB Timeout With No Exception

If authentication logging is not already enabled, you can enable it in MongoDB to get more detailed logs of authentication attempts. This can help you diagnose any authentication issues.

I will see if I can get logs from the MongoDB side of the house. It seems strange that there is a timeout in this way. As mentioned - if I connect via the MongDB Compass client there is no issue or complaint

Should also note that the target DB version is: MongoDB 3.6.13 Community

@Samir Sharma - Have you resolved the issue?

No - have not been able to resolve the issue. The MongoDB node that I am trying to connect to is a "single" read only node. It is part of the cluster, but the the client (the Connector) should be limited to that node only for "read only" use. There may be something about the set up that does allow for this on the Azure connector, but does allow the MongoDB Compass (and whatever implementation it has the MongoDB Driver implemented as.

In the IR if I attempt to use the same connection string that I put in the Azure Data Factory I get the details of the exception below. Seems like there is something that is expected of/from the Cluster that the connector is waiting for and that never comes. Some sort of Quorum? Not sure. Based on the fact that the node is not really co-operating as a read/write node....?

My issue is that if I go back and look at the MongoDB logs, there may be nothing that is happening there if the Azure connector is "waiting" for something that never happens.

I believe that the answer would lie in the

WaitForDescriptionChangedHelper

Method and what it us supposed to do.

message: TestConnection failed, error message: 'Type=Microsoft.DataTransfer.Common.Shared.HybridDeliveryException,Message=>Connection to MongoDB server is timeout.,Source=Microsoft.DataTransfer.Runtime.MongoDbAtlasConnector,StackTrace= at Microsoft.DataTransfer.Runtime.MongoDbAtlas.MongoDbAtlasValidator.TestConnection()

at Microsoft.DataTransfer.TransferTask.InteractiveTaskFactoryV2.ConnectorTestConnection(ConnectionSetting connectionSetting, TestConnectionV2Response response)

at Microsoft.DataTransfer.TransferTask.InteractiveTaskFactoryV2.TestConnection(TestConnectionV2Request request, TestConnectionV2Response response, CancellationToken token)

at Microsoft.DataTransfer.TransferTask.InteractiveTask`2.Execute(),''Type=System.TimeoutException,Message=A timeout occured after 30000ms selecting a server using CompositeServerSelector{ Selectors = MongoDB.Driver.MongoClient+AreSessionsSupportedServerSelector, LatencyLimitingServerSelector{ AllowedLatencyRange = 00:00:00.0150000 } }. Client view of cluster state is { ClusterId : "1", ConnectionMode : "Automatic", Type : "ReplicaSet", State : "Connected", Servers : [{ ServerId: "{ ClusterId : 1, EndPoint : "Unspecified/MYHOST:27017" }", EndPoint: "Unspecified/MYHOST:27017", State: "Connected", Type: "ReplicaSetOther", WireVersionRange: "[0, 6]", LastUpdateTimestamp: "2024-03-11T15:56:39.4775777Z" }] }.,Source=MongoDB.Driver.Core,StackTrace= at MongoDB.Driver.Core.Clusters.Cluster.ThrowTimeoutException(IServerSelector selector, ClusterDescription description)

at MongoDB.Driver.Core.Clusters.Cluster.WaitForDescriptionChangedHelper.HandleCompletedTask(Task completedTask)

at MongoDB.Driver.Core.Clusters.Cluster.WaitForDescriptionChanged(IServerSelector selector, ClusterDescription description, Task descriptionChangedTask, TimeSpan timeout, CancellationToken cancellationToken)

at MongoDB.Driver.Core.Clusters.Cluster.SelectServer(IServerSelector selector, CancellationToken cancellationToken)

at MongoDB.Driver.MongoClient.AreSessionsSupportedAfterServerSelection(CancellationToken cancellationToken)

at MongoDB.Driver.MongoClient.AreSessionsSupported(CancellationToken cancellationToken)

at MongoDB.Driver.OperationExecutor.StartImplicitSession(CancellationToken cancellationToken)

at MongoDB.Driver.MongoDatabaseImpl.UsingImplicitSession[TResult](Func`2 func, CancellationToken cancellationToken)

at MongoDB.Driver.MongoDatabaseImpl.RunCommand[TResult](Command`1 command, ReadPreference readPreference, CancellationToken cancellationToken)

at Microsoft.DataTransfer.Runtime.MongoDbAtlas.MongoDbAtlasValidator.TestConnection(),'.