emrstudio-20231009/alibabacloud_emrstudio20231009/client.py (480 lines of code) (raw):
# -*- coding: utf-8 -*-
# This file is auto-generated, don't edit it. Thanks.
from __future__ import unicode_literals
from Tea.converter import TeaConverter
from Tea.core import TeaCore
from alibabacloud_tea_openapi.client import Client as OpenApiClient
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_tea_util.client import Client as UtilClient
from alibabacloud_endpoint_util.client import Client as EndpointUtilClient
from alibabacloud_emrstudio20231009 import models as emr_studio_20231009_models
from alibabacloud_tea_util import models as util_models
from alibabacloud_openapi_util.client import Client as OpenApiUtilClient
class Client(OpenApiClient):
"""
*\
"""
def __init__(self, config):
super(Client, self).__init__(config)
self._endpoint_rule = ''
self.check_config(config)
self._endpoint = self.get_endpoint('emrstudio', self._region_id, self._endpoint_rule, self._network, self._suffix, self._endpoint_map, self._endpoint)
def get_endpoint(self, product_id, region_id, endpoint_rule, network, suffix, endpoint_map, endpoint):
if not UtilClient.empty(endpoint):
return endpoint
if not UtilClient.is_unset(endpoint_map) and not UtilClient.empty(endpoint_map.get(region_id)):
return endpoint_map.get(region_id)
return EndpointUtilClient.get_endpoint_rules(product_id, region_id, endpoint_rule, network, suffix)
def describe_manual_task_with_options(self, project_id, manual_task_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeManualTask',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/manualTasks/%s' % (TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(manual_task_id))),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeManualTaskResponse(),
self.call_api(params, req, runtime)
)
def describe_manual_task(self, project_id, manual_task_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_manual_task_with_options(project_id, manual_task_id, request, headers, runtime)
def describe_manual_task_instance_with_options(self, manual_task_instance_id, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeManualTaskInstance',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/manualTaskInstances/%s' % (TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(manual_task_instance_id))),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeManualTaskInstanceResponse(),
self.call_api(params, req, runtime)
)
def describe_manual_task_instance(self, manual_task_instance_id, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_manual_task_instance_with_options(manual_task_instance_id, project_id, request, headers, runtime)
def describe_project_with_options(self, code, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeProject',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(code)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeProjectResponse(),
self.call_api(params, req, runtime)
)
def describe_project(self, code, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_project_with_options(code, request, headers, runtime)
def describe_task_with_options(self, workflow_id, project_id, task_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeTask',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/workflows/%s/tasks/%s' % (TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(workflow_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(task_id))),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeTaskResponse(),
self.call_api(params, req, runtime)
)
def describe_task(self, workflow_id, project_id, task_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_task_with_options(workflow_id, project_id, task_id, request, headers, runtime)
def describe_task_instance_with_options(self, project_id, workflow_instance_id, task_instance_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeTaskInstance',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/workflows/%s/taskInstances/%s' % (TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(workflow_instance_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(task_instance_id))),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeTaskInstanceResponse(),
self.call_api(params, req, runtime)
)
def describe_task_instance(self, project_id, workflow_instance_id, task_instance_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_task_instance_with_options(project_id, workflow_instance_id, task_instance_id, request, headers, runtime)
def describe_workflow_with_options(self, project_id, workflow_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeWorkflow',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/processDefinitions/%s' % (TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(workflow_id))),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeWorkflowResponse(),
self.call_api(params, req, runtime)
)
def describe_workflow(self, project_id, workflow_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_workflow_with_options(project_id, workflow_id, request, headers, runtime)
def describe_workflow_instance_with_options(self, project_id, workflow_instance_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='DescribeWorkflowInstance',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/processInstances/%s' % (TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)), TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(workflow_instance_id))),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.DescribeWorkflowInstanceResponse(),
self.call_api(params, req, runtime)
)
def describe_workflow_instance(self, project_id, workflow_instance_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.describe_workflow_instance_with_options(project_id, workflow_instance_id, request, headers, runtime)
def list_manual_task_instances_with_options(self, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.end_time):
query['endTime'] = request.end_time
if not UtilClient.is_unset(request.execution_status):
query['executionStatus'] = request.execution_status
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.search_val):
query['searchVal'] = request.search_val
if not UtilClient.is_unset(request.start_time):
query['startTime'] = request.start_time
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListManualTaskInstances',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/manualTaskInstances' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListManualTaskInstancesResponse(),
self.call_api(params, req, runtime)
)
def list_manual_task_instances(self, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_manual_task_instances_with_options(project_id, request, headers, runtime)
def list_manual_tasks_with_options(self, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.search_val):
query['searchVal'] = request.search_val
if not UtilClient.is_unset(request.task_type):
query['taskType'] = request.task_type
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListManualTasks',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/manualTasks' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListManualTasksResponse(),
self.call_api(params, req, runtime)
)
def list_manual_tasks(self, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_manual_tasks_with_options(project_id, request, headers, runtime)
def list_projects_with_options(self, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.search_val):
query['searchVal'] = request.search_val
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListProjects',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects',
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListProjectsResponse(),
self.call_api(params, req, runtime)
)
def list_projects(self, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_projects_with_options(request, headers, runtime)
def list_task_instances_with_options(self, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.end_time):
query['endTime'] = request.end_time
if not UtilClient.is_unset(request.execution_status):
query['executionStatus'] = request.execution_status
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.search_val):
query['searchVal'] = request.search_val
if not UtilClient.is_unset(request.start_time):
query['startTime'] = request.start_time
if not UtilClient.is_unset(request.workflow_instance_id):
query['workflowInstanceId'] = request.workflow_instance_id
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListTaskInstances',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/taskInstances' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListTaskInstancesResponse(),
self.call_api(params, req, runtime)
)
def list_task_instances(self, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_task_instances_with_options(project_id, request, headers, runtime)
def list_tasks_with_options(self, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.search_val):
query['searchVal'] = request.search_val
if not UtilClient.is_unset(request.task_type):
query['taskType'] = request.task_type
if not UtilClient.is_unset(request.workflow_id):
query['workflowId'] = request.workflow_id
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListTasks',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/tasks' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListTasksResponse(),
self.call_api(params, req, runtime)
)
def list_tasks(self, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_tasks_with_options(project_id, request, headers, runtime)
def list_workflow_instances_with_options(self, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.end_date):
query['endDate'] = request.end_date
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.start_date):
query['startDate'] = request.start_date
if not UtilClient.is_unset(request.workflow_id):
query['workflowId'] = request.workflow_id
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListWorkflowInstances',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/processInstances' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListWorkflowInstancesResponse(),
self.call_api(params, req, runtime)
)
def list_workflow_instances(self, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_workflow_instances_with_options(project_id, request, headers, runtime)
def list_workflows_with_options(self, project_id, request, headers, runtime):
UtilClient.validate_model(request)
query = {}
if not UtilClient.is_unset(request.max_results):
query['maxResults'] = request.max_results
if not UtilClient.is_unset(request.next_token):
query['nextToken'] = request.next_token
if not UtilClient.is_unset(request.search_val):
query['searchVal'] = request.search_val
if not UtilClient.is_unset(request.workspace_id):
query['workspaceId'] = request.workspace_id
req = open_api_models.OpenApiRequest(
headers=headers,
query=OpenApiUtilClient.query(query)
)
params = open_api_models.Params(
action='ListWorkflows',
version='2023-10-09',
protocol='HTTPS',
pathname='/dolphinscheduler/v3/projects/%s/processDefinitions' % TeaConverter.to_unicode(OpenApiUtilClient.get_encode_param(project_id)),
method='GET',
auth_type='AK',
style='ROA',
req_body_type='json',
body_type='json'
)
return TeaCore.from_map(
emr_studio_20231009_models.ListWorkflowsResponse(),
self.call_api(params, req, runtime)
)
def list_workflows(self, project_id, request):
runtime = util_models.RuntimeOptions()
headers = {}
return self.list_workflows_with_options(project_id, request, headers, runtime)