diff --git a/eng/mgmt/mgmtmetadata/datafactory_resource-manager.txt b/eng/mgmt/mgmtmetadata/datafactory_resource-manager.txt index 8f74f026cbebf..29609e2f46dd3 100644 --- a/eng/mgmt/mgmtmetadata/datafactory_resource-manager.txt +++ b/eng/mgmt/mgmtmetadata/datafactory_resource-manager.txt @@ -4,11 +4,11 @@ Commencing code generation Generating CSharp code Executing AutoRest command cmd.exe /c autorest.cmd https://github.com/Azure/azure-rest-api-specs/blob/master/specification/datafactory/resource-manager/readme.md --csharp --version=v2 --reflect-api-versions --tag=package-2018-06 --csharp-sdks-folder=D:\Projects\azure-sdk-for-net\sdk -2021-04-01 08:12:55 UTC +2021-04-19 06:02:05 UTC Azure-rest-api-specs repository information GitHub fork: Azure Branch: master -Commit: 467bc839e205459f530f4b33e08e57882734a8f5 +Commit: 2917973fd886553c6277b66d786dc2827d11c386 AutoRest information Requested version: v2 Bootstrapper version: autorest@2.0.4413 diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/CHANGELOG.md b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/CHANGELOG.md index 8e7508f6d9780..a8e7f3685636f 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/CHANGELOG.md +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/CHANGELOG.md @@ -1,5 +1,10 @@ # Changelog for the Azure Data Factory V2 .NET SDK +## Version 4.18.0 +### Feature Additions +- Added MongoDB/MongoDBAtlas sink +- Added Sql always encrypted settings + ## Version 4.17.1 ### Feature Additions - Fixed potential MI type missing issue by using system assigned MI as default diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlDatabaseLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlDatabaseLinkedService.cs index adf8fc049fccd..61cd7f5fc6a47 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlDatabaseLinkedService.cs +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlDatabaseLinkedService.cs @@ -65,7 +65,9 @@ public AzureSqlDatabaseLinkedService() /// authentication. Credentials are encrypted using the integration /// runtime credential manager. Type: string (or Expression with /// resultType string). - public AzureSqlDatabaseLinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), AzureKeyVaultSecretReference password = default(AzureKeyVaultSecretReference), object servicePrincipalId = default(object), SecretBase servicePrincipalKey = default(SecretBase), object tenant = default(object), object azureCloudType = default(object), object encryptedCredential = default(object)) + /// Sql always encrypted + /// properties. + public AzureSqlDatabaseLinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), AzureKeyVaultSecretReference password = default(AzureKeyVaultSecretReference), object servicePrincipalId = default(object), SecretBase servicePrincipalKey = default(SecretBase), object tenant = default(object), object azureCloudType = default(object), object encryptedCredential = default(object), SqlAlwaysEncryptedProperties alwaysEncryptedSettings = default(SqlAlwaysEncryptedProperties)) : base(additionalProperties, connectVia, description, parameters, annotations) { ConnectionString = connectionString; @@ -75,6 +77,7 @@ public AzureSqlDatabaseLinkedService() Tenant = tenant; AzureCloudType = azureCloudType; EncryptedCredential = encryptedCredential; + AlwaysEncryptedSettings = alwaysEncryptedSettings; CustomInit(); } @@ -138,6 +141,12 @@ public AzureSqlDatabaseLinkedService() [JsonProperty(PropertyName = "typeProperties.encryptedCredential")] public object EncryptedCredential { get; set; } + /// + /// Gets or sets sql always encrypted properties. + /// + [JsonProperty(PropertyName = "typeProperties.alwaysEncryptedSettings")] + public SqlAlwaysEncryptedProperties AlwaysEncryptedSettings { get; set; } + /// /// Validate the object. /// @@ -155,6 +164,10 @@ public override void Validate() { Password.Validate(); } + if (AlwaysEncryptedSettings != null) + { + AlwaysEncryptedSettings.Validate(); + } } } } diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs index c3f7e2891d9c6..9363409a926aa 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs @@ -63,7 +63,9 @@ public AzureSqlMILinkedService() /// authentication. Credentials are encrypted using the integration /// runtime credential manager. Type: string (or Expression with /// resultType string). - public AzureSqlMILinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), AzureKeyVaultSecretReference password = default(AzureKeyVaultSecretReference), object servicePrincipalId = default(object), SecretBase servicePrincipalKey = default(SecretBase), object tenant = default(object), object azureCloudType = default(object), object encryptedCredential = default(object)) + /// Sql always encrypted + /// properties. + public AzureSqlMILinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), AzureKeyVaultSecretReference password = default(AzureKeyVaultSecretReference), object servicePrincipalId = default(object), SecretBase servicePrincipalKey = default(SecretBase), object tenant = default(object), object azureCloudType = default(object), object encryptedCredential = default(object), SqlAlwaysEncryptedProperties alwaysEncryptedSettings = default(SqlAlwaysEncryptedProperties)) : base(additionalProperties, connectVia, description, parameters, annotations) { ConnectionString = connectionString; @@ -73,6 +75,7 @@ public AzureSqlMILinkedService() Tenant = tenant; AzureCloudType = azureCloudType; EncryptedCredential = encryptedCredential; + AlwaysEncryptedSettings = alwaysEncryptedSettings; CustomInit(); } @@ -136,6 +139,12 @@ public AzureSqlMILinkedService() [JsonProperty(PropertyName = "typeProperties.encryptedCredential")] public object EncryptedCredential { get; set; } + /// + /// Gets or sets sql always encrypted properties. + /// + [JsonProperty(PropertyName = "typeProperties.alwaysEncryptedSettings")] + public SqlAlwaysEncryptedProperties AlwaysEncryptedSettings { get; set; } + /// /// Validate the object. /// @@ -153,6 +162,10 @@ public override void Validate() { Password.Validate(); } + if (AlwaysEncryptedSettings != null) + { + AlwaysEncryptedSettings.Validate(); + } } } } diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MongoDbAtlasSink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MongoDbAtlasSink.cs new file mode 100644 index 0000000000000..7106c1a4db39c --- /dev/null +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MongoDbAtlasSink.cs @@ -0,0 +1,77 @@ +// +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for +// license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is +// regenerated. +// + +namespace Microsoft.Azure.Management.DataFactory.Models +{ + using Newtonsoft.Json; + using System.Collections; + using System.Collections.Generic; + using System.Linq; + + /// + /// A copy activity MongoDB Atlas sink. + /// + public partial class MongoDbAtlasSink : CopySink + { + /// + /// Initializes a new instance of the MongoDbAtlasSink class. + /// + public MongoDbAtlasSink() + { + CustomInit(); + } + + /// + /// Initializes a new instance of the MongoDbAtlasSink class. + /// + /// Unmatched properties from the + /// message are deserialized this collection + /// Write batch size. Type: integer (or + /// Expression with resultType integer), minimum: 0. + /// Write batch timeout. Type: string + /// (or Expression with resultType string), pattern: + /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + /// Sink retry count. Type: integer (or + /// Expression with resultType integer). + /// Sink retry wait. Type: string (or + /// Expression with resultType string), pattern: + /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + /// The maximum concurrent + /// connection count for the sink data store. Type: integer (or + /// Expression with resultType integer). + /// Specifies whether the document with + /// same key to be overwritten (upsert) rather than throw exception + /// (insert). The default value is "insert". Type: string (or + /// Expression with resultType string). Type: string (or Expression + /// with resultType string). + public MongoDbAtlasSink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object writeBehavior = default(object)) + : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections) + { + WriteBehavior = writeBehavior; + CustomInit(); + } + + /// + /// An initialization method that performs custom operations like setting defaults + /// + partial void CustomInit(); + + /// + /// Gets or sets specifies whether the document with same key to be + /// overwritten (upsert) rather than throw exception (insert). The + /// default value is "insert". Type: string (or Expression with + /// resultType string). Type: string (or Expression with resultType + /// string). + /// + [JsonProperty(PropertyName = "writeBehavior")] + public object WriteBehavior { get; set; } + + } +} diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MongoDbV2Sink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MongoDbV2Sink.cs new file mode 100644 index 0000000000000..9a21c9d9c42fa --- /dev/null +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MongoDbV2Sink.cs @@ -0,0 +1,77 @@ +// +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for +// license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is +// regenerated. +// + +namespace Microsoft.Azure.Management.DataFactory.Models +{ + using Newtonsoft.Json; + using System.Collections; + using System.Collections.Generic; + using System.Linq; + + /// + /// A copy activity MongoDB sink. + /// + public partial class MongoDbV2Sink : CopySink + { + /// + /// Initializes a new instance of the MongoDbV2Sink class. + /// + public MongoDbV2Sink() + { + CustomInit(); + } + + /// + /// Initializes a new instance of the MongoDbV2Sink class. + /// + /// Unmatched properties from the + /// message are deserialized this collection + /// Write batch size. Type: integer (or + /// Expression with resultType integer), minimum: 0. + /// Write batch timeout. Type: string + /// (or Expression with resultType string), pattern: + /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + /// Sink retry count. Type: integer (or + /// Expression with resultType integer). + /// Sink retry wait. Type: string (or + /// Expression with resultType string), pattern: + /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). + /// The maximum concurrent + /// connection count for the sink data store. Type: integer (or + /// Expression with resultType integer). + /// Specifies whether the document with + /// same key to be overwritten (upsert) rather than throw exception + /// (insert). The default value is "insert". Type: string (or + /// Expression with resultType string). Type: string (or Expression + /// with resultType string). + public MongoDbV2Sink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object writeBehavior = default(object)) + : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections) + { + WriteBehavior = writeBehavior; + CustomInit(); + } + + /// + /// An initialization method that performs custom operations like setting defaults + /// + partial void CustomInit(); + + /// + /// Gets or sets specifies whether the document with same key to be + /// overwritten (upsert) rather than throw exception (insert). The + /// default value is "insert". Type: string (or Expression with + /// resultType string). Type: string (or Expression with resultType + /// string). + /// + [JsonProperty(PropertyName = "writeBehavior")] + public object WriteBehavior { get; set; } + + } +} diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlAlwaysEncryptedAkvAuthType.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlAlwaysEncryptedAkvAuthType.cs new file mode 100644 index 0000000000000..2072bf64d6d12 --- /dev/null +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlAlwaysEncryptedAkvAuthType.cs @@ -0,0 +1,22 @@ +// +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for +// license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is +// regenerated. +// + +namespace Microsoft.Azure.Management.DataFactory.Models +{ + + /// + /// Defines values for SqlAlwaysEncryptedAkvAuthType. + /// + public static class SqlAlwaysEncryptedAkvAuthType + { + public const string ServicePrincipal = "ServicePrincipal"; + public const string ManagedIdentity = "ManagedIdentity"; + } +} diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlAlwaysEncryptedProperties.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlAlwaysEncryptedProperties.cs new file mode 100644 index 0000000000000..2feba70930537 --- /dev/null +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlAlwaysEncryptedProperties.cs @@ -0,0 +1,94 @@ +// +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. See License.txt in the project root for +// license information. +// +// Code generated by Microsoft (R) AutoRest Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is +// regenerated. +// + +namespace Microsoft.Azure.Management.DataFactory.Models +{ + using Microsoft.Rest; + using Newtonsoft.Json; + using System.Linq; + + /// + /// Sql always encrypted properties. + /// + public partial class SqlAlwaysEncryptedProperties + { + /// + /// Initializes a new instance of the SqlAlwaysEncryptedProperties + /// class. + /// + public SqlAlwaysEncryptedProperties() + { + CustomInit(); + } + + /// + /// Initializes a new instance of the SqlAlwaysEncryptedProperties + /// class. + /// + /// Sql always encrypted AKV + /// authentication type. Type: string (or Expression with resultType + /// string). Possible values include: 'ServicePrincipal', + /// 'ManagedIdentity' + /// The client ID of the application + /// in Azure Active Directory used for Azure Key Vault authentication. + /// Type: string (or Expression with resultType string). + /// The key of the service principal + /// used to authenticate against Azure Key Vault. + public SqlAlwaysEncryptedProperties(string alwaysEncryptedAkvAuthType, object servicePrincipalId = default(object), SecretBase servicePrincipalKey = default(SecretBase)) + { + AlwaysEncryptedAkvAuthType = alwaysEncryptedAkvAuthType; + ServicePrincipalId = servicePrincipalId; + ServicePrincipalKey = servicePrincipalKey; + CustomInit(); + } + + /// + /// An initialization method that performs custom operations like setting defaults + /// + partial void CustomInit(); + + /// + /// Gets or sets sql always encrypted AKV authentication type. Type: + /// string (or Expression with resultType string). Possible values + /// include: 'ServicePrincipal', 'ManagedIdentity' + /// + [JsonProperty(PropertyName = "alwaysEncryptedAkvAuthType")] + public string AlwaysEncryptedAkvAuthType { get; set; } + + /// + /// Gets or sets the client ID of the application in Azure Active + /// Directory used for Azure Key Vault authentication. Type: string (or + /// Expression with resultType string). + /// + [JsonProperty(PropertyName = "servicePrincipalId")] + public object ServicePrincipalId { get; set; } + + /// + /// Gets or sets the key of the service principal used to authenticate + /// against Azure Key Vault. + /// + [JsonProperty(PropertyName = "servicePrincipalKey")] + public SecretBase ServicePrincipalKey { get; set; } + + /// + /// Validate the object. + /// + /// + /// Thrown if validation fails + /// + public virtual void Validate() + { + if (AlwaysEncryptedAkvAuthType == null) + { + throw new ValidationException(ValidationRules.CannotBeNull, "AlwaysEncryptedAkvAuthType"); + } + } + } +} diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerLinkedService.cs index 25b3132c5d1ee..35045e230c5a0 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerLinkedService.cs +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlServerLinkedService.cs @@ -52,13 +52,16 @@ public SqlServerLinkedService() /// authentication. Credentials are encrypted using the integration /// runtime credential manager. Type: string (or Expression with /// resultType string). - public SqlServerLinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object userName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object)) + /// Sql always encrypted + /// properties. + public SqlServerLinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object userName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object), SqlAlwaysEncryptedProperties alwaysEncryptedSettings = default(SqlAlwaysEncryptedProperties)) : base(additionalProperties, connectVia, description, parameters, annotations) { ConnectionString = connectionString; UserName = userName; Password = password; EncryptedCredential = encryptedCredential; + AlwaysEncryptedSettings = alwaysEncryptedSettings; CustomInit(); } @@ -95,6 +98,12 @@ public SqlServerLinkedService() [JsonProperty(PropertyName = "typeProperties.encryptedCredential")] public object EncryptedCredential { get; set; } + /// + /// Gets or sets sql always encrypted properties. + /// + [JsonProperty(PropertyName = "typeProperties.alwaysEncryptedSettings")] + public SqlAlwaysEncryptedProperties AlwaysEncryptedSettings { get; set; } + /// /// Validate the object. /// @@ -108,6 +117,10 @@ public override void Validate() { throw new ValidationException(ValidationRules.CannotBeNull, "ConnectionString"); } + if (AlwaysEncryptedSettings != null) + { + AlwaysEncryptedSettings.Validate(); + } } } } diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj index f72e1c3b1f667..5261abe94990d 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj @@ -5,12 +5,13 @@ Microsoft.Azure.Management.DataFactory Azure Data Factory V2 is the data integration platform that goes beyond Azure Data Factory V1's orchestration and batch-processing of time-series data, with a general purpose app model supporting modern data warehousing patterns and scenarios, lift-and-shift SSIS, and data-driven SaaS applications. Compose and manage reliable and secure data integration workflows at scale. Use native ADF data connectors and Integration Runtimes to move and transform cloud and on-premises data that can be unstructured, semi-structured, and structured with Hadoop, Azure Data Lake, Spark, SQL Server, Cosmos DB and many other data platforms. - 4.17.1 + 4.18.0 Microsoft.Azure.Management.DataFactory Microsoft Azure resource management;Data Factory;ADF; diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs index 3ecc2e07c8c0b..3d119a9956996 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs @@ -6,8 +6,8 @@ [assembly: AssemblyTitle("Microsoft Azure Data Factory Management Library")] [assembly: AssemblyDescription("Provides management functionality for Microsoft Azure Data Factory Resources.")] -[assembly: AssemblyVersion("4.17.1.0")] -[assembly: AssemblyFileVersion("4.17.1.0")] +[assembly: AssemblyVersion("4.18.0.0")] +[assembly: AssemblyFileVersion("4.18.0.0")] [assembly: AssemblyConfiguration("")] [assembly: AssemblyCompany("Microsoft")] [assembly: AssemblyProduct("Microsoft Azure .NET SDK")] diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs index 581cb4f3b3f77..106182ada0aa2 100644 --- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs +++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs @@ -173,6 +173,39 @@ public class LinkedServiceJsonSamples : JsonSampleCollection } } } +"; + + [JsonSample] + public const string MongoDbV2SinkCopyActivity = @" +{ + ""name"": ""ExampleCopyActivity"", + ""properties"": { + ""activities"": [ + { + ""name"": ""MyActivity"", + ""type"": ""Copy"", + ""typeProperties"": { + ""source"": { + ""type"": ""MongoDbAtlasSource"", + ""filter"": { + ""value"": ""@dataset().MyFilter"" + }, + ""cursorMethods"": { + ""project"": { + ""value"": ""@dataset().MyProject"", + ""type"": ""Expression"" + }, + ""sort"": ""{ age : 1 }"", + ""skip"": ""3"", + ""limit"": ""3"" + }, + ""batchSize"": ""5"" + }, + ""sink"": { + ""type"": ""MongoDbV2Sink"", + ""writeBehavior"": ""upsert"", + ""writeBatchSize"": ""5000"" + } + }, + ""inputs"": [ + { + ""referenceName"": ""exampleSourceDataset"", + ""type"": ""DatasetReference"" + } + ], + ""outputs"": [ + { + ""referenceName"": ""exampleSinkDataset"", + ""type"": ""DatasetReference"" + } + ] + } + ], + ""parameters"": { + ""MyFilter"": { + ""type"": ""String"" + }, + ""MyProject"": { + ""type"": ""String"" + } + } +} +} "; [JsonSample]