[ReleasePR datafactory] [Mirror] [WIP]codegen onboard df for cli

src/datafactory/HISTORY.rst

@@ -0,0 +1,8 @@
+.. :changelog:
+
+Release History
+===============
+
+0.1.0
+++++++
+* Initial release.

src/datafactory/README.rst

@@ -0,0 +1,5 @@
+Microsoft Azure CLI 'datafactory' Extension
+==========================================
+
+This package is for the 'datafactory' extension.
+i.e. 'az datafactory'

src/datafactory/azext_datafactory/__init__.py

@@ -0,0 +1,32 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+from azure.cli.core import AzCommandsLoader
+
+from azext_datafactory.generated._help import helps  # pylint: disable=unused-import
+
+
+class DataFactoryManagementClientCommandsLoader(AzCommandsLoader):
+
+    def __init__(self, cli_ctx=None):
+        from azure.cli.core.commands import CliCommandType
+        from azext_datafactory.generated._client_factory import cf_datafactory
+        datafactory_custom = CliCommandType(
+            operations_tmpl='azext_datafactory.custom#{}',
+            client_factory=cf_datafactory)
+        super(DataFactoryManagementClientCommandsLoader, self).__init__(cli_ctx=cli_ctx,
+                                                                        custom_command_type=datafactory_custom)
+
+    def load_command_table(self, args):
+        from azext_datafactory.generated.commands import load_command_table
+        load_command_table(self, args)
+        return self.command_table
+
+    def load_arguments(self, command):
+        from azext_datafactory.generated._params import load_arguments
+        load_arguments(self, command)
+
+
+COMMAND_LOADER_CLS = DataFactoryManagementClientCommandsLoader

src/datafactory/azext_datafactory/action.py

@@ -0,0 +1,13 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+# pylint: disable=wildcard-import
+# pylint: disable=unused-wildcard-import
+
+from azext_datafactory.generated.action import *  # noqa: F403
+try:
+    from azext_datafactory.manual.action import *  # noqa: F403
+except ImportError:
+    pass

src/datafactory/azext_datafactory/azext_metadata.json

@@ -0,0 +1,4 @@
+{
+    "azext.isPreview": true,
+    "azext.minCliCoreVersion": "2.0.67"
+}

src/datafactory/azext_datafactory/commands.py

@@ -0,0 +1,13 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+# pylint: disable=wildcard-import
+# pylint: disable=unused-wildcard-import
+
+from azext_datafactory.generated.commands import *  # noqa: F403
+try:
+    from azext_datafactory.manual.commands import *  # noqa: F403
+except ImportError:
+    pass

src/datafactory/azext_datafactory/custom.py

@@ -0,0 +1,13 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+# pylint: disable=wildcard-import
+# pylint: disable=unused-wildcard-import
+
+from azext_datafactory.generated.custom import *  # noqa: F403
+try:
+    from azext_datafactory.manual.custom import *  # noqa: F403
+except ImportError:
+    pass

src/datafactory/azext_datafactory/generated/_client_factory.py

@@ -0,0 +1,70 @@
+# --------------------------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------------------------
+
+
+def cf_datafactory(cli_ctx, *_):
+    from azure.cli.core.commands.client_factory import get_mgmt_service_client
+    from ..vendored_sdks.datafactory import DataFactoryManagementClient
+    return get_mgmt_service_client(cli_ctx, DataFactoryManagementClient)
+
+
+def cf_operation(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).operation
+
+
+def cf_factory(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).factory
+
+
+def cf_exposure_control(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).exposure_control
+
+
+def cf_integration_runtime(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).integration_runtime
+
+
+def cf_integration_runtime_object_metadata(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).integration_runtime_object_metadata
+
+
+def cf_integration_runtime_node(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).integration_runtime_node
+
+
+def cf_linked_service(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).linked_service
+
+
+def cf_dataset(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).dataset
+
+
+def cf_pipeline(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).pipeline
+
+
+def cf_pipeline_run(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).pipeline_run
+
+
+def cf_activity_run(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).activity_run
+
+
+def cf_trigger(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).trigger
+
+
+def cf_trigger_run(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).trigger_run
+
+
+def cf_data_flow(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).data_flow
+
+
+def cf_data_flow_debug_session(cli_ctx, *_):
+    return cf_datafactory(cli_ctx).data_flow_debug_session