[AutoPR azure-mgmt-datafactory] Add MongoDB/MongoDBAtlas sink

sdk/datafactory/azure-mgmt-datafactory/MANIFEST.in

@@ -1,3 +1,4 @@
+include _meta.json
 recursive-include tests *.py *.yaml
 include *.md
 include azure/__init__.py

sdk/datafactory/azure-mgmt-datafactory/_meta.json

@@ -0,0 +1,8 @@
+{
+  "autorest": "V2",
+  "use": "@microsoft.azure/autorest.python@~4.0.71",
+  "commit": "361651646870a3cfad36f9caee14db72c57c1460",
+  "repository_url": "https://github.com/Azure/azure-rest-api-specs",
+  "autorest_command": "autorest specification/datafactory/resource-manager/readme.md --keep-version-file --multiapi --no-async --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/s/azure-sdk-for-python/sdk [email protected]/autorest.python@~4.0.71 --version=V2",
+  "readme": "specification/datafactory/resource-manager/readme.md"
+}

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_data_factory_management_client.py

@@ -30,6 +30,9 @@
 from .operations import DataFlowDebugSessionOperations
 from .operations import ManagedVirtualNetworksOperations
 from .operations import ManagedPrivateEndpointsOperations
+from .operations import PrivateEndPointConnectionsOperations
+from .operations import PrivateEndpointConnectionOperations
+from .operations import PrivateLinkResourcesOperations
 from . import models
 
 
@@ -73,6 +76,12 @@ class DataFactoryManagementClient(SDKClient):
     :vartype managed_virtual_networks: azure.mgmt.datafactory.operations.ManagedVirtualNetworksOperations
     :ivar managed_private_endpoints: ManagedPrivateEndpoints operations
     :vartype managed_private_endpoints: azure.mgmt.datafactory.operations.ManagedPrivateEndpointsOperations
+    :ivar private_end_point_connections: PrivateEndPointConnections operations
+    :vartype private_end_point_connections: azure.mgmt.datafactory.operations.PrivateEndPointConnectionsOperations
+    :ivar private_endpoint_connection: PrivateEndpointConnection operations
+    :vartype private_endpoint_connection: azure.mgmt.datafactory.operations.PrivateEndpointConnectionOperations
+    :ivar private_link_resources: PrivateLinkResources operations
+    :vartype private_link_resources: azure.mgmt.datafactory.operations.PrivateLinkResourcesOperations
 
     :param credentials: Credentials needed for the client to connect to Azure.
     :type credentials: :mod:`A msrestazure Credentials
@@ -127,3 +136,9 @@ def __init__(
             self._client, self.config, self._serialize, self._deserialize)
         self.managed_private_endpoints = ManagedPrivateEndpointsOperations(
             self._client, self.config, self._serialize, self._deserialize)
+        self.private_end_point_connections = PrivateEndPointConnectionsOperations(
+            self._client, self.config, self._serialize, self._deserialize)
+        self.private_endpoint_connection = PrivateEndpointConnectionOperations(
+            self._client, self.config, self._serialize, self._deserialize)
+        self.private_link_resources = PrivateLinkResourcesOperations(
+            self._client, self.config, self._serialize, self._deserialize)

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py

@@ -24,11 +24,15 @@
     from ._models_py3 import AmazonRedshiftLinkedService
     from ._models_py3 import AmazonRedshiftSource
     from ._models_py3 import AmazonRedshiftTableDataset
+    from ._models_py3 import AmazonS3CompatibleLinkedService
+    from ._models_py3 import AmazonS3CompatibleLocation
+    from ._models_py3 import AmazonS3CompatibleReadSettings
     from ._models_py3 import AmazonS3Dataset
     from ._models_py3 import AmazonS3LinkedService
     from ._models_py3 import AmazonS3Location
     from ._models_py3 import AmazonS3ReadSettings
     from ._models_py3 import AppendVariableActivity
+    from ._models_py3 import ArmIdWrapper
     from ._models_py3 import AvroDataset
     from ._models_py3 import AvroFormat
     from ._models_py3 import AvroSink
@@ -387,13 +391,15 @@
     from ._models_py3 import MicrosoftAccessTableDataset
     from ._models_py3 import MongoDbAtlasCollectionDataset
     from ._models_py3 import MongoDbAtlasLinkedService
+    from ._models_py3 import MongoDbAtlasSink
     from ._models_py3 import MongoDbAtlasSource
     from ._models_py3 import MongoDbCollectionDataset
     from ._models_py3 import MongoDbCursorMethodsProperties
     from ._models_py3 import MongoDbLinkedService
     from ._models_py3 import MongoDbSource
     from ._models_py3 import MongoDbV2CollectionDataset
     from ._models_py3 import MongoDbV2LinkedService
+    from ._models_py3 import MongoDbV2Sink
     from ._models_py3 import MongoDbV2Source
     from ._models_py3 import MultiplePipelineTrigger
     from ._models_py3 import MySqlLinkedService
@@ -420,6 +426,9 @@
     from ._models_py3 import OperationMetricDimension
     from ._models_py3 import OperationMetricSpecification
     from ._models_py3 import OperationServiceSpecification
+    from ._models_py3 import OracleCloudStorageLinkedService
+    from ._models_py3 import OracleCloudStorageLocation
+    from ._models_py3 import OracleCloudStorageReadSettings
     from ._models_py3 import OracleLinkedService
     from ._models_py3 import OraclePartitionSettings
     from ._models_py3 import OracleServiceCloudLinkedService
@@ -461,6 +470,13 @@
     from ._models_py3 import PrestoLinkedService
     from ._models_py3 import PrestoObjectDataset
     from ._models_py3 import PrestoSource
+    from ._models_py3 import PrivateEndpointConnectionResource
+    from ._models_py3 import PrivateLinkConnectionApprovalRequest
+    from ._models_py3 import PrivateLinkConnectionApprovalRequestResource
+    from ._models_py3 import PrivateLinkConnectionState
+    from ._models_py3 import PrivateLinkResource
+    from ._models_py3 import PrivateLinkResourceProperties
+    from ._models_py3 import PrivateLinkResourcesWrapper
     from ._models_py3 import QuickBooksLinkedService
     from ._models_py3 import QuickBooksObjectDataset
     from ._models_py3 import QuickBooksSource
@@ -470,6 +486,7 @@
     from ._models_py3 import RedshiftUnloadSettings
     from ._models_py3 import RelationalSource
     from ._models_py3 import RelationalTableDataset
+    from ._models_py3 import RemotePrivateEndpointConnection
     from ._models_py3 import RerunTumblingWindowTrigger
     from ._models_py3 import Resource
     from ._models_py3 import ResponsysLinkedService
@@ -548,6 +565,7 @@
     from ._models_py3 import SparkLinkedService
     from ._models_py3 import SparkObjectDataset
     from ._models_py3 import SparkSource
+    from ._models_py3 import SqlAlwaysEncryptedProperties
     from ._models_py3 import SqlDWSink
     from ._models_py3 import SqlDWSource
     from ._models_py3 import SqlMISink
@@ -660,11 +678,15 @@
     from ._models import AmazonRedshiftLinkedService
     from ._models import AmazonRedshiftSource
     from ._models import AmazonRedshiftTableDataset
+    from ._models import AmazonS3CompatibleLinkedService
+    from ._models import AmazonS3CompatibleLocation
+    from ._models import AmazonS3CompatibleReadSettings
     from ._models import AmazonS3Dataset
     from ._models import AmazonS3LinkedService
     from ._models import AmazonS3Location
     from ._models import AmazonS3ReadSettings
     from ._models import AppendVariableActivity
+    from ._models import ArmIdWrapper
     from ._models import AvroDataset
     from ._models import AvroFormat
     from ._models import AvroSink
@@ -1023,13 +1045,15 @@
     from ._models import MicrosoftAccessTableDataset
     from ._models import MongoDbAtlasCollectionDataset
     from ._models import MongoDbAtlasLinkedService
+    from ._models import MongoDbAtlasSink
     from ._models import MongoDbAtlasSource
     from ._models import MongoDbCollectionDataset
     from ._models import MongoDbCursorMethodsProperties
     from ._models import MongoDbLinkedService
     from ._models import MongoDbSource
     from ._models import MongoDbV2CollectionDataset
     from ._models import MongoDbV2LinkedService
+    from ._models import MongoDbV2Sink
     from ._models import MongoDbV2Source
     from ._models import MultiplePipelineTrigger
     from ._models import MySqlLinkedService
@@ -1056,6 +1080,9 @@
     from ._models import OperationMetricDimension
     from ._models import OperationMetricSpecification
     from ._models import OperationServiceSpecification
+    from ._models import OracleCloudStorageLinkedService
+    from ._models import OracleCloudStorageLocation
+    from ._models import OracleCloudStorageReadSettings
     from ._models import OracleLinkedService
     from ._models import OraclePartitionSettings
     from ._models import OracleServiceCloudLinkedService
@@ -1097,6 +1124,13 @@
     from ._models import PrestoLinkedService
     from ._models import PrestoObjectDataset
     from ._models import PrestoSource
+    from ._models import PrivateEndpointConnectionResource
+    from ._models import PrivateLinkConnectionApprovalRequest
+    from ._models import PrivateLinkConnectionApprovalRequestResource
+    from ._models import PrivateLinkConnectionState
+    from ._models import PrivateLinkResource
+    from ._models import PrivateLinkResourceProperties
+    from ._models import PrivateLinkResourcesWrapper
     from ._models import QuickBooksLinkedService
     from ._models import QuickBooksObjectDataset
     from ._models import QuickBooksSource
@@ -1106,6 +1140,7 @@
     from ._models import RedshiftUnloadSettings
     from ._models import RelationalSource
     from ._models import RelationalTableDataset
+    from ._models import RemotePrivateEndpointConnection
     from ._models import RerunTumblingWindowTrigger
     from ._models import Resource
     from ._models import ResponsysLinkedService
@@ -1184,6 +1219,7 @@
     from ._models import SparkLinkedService
     from ._models import SparkObjectDataset
     from ._models import SparkSource
+    from ._models import SqlAlwaysEncryptedProperties
     from ._models import SqlDWSink
     from ._models import SqlDWSource
     from ._models import SqlMISink
@@ -1291,6 +1327,7 @@
 from ._paged_models import ManagedVirtualNetworkResourcePaged
 from ._paged_models import OperationPaged
 from ._paged_models import PipelineResourcePaged
+from ._paged_models import PrivateEndpointConnectionResourcePaged
 from ._paged_models import TriggerResourcePaged
 from ._data_factory_management_client_enums import (
     FactoryIdentityType,
@@ -1337,6 +1374,7 @@
     DynamicsAuthenticationType,
     CosmosDbServicePrincipalCredentialType,
     CosmosDbConnectionMode,
+    SqlAlwaysEncryptedAkvAuthType,
     OrcCompressionCodec,
     AvroCompressionCodec,
     TumblingWindowFrequency,
@@ -1394,11 +1432,15 @@
     'AmazonRedshiftLinkedService',
     'AmazonRedshiftSource',
     'AmazonRedshiftTableDataset',
+    'AmazonS3CompatibleLinkedService',
+    'AmazonS3CompatibleLocation',
+    'AmazonS3CompatibleReadSettings',
     'AmazonS3Dataset',
     'AmazonS3LinkedService',
     'AmazonS3Location',
     'AmazonS3ReadSettings',
     'AppendVariableActivity',
+    'ArmIdWrapper',
     'AvroDataset',
     'AvroFormat',
     'AvroSink',
@@ -1757,13 +1799,15 @@
     'MicrosoftAccessTableDataset',
     'MongoDbAtlasCollectionDataset',
     'MongoDbAtlasLinkedService',
+    'MongoDbAtlasSink',
     'MongoDbAtlasSource',
     'MongoDbCollectionDataset',
     'MongoDbCursorMethodsProperties',
     'MongoDbLinkedService',
     'MongoDbSource',
     'MongoDbV2CollectionDataset',
     'MongoDbV2LinkedService',
+    'MongoDbV2Sink',
     'MongoDbV2Source',
     'MultiplePipelineTrigger',
     'MySqlLinkedService',
@@ -1790,6 +1834,9 @@
     'OperationMetricDimension',
     'OperationMetricSpecification',
     'OperationServiceSpecification',
+    'OracleCloudStorageLinkedService',
+    'OracleCloudStorageLocation',
+    'OracleCloudStorageReadSettings',
     'OracleLinkedService',
     'OraclePartitionSettings',
     'OracleServiceCloudLinkedService',
@@ -1831,6 +1878,13 @@
     'PrestoLinkedService',
     'PrestoObjectDataset',
     'PrestoSource',
+    'PrivateEndpointConnectionResource',
+    'PrivateLinkConnectionApprovalRequest',
+    'PrivateLinkConnectionApprovalRequestResource',
+    'PrivateLinkConnectionState',
+    'PrivateLinkResource',
+    'PrivateLinkResourceProperties',
+    'PrivateLinkResourcesWrapper',
     'QuickBooksLinkedService',
     'QuickBooksObjectDataset',
     'QuickBooksSource',
@@ -1840,6 +1894,7 @@
     'RedshiftUnloadSettings',
     'RelationalSource',
     'RelationalTableDataset',
+    'RemotePrivateEndpointConnection',
     'RerunTumblingWindowTrigger',
     'Resource',
     'ResponsysLinkedService',
@@ -1918,6 +1973,7 @@
     'SparkLinkedService',
     'SparkObjectDataset',
     'SparkSource',
+    'SqlAlwaysEncryptedProperties',
     'SqlDWSink',
     'SqlDWSource',
     'SqlMISink',
@@ -2026,6 +2082,7 @@
     'DataFlowDebugSessionInfoPaged',
     'ManagedVirtualNetworkResourcePaged',
     'ManagedPrivateEndpointResourcePaged',
+    'PrivateEndpointConnectionResourcePaged',
     'FactoryIdentityType',
     'GlobalParameterType',
     'PublicNetworkAccess',
@@ -2070,6 +2127,7 @@
     'DynamicsAuthenticationType',
     'CosmosDbServicePrincipalCredentialType',
     'CosmosDbConnectionMode',
+    'SqlAlwaysEncryptedAkvAuthType',
     'OrcCompressionCodec',
     'AvroCompressionCodec',
     'TumblingWindowFrequency',

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py

@@ -341,6 +341,12 @@ class CosmosDbConnectionMode(str, Enum):
     direct = "Direct"
 
 
+class SqlAlwaysEncryptedAkvAuthType(str, Enum):
+
+    service_principal = "ServicePrincipal"
+    managed_identity = "ManagedIdentity"
+
+
 class OrcCompressionCodec(str, Enum):
 
     none = "none"