aliyun-python-sdk-schedulerx2/aliyunsdkschedulerx2/request/v20190430/CreateJobRequest.py (162 lines of code) (raw):
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
#
# http://www.apache.org/licenses/LICENSE-2.0
#
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
from aliyunsdkcore.request import RpcRequest
from aliyunsdkschedulerx2.endpoint import endpoint_data
class CreateJobRequest(RpcRequest):
def __init__(self):
RpcRequest.__init__(self, 'schedulerx2', '2019-04-30', 'CreateJob','schedulerx2')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
if hasattr(self, "endpoint_regional"):
setattr(self, "endpoint_regional", endpoint_data.getEndpointRegional())
def get_AttemptInterval(self): # Integer
return self.get_body_params().get('AttemptInterval')
def set_AttemptInterval(self, AttemptInterval): # Integer
self.add_body_params('AttemptInterval', AttemptInterval)
def get_FailTimes(self): # Integer
return self.get_body_params().get('FailTimes')
def set_FailTimes(self, FailTimes): # Integer
self.add_body_params('FailTimes', FailTimes)
def get_ConsumerSize(self): # Integer
return self.get_body_params().get('ConsumerSize')
def set_ConsumerSize(self, ConsumerSize): # Integer
self.add_body_params('ConsumerSize', ConsumerSize)
def get_GroupId(self): # String
return self.get_body_params().get('GroupId')
def set_GroupId(self, GroupId): # String
self.add_body_params('GroupId', GroupId)
def get_DataOffset(self): # Integer
return self.get_body_params().get('DataOffset')
def set_DataOffset(self, DataOffset): # Integer
self.add_body_params('DataOffset', DataOffset)
def get_TaskMaxAttempt(self): # Integer
return self.get_body_params().get('TaskMaxAttempt')
def set_TaskMaxAttempt(self, TaskMaxAttempt): # Integer
self.add_body_params('TaskMaxAttempt', TaskMaxAttempt)
def get_DispatcherSize(self): # Integer
return self.get_body_params().get('DispatcherSize')
def set_DispatcherSize(self, DispatcherSize): # Integer
self.add_body_params('DispatcherSize', DispatcherSize)
def get_Priority(self): # Integer
return self.get_query_params().get('Priority')
def set_Priority(self, Priority): # Integer
self.add_query_param('Priority', Priority)
def get_JobType(self): # String
return self.get_body_params().get('JobType')
def set_JobType(self, JobType): # String
self.add_body_params('JobType', JobType)
def get_TaskAttemptInterval(self): # Integer
return self.get_body_params().get('TaskAttemptInterval')
def set_TaskAttemptInterval(self, TaskAttemptInterval): # Integer
self.add_body_params('TaskAttemptInterval', TaskAttemptInterval)
def get_ExecuteMode(self): # String
return self.get_body_params().get('ExecuteMode')
def set_ExecuteMode(self, ExecuteMode): # String
self.add_body_params('ExecuteMode', ExecuteMode)
def get_TimeExpression(self): # String
return self.get_body_params().get('TimeExpression')
def set_TimeExpression(self, TimeExpression): # String
self.add_body_params('TimeExpression', TimeExpression)
def get_TimeoutEnable(self): # Boolean
return self.get_body_params().get('TimeoutEnable')
def set_TimeoutEnable(self, TimeoutEnable): # Boolean
self.add_body_params('TimeoutEnable', TimeoutEnable)
def get_ContactInfos(self): # RepeatList
return self.get_body_params().get('ContactInfo')
def set_ContactInfos(self, ContactInfo): # RepeatList
for depth1 in range(len(ContactInfo)):
if ContactInfo[depth1].get('Ding') is not None:
self.add_body_params('ContactInfo.' + str(depth1 + 1) + '.Ding', ContactInfo[depth1].get('Ding'))
if ContactInfo[depth1].get('UserPhone') is not None:
self.add_body_params('ContactInfo.' + str(depth1 + 1) + '.UserPhone', ContactInfo[depth1].get('UserPhone'))
if ContactInfo[depth1].get('UserMail') is not None:
self.add_body_params('ContactInfo.' + str(depth1 + 1) + '.UserMail', ContactInfo[depth1].get('UserMail'))
if ContactInfo[depth1].get('UserName') is not None:
self.add_body_params('ContactInfo.' + str(depth1 + 1) + '.UserName', ContactInfo[depth1].get('UserName'))
def get_Name(self): # String
return self.get_body_params().get('Name')
def set_Name(self, Name): # String
self.add_body_params('Name', Name)
def get_TimeType(self): # Integer
return self.get_body_params().get('TimeType')
def set_TimeType(self, TimeType): # Integer
self.add_body_params('TimeType', TimeType)
def get_Parameters(self): # String
return self.get_body_params().get('Parameters')
def set_Parameters(self, Parameters): # String
self.add_body_params('Parameters', Parameters)
def get_Status(self): # Integer
return self.get_body_params().get('Status')
def set_Status(self, Status): # Integer
self.add_body_params('Status', Status)
def get_NamespaceSource(self): # String
return self.get_body_params().get('NamespaceSource')
def set_NamespaceSource(self, NamespaceSource): # String
self.add_body_params('NamespaceSource', NamespaceSource)
def get_Timezone(self): # String
return self.get_body_params().get('Timezone')
def set_Timezone(self, Timezone): # String
self.add_body_params('Timezone', Timezone)
def get_Description(self): # String
return self.get_body_params().get('Description')
def set_Description(self, Description): # String
self.add_body_params('Description', Description)
def get_Content(self): # String
return self.get_body_params().get('Content')
def set_Content(self, Content): # String
self.add_body_params('Content', Content)
def get_Timeout(self): # Long
return self.get_body_params().get('Timeout')
def set_Timeout(self, Timeout): # Long
self.add_body_params('Timeout', Timeout)
def get_TimeoutKillEnable(self): # Boolean
return self.get_body_params().get('TimeoutKillEnable')
def set_TimeoutKillEnable(self, TimeoutKillEnable): # Boolean
self.add_body_params('TimeoutKillEnable', TimeoutKillEnable)
def get_PageSize(self): # Integer
return self.get_body_params().get('PageSize')
def set_PageSize(self, PageSize): # Integer
self.add_body_params('PageSize', PageSize)
def get_Calendar(self): # String
return self.get_body_params().get('Calendar')
def set_Calendar(self, Calendar): # String
self.add_body_params('Calendar', Calendar)
def get_FailEnable(self): # Boolean
return self.get_body_params().get('FailEnable')
def set_FailEnable(self, FailEnable): # Boolean
self.add_body_params('FailEnable', FailEnable)
def get_SendChannel(self): # String
return self.get_body_params().get('SendChannel')
def set_SendChannel(self, SendChannel): # String
self.add_body_params('SendChannel', SendChannel)
def get_MaxAttempt(self): # Integer
return self.get_body_params().get('MaxAttempt')
def set_MaxAttempt(self, MaxAttempt): # Integer
self.add_body_params('MaxAttempt', MaxAttempt)
def get_MissWorkerEnable(self): # Boolean
return self.get_body_params().get('MissWorkerEnable')
def set_MissWorkerEnable(self, MissWorkerEnable): # Boolean
self.add_body_params('MissWorkerEnable', MissWorkerEnable)
def get_SuccessNoticeEnable(self): # Boolean
return self.get_body_params().get('SuccessNoticeEnable')
def set_SuccessNoticeEnable(self, SuccessNoticeEnable): # Boolean
self.add_body_params('SuccessNoticeEnable', SuccessNoticeEnable)
def get_QueueSize(self): # Integer
return self.get_body_params().get('QueueSize')
def set_QueueSize(self, QueueSize): # Integer
self.add_body_params('QueueSize', QueueSize)
def get_ClassName(self): # String
return self.get_body_params().get('ClassName')
def set_ClassName(self, ClassName): # String
self.add_body_params('ClassName', ClassName)
def get_Namespace(self): # String
return self.get_body_params().get('Namespace')
def set_Namespace(self, Namespace): # String
self.add_body_params('Namespace', Namespace)
def get_XAttrs(self): # String
return self.get_body_params().get('XAttrs')
def set_XAttrs(self, XAttrs): # String
self.add_body_params('XAttrs', XAttrs)
def get_MaxConcurrency(self): # Integer
return self.get_body_params().get('MaxConcurrency')
def set_MaxConcurrency(self, MaxConcurrency): # Integer
self.add_body_params('MaxConcurrency', MaxConcurrency)