use service connection for nosql adaptor factory

ingestion/src/metadata/profiler/adaptors/factory.py

@@ -13,8 +13,12 @@
 """
 from typing import Callable
 
-from pymongo import MongoClient
-
+from metadata.generated.schema.entity.services.connections.database.dynamoDBConnection import (
+    DynamoDBConnection,
+)
+from metadata.generated.schema.entity.services.connections.database.mongoDBConnection import (
+    MongoDBConnection,
+)
 from metadata.profiler.adaptors.dynamodb import DynamoDB
 from metadata.profiler.adaptors.mongodb import MongoDB
 from metadata.profiler.adaptors.nosql_adaptor import NoSQLAdaptor
@@ -32,12 +36,6 @@ class NoSQLAdaptorFactory(Factory):
     and can be created using the `construct` method.
     """
 
-    def __init__(self):
-        """
-        Initialize a new instance of NoSQLClientFactory.
-        """
-        super().__init__()
-
     def register(self, interface_type: str, interface_class: NoSQLAdaptorConstructor):
         """
         Register a client type with its constructor.
@@ -56,20 +54,23 @@ def create(self, interface_type: any, *args, **kwargs) -> NoSQLAdaptor:
         Create a client instance of the type of the given source client.
 
         Args:
-            interface_type (any): The source client instance.
+            interface_type (str): The type of the source connection.
 
         Returns:
             NoSQLAdaptor: The created client instance.
 
         Raises:
             ValueError: If the type of the source client is not registered.
         """
-        client_class = self._interface_type.get(type(interface_type).__name__)
+        client_class = self._interface_type.get(interface_type)
         if not client_class:
-            raise ValueError(f"Unknown NoSQL source: {type(interface_type).__name__}")
-        return client_class(interface_type)
+            raise ValueError(f"Unknown NoSQL source: {interface_type}")
+        return client_class(*args, **kwargs)
 
 
 factory = NoSQLAdaptorFactory()
-factory.register(type(MongoClient).__name__, MongoDB)
-factory.register("dynamodb.ServiceResource", DynamoDB)
+adaptors = {
+    MongoDBConnection.__name__: MongoDB,
+    DynamoDBConnection.__name__: DynamoDB,
+}
+factory.register_many(adaptors)

ingestion/src/metadata/profiler/interface/nosql/profiler_interface.py

@@ -165,7 +165,10 @@ def _get_sampler(self) -> NoSQLSampler:
         return sampler_factory_.create(
             self.service_connection_config.__class__.__name__,
             table=self.table,
-            client=factory.create(self.connection),
+            client=factory.create(
+                self.service_connection_config.config.__class__.__name__,
+                client=self.connection,
+            ),
             profile_sample_config=self.profile_sample_config,
             partition_details=self.partition_details,
             profile_sample_query=self.profile_query,
@@ -187,7 +190,10 @@ def get_all_metrics(
     ):
         """get all profiler metrics"""
         profile_results = {"table": {}, "columns": defaultdict(dict)}
-        runner = factory.create(self.connection)
+        runner = factory.create(
+            self.service_connection_config.config.__class__.__name__,
+            client=self.connection,
+        )
         metric_list = [
             self.compute_metrics(runner, metric_func) for metric_func in metric_funcs
         ]

ingestion/tests/integration/profiler/conftest.py

@@ -2,7 +2,7 @@
 
 import boto3
 import pytest
-from integration.integration_base import int_admin_ometa
+from ...integration.integration_base import int_admin_ometa
 from testcontainers.localstack import LocalStackContainer
 
 from metadata.generated.schema.api.services.createDatabaseService import (