Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[AutoPR datafactory/resource-manager] SSIS File System Support #4810

Closed
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -339,6 +339,8 @@
from .sql_server_stored_procedure_activity_py3 import SqlServerStoredProcedureActivity
from .custom_activity_reference_object_py3 import CustomActivityReferenceObject
from .custom_activity_py3 import CustomActivity
from .ssis_access_credential_py3 import SSISAccessCredential
from .ssis_log_location_py3 import SSISLogLocation
from .ssis_property_override_py3 import SSISPropertyOverride
from .ssis_execution_parameter_py3 import SSISExecutionParameter
from .ssis_execution_credential_py3 import SSISExecutionCredential
Expand Down Expand Up @@ -378,6 +380,7 @@
from .append_variable_activity_py3 import AppendVariableActivity
from .set_variable_activity_py3 import SetVariableActivity
from .filter_activity_py3 import FilterActivity
from .validation_activity_py3 import ValidationActivity
from .until_activity_py3 import UntilActivity
from .wait_activity_py3 import WaitActivity
from .for_each_activity_py3 import ForEachActivity
Expand Down Expand Up @@ -739,6 +742,8 @@
from .sql_server_stored_procedure_activity import SqlServerStoredProcedureActivity
from .custom_activity_reference_object import CustomActivityReferenceObject
from .custom_activity import CustomActivity
from .ssis_access_credential import SSISAccessCredential
from .ssis_log_location import SSISLogLocation
from .ssis_property_override import SSISPropertyOverride
from .ssis_execution_parameter import SSISExecutionParameter
from .ssis_execution_credential import SSISExecutionCredential
Expand Down Expand Up @@ -778,6 +783,7 @@
from .append_variable_activity import AppendVariableActivity
from .set_variable_activity import SetVariableActivity
from .filter_activity import FilterActivity
from .validation_activity import ValidationActivity
from .until_activity import UntilActivity
from .wait_activity import WaitActivity
from .for_each_activity import ForEachActivity
Expand Down Expand Up @@ -865,6 +871,7 @@
CassandraSourceReadConsistencyLevels,
StoredProcedureParameterType,
SalesforceSourceReadBehavior,
SsisPackageLocationType,
HDInsightActivityDebugInfoOption,
SalesforceSinkWriteBehavior,
AzureSearchIndexWriteBehaviorType,
Expand Down Expand Up @@ -1214,6 +1221,8 @@
'SqlServerStoredProcedureActivity',
'CustomActivityReferenceObject',
'CustomActivity',
'SSISAccessCredential',
'SSISLogLocation',
'SSISPropertyOverride',
'SSISExecutionParameter',
'SSISExecutionCredential',
Expand Down Expand Up @@ -1253,6 +1262,7 @@
'AppendVariableActivity',
'SetVariableActivity',
'FilterActivity',
'ValidationActivity',
'UntilActivity',
'WaitActivity',
'ForEachActivity',
Expand Down Expand Up @@ -1339,6 +1349,7 @@
'CassandraSourceReadConsistencyLevels',
'StoredProcedureParameterType',
'SalesforceSourceReadBehavior',
'SsisPackageLocationType',
'HDInsightActivityDebugInfoOption',
'SalesforceSinkWriteBehavior',
'AzureSearchIndexWriteBehaviorType',
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@ class ControlActivity(Activity):

You probably want to use the sub-classes and not this class directly. Known
sub-classes are: WebHookActivity, AppendVariableActivity,
SetVariableActivity, FilterActivity, UntilActivity, WaitActivity,
ForEachActivity, IfConditionActivity, ExecutePipelineActivity
SetVariableActivity, FilterActivity, ValidationActivity, UntilActivity,
WaitActivity, ForEachActivity, IfConditionActivity, ExecutePipelineActivity

All required parameters must be populated in order to send to Azure.

Expand Down Expand Up @@ -52,7 +52,7 @@ class ControlActivity(Activity):
}

_subtype_map = {
'type': {'WebHook': 'WebHookActivity', 'AppendVariable': 'AppendVariableActivity', 'SetVariable': 'SetVariableActivity', 'Filter': 'FilterActivity', 'Until': 'UntilActivity', 'Wait': 'WaitActivity', 'ForEach': 'ForEachActivity', 'IfCondition': 'IfConditionActivity', 'ExecutePipeline': 'ExecutePipelineActivity'}
'type': {'WebHook': 'WebHookActivity', 'AppendVariable': 'AppendVariableActivity', 'SetVariable': 'SetVariableActivity', 'Filter': 'FilterActivity', 'Validation': 'ValidationActivity', 'Until': 'UntilActivity', 'Wait': 'WaitActivity', 'ForEach': 'ForEachActivity', 'IfCondition': 'IfConditionActivity', 'ExecutePipeline': 'ExecutePipelineActivity'}
}

def __init__(self, **kwargs):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@ class ControlActivity(Activity):

You probably want to use the sub-classes and not this class directly. Known
sub-classes are: WebHookActivity, AppendVariableActivity,
SetVariableActivity, FilterActivity, UntilActivity, WaitActivity,
ForEachActivity, IfConditionActivity, ExecutePipelineActivity
SetVariableActivity, FilterActivity, ValidationActivity, UntilActivity,
WaitActivity, ForEachActivity, IfConditionActivity, ExecutePipelineActivity

All required parameters must be populated in order to send to Azure.

Expand Down Expand Up @@ -52,7 +52,7 @@ class ControlActivity(Activity):
}

_subtype_map = {
'type': {'WebHook': 'WebHookActivity', 'AppendVariable': 'AppendVariableActivity', 'SetVariable': 'SetVariableActivity', 'Filter': 'FilterActivity', 'Until': 'UntilActivity', 'Wait': 'WaitActivity', 'ForEach': 'ForEachActivity', 'IfCondition': 'IfConditionActivity', 'ExecutePipeline': 'ExecutePipelineActivity'}
'type': {'WebHook': 'WebHookActivity', 'AppendVariable': 'AppendVariableActivity', 'SetVariable': 'SetVariableActivity', 'Filter': 'FilterActivity', 'Validation': 'ValidationActivity', 'Until': 'UntilActivity', 'Wait': 'WaitActivity', 'ForEach': 'ForEachActivity', 'IfCondition': 'IfConditionActivity', 'ExecutePipeline': 'ExecutePipelineActivity'}
}

def __init__(self, *, name: str, additional_properties=None, description: str=None, depends_on=None, user_properties=None, **kwargs) -> None:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -382,6 +382,12 @@ class SalesforceSourceReadBehavior(str, Enum):
query_all = "QueryAll"


class SsisPackageLocationType(str, Enum):

ssisdb = "SSISDB"
file = "File"


class HDInsightActivityDebugInfoOption(str, Enum):

none = "None"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,8 @@ class ExecuteSSISPackageActivity(ExecutionActivity):
package.
:type property_overrides: dict[str,
~azure.mgmt.datafactory.models.SSISPropertyOverride]
:param log_location: SSIS package execution log location.
:type log_location: ~azure.mgmt.datafactory.models.SSISLogLocation
"""

_validation = {
Expand Down Expand Up @@ -102,6 +104,7 @@ class ExecuteSSISPackageActivity(ExecutionActivity):
'project_connection_managers': {'key': 'typeProperties.projectConnectionManagers', 'type': '{{SSISExecutionParameter}}'},
'package_connection_managers': {'key': 'typeProperties.packageConnectionManagers', 'type': '{{SSISExecutionParameter}}'},
'property_overrides': {'key': 'typeProperties.propertyOverrides', 'type': '{SSISPropertyOverride}'},
'log_location': {'key': 'typeProperties.logLocation', 'type': 'SSISLogLocation'},
}

def __init__(self, **kwargs):
Expand All @@ -117,4 +120,5 @@ def __init__(self, **kwargs):
self.project_connection_managers = kwargs.get('project_connection_managers', None)
self.package_connection_managers = kwargs.get('package_connection_managers', None)
self.property_overrides = kwargs.get('property_overrides', None)
self.log_location = kwargs.get('log_location', None)
self.type = 'ExecuteSSISPackage'
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,8 @@ class ExecuteSSISPackageActivity(ExecutionActivity):
package.
:type property_overrides: dict[str,
~azure.mgmt.datafactory.models.SSISPropertyOverride]
:param log_location: SSIS package execution log location.
:type log_location: ~azure.mgmt.datafactory.models.SSISLogLocation
"""

_validation = {
Expand Down Expand Up @@ -102,9 +104,10 @@ class ExecuteSSISPackageActivity(ExecutionActivity):
'project_connection_managers': {'key': 'typeProperties.projectConnectionManagers', 'type': '{{SSISExecutionParameter}}'},
'package_connection_managers': {'key': 'typeProperties.packageConnectionManagers', 'type': '{{SSISExecutionParameter}}'},
'property_overrides': {'key': 'typeProperties.propertyOverrides', 'type': '{SSISPropertyOverride}'},
'log_location': {'key': 'typeProperties.logLocation', 'type': 'SSISLogLocation'},
}

def __init__(self, *, name: str, package_location, connect_via, additional_properties=None, description: str=None, depends_on=None, user_properties=None, linked_service_name=None, policy=None, runtime=None, logging_level=None, environment_path=None, execution_credential=None, project_parameters=None, package_parameters=None, project_connection_managers=None, package_connection_managers=None, property_overrides=None, **kwargs) -> None:
def __init__(self, *, name: str, package_location, connect_via, additional_properties=None, description: str=None, depends_on=None, user_properties=None, linked_service_name=None, policy=None, runtime=None, logging_level=None, environment_path=None, execution_credential=None, project_parameters=None, package_parameters=None, project_connection_managers=None, package_connection_managers=None, property_overrides=None, log_location=None, **kwargs) -> None:
super(ExecuteSSISPackageActivity, self).__init__(additional_properties=additional_properties, name=name, description=description, depends_on=depends_on, user_properties=user_properties, linked_service_name=linked_service_name, policy=policy, **kwargs)
self.package_location = package_location
self.runtime = runtime
Expand All @@ -117,4 +120,5 @@ def __init__(self, *, name: str, package_location, connect_via, additional_prope
self.project_connection_managers = project_connection_managers
self.package_connection_managers = package_connection_managers
self.property_overrides = property_overrides
self.log_location = log_location
self.type = 'ExecuteSSISPackage'
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
# coding=utf-8
# --------------------------------------------------------------------------
# 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.
# --------------------------------------------------------------------------

from msrest.serialization import Model


class SSISAccessCredential(Model):
"""SSIS access credential.

All required parameters must be populated in order to send to Azure.

:param domain: Required. Domain for windows authentication.
:type domain: object
:param user_name: Required. UseName for windows authentication.
:type user_name: object
:param password: Required. Password for windows authentication.
:type password: ~azure.mgmt.datafactory.models.SecureString
"""

_validation = {
'domain': {'required': True},
'user_name': {'required': True},
'password': {'required': True},
}

_attribute_map = {
'domain': {'key': 'domain', 'type': 'object'},
'user_name': {'key': 'userName', 'type': 'object'},
'password': {'key': 'password', 'type': 'SecureString'},
}

def __init__(self, **kwargs):
super(SSISAccessCredential, self).__init__(**kwargs)
self.domain = kwargs.get('domain', None)
self.user_name = kwargs.get('user_name', None)
self.password = kwargs.get('password', None)
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
# coding=utf-8
# --------------------------------------------------------------------------
# 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.
# --------------------------------------------------------------------------

from msrest.serialization import Model


class SSISAccessCredential(Model):
"""SSIS access credential.

All required parameters must be populated in order to send to Azure.

:param domain: Required. Domain for windows authentication.
:type domain: object
:param user_name: Required. UseName for windows authentication.
:type user_name: object
:param password: Required. Password for windows authentication.
:type password: ~azure.mgmt.datafactory.models.SecureString
"""

_validation = {
'domain': {'required': True},
'user_name': {'required': True},
'password': {'required': True},
}

_attribute_map = {
'domain': {'key': 'domain', 'type': 'object'},
'user_name': {'key': 'userName', 'type': 'object'},
'password': {'key': 'password', 'type': 'SecureString'},
}

def __init__(self, *, domain, user_name, password, **kwargs) -> None:
super(SSISAccessCredential, self).__init__(**kwargs)
self.domain = domain
self.user_name = user_name
self.password = password
Original file line number Diff line number Diff line change
@@ -0,0 +1,50 @@
# coding=utf-8
# --------------------------------------------------------------------------
# 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.
# --------------------------------------------------------------------------

from msrest.serialization import Model


class SSISLogLocation(Model):
"""SSIS package execution log location.

Variables are only populated by the server, and will be ignored when
sending a request.

All required parameters must be populated in order to send to Azure.

:param log_path: Required. The SSIS package execution log path. Type:
string (or Expression with resultType string).
:type log_path: object
:ivar type: Required. The type of SSIS log location. Default value: "File"
.
:vartype type: str
:param access_credential: The package execution log access credential.
:type access_credential:
~azure.mgmt.datafactory.models.SSISAccessCredential
"""

_validation = {
'log_path': {'required': True},
'type': {'required': True, 'constant': True},
}

_attribute_map = {
'log_path': {'key': 'logPath', 'type': 'object'},
'type': {'key': 'type', 'type': 'str'},
'access_credential': {'key': 'typeProperties.accessCredential', 'type': 'SSISAccessCredential'},
}

type = "File"

def __init__(self, **kwargs):
super(SSISLogLocation, self).__init__(**kwargs)
self.log_path = kwargs.get('log_path', None)
self.access_credential = kwargs.get('access_credential', None)
Original file line number Diff line number Diff line change
@@ -0,0 +1,50 @@
# coding=utf-8
# --------------------------------------------------------------------------
# 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.
# --------------------------------------------------------------------------

from msrest.serialization import Model


class SSISLogLocation(Model):
"""SSIS package execution log location.

Variables are only populated by the server, and will be ignored when
sending a request.

All required parameters must be populated in order to send to Azure.

:param log_path: Required. The SSIS package execution log path. Type:
string (or Expression with resultType string).
:type log_path: object
:ivar type: Required. The type of SSIS log location. Default value: "File"
.
:vartype type: str
:param access_credential: The package execution log access credential.
:type access_credential:
~azure.mgmt.datafactory.models.SSISAccessCredential
"""

_validation = {
'log_path': {'required': True},
'type': {'required': True, 'constant': True},
}

_attribute_map = {
'log_path': {'key': 'logPath', 'type': 'object'},
'type': {'key': 'type', 'type': 'str'},
'access_credential': {'key': 'typeProperties.accessCredential', 'type': 'SSISAccessCredential'},
}

type = "File"

def __init__(self, *, log_path, access_credential=None, **kwargs) -> None:
super(SSISLogLocation, self).__init__(**kwargs)
self.log_path = log_path
self.access_credential = access_credential
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,17 @@ class SSISPackageLocation(Model):
:param package_path: Required. The SSIS package path. Type: string (or
Expression with resultType string).
:type package_path: object
:param type: The type of SSIS package location. Possible values include:
'SSISDB', 'File'
:type type: str or ~azure.mgmt.datafactory.models.SsisPackageLocationType
:param package_password: Password of the package.
:type package_password: ~azure.mgmt.datafactory.models.SecureString
:param access_credential: The package access credential.
:type access_credential:
~azure.mgmt.datafactory.models.SSISAccessCredential
:param configuration_path: The configuration file of the package
execution. Type: string (or Expression with resultType string).
:type configuration_path: object
"""

_validation = {
Expand All @@ -28,8 +39,16 @@ class SSISPackageLocation(Model):

_attribute_map = {
'package_path': {'key': 'packagePath', 'type': 'object'},
'type': {'key': 'type', 'type': 'str'},
'package_password': {'key': 'typeProperties.packagePassword', 'type': 'SecureString'},
'access_credential': {'key': 'typeProperties.accessCredential', 'type': 'SSISAccessCredential'},
'configuration_path': {'key': 'typeProperties.configurationPath', 'type': 'object'},
}

def __init__(self, **kwargs):
super(SSISPackageLocation, self).__init__(**kwargs)
self.package_path = kwargs.get('package_path', None)
self.type = kwargs.get('type', None)
self.package_password = kwargs.get('package_password', None)
self.access_credential = kwargs.get('access_credential', None)
self.configuration_path = kwargs.get('configuration_path', None)
Loading