ALIYUN::SchedulerX::Job类型用于创建任务。
语法
{
"Type": "ALIYUN::SchedulerX::Job",
"Properties": {
"ExecuteMode": String,
"GroupId": String,
"JobType": String,
"Name": String,
"Namespace": String,
"TimeType": Integer,
"AttemptInterval": Integer,
"ClassName": String,
"ContactInfo": List,
"ConsumerSize": Integer,
"Calendar": String,
"Content": String,
"Description": String,
"DispatcherSize": Integer,
"DataOffset": Integer,
"FailEnable": Boolean,
"FailTimes": Integer,
"MissWorkerEnable": Boolean,
"MaxAttempt": Integer,
"MaxConcurrency": Integer,
"NamespaceSource": String,
"PageSize": Integer,
"Parameters": String,
"Priority": Integer,
"QueueSize": Integer,
"SuccessNoticeEnable": Boolean,
"SendChannel": String,
"Timezone": String,
"TimeExpression": String,
"TaskMaxAttempt": Integer,
"Timeout": Integer,
"TimeoutKillEnable": Boolean,
"TaskAttemptInterval": Integer,
"TimeoutEnable": Boolean,
"XAttrs": Map
}
}
属性
|
属性名称 |
类型 |
必须 |
允许更新 |
描述 |
约束 |
|
ExecuteMode |
String |
是 |
是 |
任务的执行模式。 |
取值:
|
|
GroupId |
String |
是 |
否 |
任务的组ID。 |
无 |
|
JobType |
String |
是 |
否 |
任务的类型。 |
取值:
|
|
Name |
String |
是 |
是 |
任务的名称。 |
无 |
|
Namespace |
String |
是 |
否 |
任务的命名空间。 |
无 |
|
TimeType |
Integer |
是 |
是 |
任务的时间类型。 |
取值:
|
|
AttemptInterval |
Integer |
否 |
是 |
任务的重试间隔。 |
无 |
|
Calendar |
String |
否 |
是 |
任务的日历。 |
无 |
|
ClassName |
String |
否 |
是 |
任务的类名。 |
无 |
|
ConsumerSize |
Integer |
否 |
是 |
任务的消费者数量。 |
无 |
|
ContactInfo |
List |
否 |
是 |
任务的联系人信息。 |
长度最大值为10。更多信息,请参考ContactInfo属性。 |
|
Content |
String |
否 |
是 |
任务的内容。 |
无 |
|
DataOffset |
Integer |
否 |
是 |
任务的数据偏移量。 |
无 |
|
Description |
String |
否 |
是 |
任务的描述。 |
无 |
|
DispatcherSize |
Integer |
否 |
是 |
任务的调度器数量。 |
无 |
|
FailEnable |
Boolean |
否 |
是 |
任务是否启用失败重试。 |
无 |
|
FailTimes |
Integer |
否 |
是 |
任务的失败次数。 |
无 |
|
MaxAttempt |
Integer |
否 |
是 |
任务的最大重试次数。 |
无 |
|
MaxConcurrency |
Integer |
否 |
是 |
任务的最大并发数。 |
取值范围:1到200。 |
|
MissWorkerEnable |
Boolean |
否 |
是 |
任务是否启用缺失worker。 |
无 |
|
NamespaceSource |
String |
否 |
否 |
任务的命名空间来源。 |
无 |
|
PageSize |
Integer |
否 |
是 |
并行网格任务的高级配置。 |
一次拉取子任务的默认数量为100。 |
|
Parameters |
String |
否 |
是 |
任务的参数。 |
无 |
|
Priority |
Integer |
否 |
是 |
任务的优先级。 |
取值:
|
|
QueueSize |
Integer |
否 |
是 |
任务的队列大小。 |
无 |
|
SendChannel |
String |
否 |
是 |
任务的发送通道。 |
无 |
|
SuccessNoticeEnable |
Boolean |
否 |
是 |
任务是否启用成功通知。 |
无 |
|
TaskAttemptInterval |
Integer |
否 |
是 |
任务子任务的重试间隔。 |
无 |
|
TaskMaxAttempt |
Integer |
否 |
是 |
任务子任务的最大重试次数。 |
无 |
|
TimeExpression |
String |
否 |
是 |
任务的时间表达式。 |
无 |
|
Timeout |
Integer |
否 |
是 |
任务的超时时间。 |
无 |
|
TimeoutEnable |
Boolean |
否 |
是 |
任务是否启用超时。 |
无 |
|
TimeoutKillEnable |
Boolean |
否 |
是 |
任务是否启用超时终止。 |
无 |
|
Timezone |
String |
否 |
是 |
任务的时区。 |
无 |
|
XAttrs |
Map |
否 |
是 |
任务的扩展属性。 |
无 |
ContactInfo语法
"ContactInfo": [
{
"UserName": String,
"UserPhone": String,
"UserMail": String,
"Ding": String
}
]
ContactInfo属性
|
属性名称 |
类型 |
必须 |
允许更新 |
描述 |
约束 |
|
Ding |
String |
否 |
是 |
联系人信息中的钉钉。 |
无 |
|
UserMail |
String |
否 |
是 |
联系人信息中的用户邮箱。 |
无 |
|
UserName |
String |
否 |
是 |
联系人信息中的用户名。 |
无 |
|
UserPhone |
String |
否 |
是 |
联系人信息中的用户电话。 |
无 |
返回值
Fn::GetAtt
JobId:任务的ID。
示例
ROSTemplateFormatVersion: '2015-09-01'
Parameters:
Namespace:
Type: String
Description:
en: The namespace of the job.
Required: true
NamespaceSource:
Type: String
Description:
en: The namespace source of the job.
Default: Null
Required: false
GroupId:
Type: String
Description:
en: The group ID of the job.
Required: true
JobType:
Type: String
Description:
en: The type of the job.
AllowedValues:
- python
- xxljob
- java
- shell
- golang
- go
- http
- dataworks
Required: true
Name:
Type: String
Description:
en: The name of the job.
Required: true
Description:
Type: String
Description:
en: The description of the job.
AssociationProperty: TextArea
Default: Null
Required: false
ExecuteMode:
Type: String
Description:
en: The execute mode of the job.
AllowedValues:
- standalone
- broadcast
- parallel
- batch
- sharding
Required: true
ClassName:
Type: String
Description:
en: The class name of the job.
Default: Null
Required: false
Content:
Type: String
Description:
en: The content of the job.
Default: Null
Required: false
Parameters:
Type: String
Description:
en: The parameters of the job.
Default: Null
Required: false
MaxConcurrency:
Type: Number
Description:
en: The max concurrency of the job.
MinValue: 1
MaxValue: 200
Default: Null
Required: false
MaxAttempt:
Type: Number
Description:
en: The max attempt of the job.
Default: Null
Required: false
AttemptInterval:
Type: Number
Description:
en: The attempt interval of the job.
Default: Null
Required: false
PageSize:
Type: Number
Description:
en: Advanced configuration for parallel grid tasks, the default number of sub-tasks pulled at a time is 100.
Default: Null
Required: false
ConsumerSize:
Type: Number
Description:
en: The consumer size of the job.
Default: Null
Required: false
QueueSize:
Type: Number
Description:
en: The queue size of the job.
Default: Null
Required: false
DispatcherSize:
Type: Number
Description:
en: The dispatcher size of the job.
Default: Null
Required: false
TimeType:
Type: Number
Description:
en: |-
The time type of the job.
cron:1
fixed_rate:3
second_delay:4
one_time :5
api:100
none:-1
AllowedValues:
- 1
- 3
- 4
- 5
- 100
- -1
Required: true
TimeExpression:
Type: String
Description:
en: The time expression of the job.
Default: Null
Required: false
Calendar:
Type: String
Description:
en: The calendar of the job.
Default: Null
Required: false
DataOffset:
Type: Number
Description:
en: The data offset of the job.
Default: Null
Required: false
Timezone:
Type: String
Description:
en: The timezone of the job.
Default: Null
Required: false
TimeoutEnable:
Type: Boolean
Description:
en: Whether timeout is enabled for the job.
Default: Null
Required: false
Timeout:
Type: Number
Description:
en: The timeout of the job.
Default: Null
Required: false
TimeoutKillEnable:
Type: Boolean
Description:
en: Whether timeout kill is enabled for the job.
Default: Null
Required: false
FailEnable:
Type: Boolean
Description:
en: Whether fail is enabled for the job.
Default: Null
Required: false
FailTimes:
Type: Number
Description:
en: The fail times of the job.
Default: Null
Required: false
MissWorkerEnable:
Type: Boolean
Description:
en: Whether miss worker is enabled for the job.
Default: Null
Required: false
SuccessNoticeEnable:
Type: Boolean
Description:
en: Whether success notice is enabled for the job.
Default: Null
Required: false
SendChannel:
Type: String
Description:
en: The send channel of the job.
Default: Null
Required: false
TaskMaxAttempt:
Type: Number
Description:
en: The task max attempt of the job.
Default: Null
Required: false
TaskAttemptInterval:
Type: Number
Description:
en: The task attempt interval of the job.
Default: Null
Required: false
ContactInfo:
Description:
en: The contact info of the job.
Required: false
Default: Null
Type: Json
MaxLength: 10
AssociationProperty: List[Parameters]
AssociationPropertyMetadata:
Parameters:
UserPhone:
Type: String
Description:
en: The user phone in contact info.
Default: Null
Required: false
UserName:
Type: String
Description:
en: The user name in contact info.
Default: Null
Required: false
UserMail:
Type: String
Description:
en: The user mail in contact info.
Default: Null
Required: false
Ding:
Type: String
Description:
en: The ding in contact info.
Default: Null
Required: false
XAttrs:
Description:
en: The extended attributes of the job.
Required: false
Default: Null
Type: Json
Priority:
Type: Number
Description:
en: The priority of the job.
AllowedValues:
- 1
- 5
- 10
- 15
Default: Null
Required: false
Resources:
Job:
Type: ALIYUN::SchedulerX::Job
Properties:
Namespace:
Ref: Namespace
NamespaceSource:
Ref: NamespaceSource
GroupId:
Ref: GroupId
JobType:
Ref: JobType
Name:
Ref: Name
Description:
Ref: Description
ExecuteMode:
Ref: ExecuteMode
ClassName:
Ref: ClassName
Content:
Ref: Content
Parameters:
Ref: Parameters
MaxConcurrency:
Ref: MaxConcurrency
MaxAttempt:
Ref: MaxAttempt
AttemptInterval:
Ref: AttemptInterval
PageSize:
Ref: PageSize
ConsumerSize:
Ref: ConsumerSize
QueueSize:
Ref: QueueSize
DispatcherSize:
Ref: DispatcherSize
TimeType:
Ref: TimeType
TimeExpression:
Ref: TimeExpression
Calendar:
Ref: Calendar
DataOffset:
Ref: DataOffset
Timezone:
Ref: Timezone
TimeoutEnable:
Ref: TimeoutEnable
Timeout:
Ref: Timeout
TimeoutKillEnable:
Ref: TimeoutKillEnable
FailEnable:
Ref: FailEnable
FailTimes:
Ref: FailTimes
MissWorkerEnable:
Ref: MissWorkerEnable
SuccessNoticeEnable:
Ref: SuccessNoticeEnable
SendChannel:
Ref: SendChannel
TaskMaxAttempt:
Ref: TaskMaxAttempt
TaskAttemptInterval:
Ref: TaskAttemptInterval
ContactInfo:
Ref: ContactInfo
XAttrs:
Ref: XAttrs
Priority:
Ref: Priority
Outputs:
JobId:
Value:
Fn::GetAtt:
- Job
- JobId
Description: The ID of the job.
{
"ROSTemplateFormatVersion": "2015-09-01",
"Parameters": {
"Namespace": {
"Type": "String",
"Description": {
"en": "The namespace of the job."
},
"Required": true
},
"NamespaceSource": {
"Type": "String",
"Description": {
"en": "The namespace source of the job."
},
"Default": null,
"Required": false
},
"GroupId": {
"Type": "String",
"Description": {
"en": "The group ID of the job."
},
"Required": true
},
"JobType": {
"Type": "String",
"Description": {
"en": "The type of the job."
},
"AllowedValues": [
"python",
"xxljob",
"java",
"shell",
"golang",
"go",
"http",
"dataworks"
],
"Required": true
},
"Name": {
"Type": "String",
"Description": {
"en": "The name of the job."
},
"Required": true
},
"Description": {
"Type": "String",
"Description": {
"en": "The description of the job."
},
"AssociationProperty": "TextArea",
"Default": null,
"Required": false
},
"ExecuteMode": {
"Type": "String",
"Description": {
"en": "The execute mode of the job."
},
"AllowedValues": [
"standalone",
"broadcast",
"parallel",
"batch",
"sharding"
],
"Required": true
},
"ClassName": {
"Type": "String",
"Description": {
"en": "The class name of the job."
},
"Default": null,
"Required": false
},
"Content": {
"Type": "String",
"Description": {
"en": "The content of the job."
},
"Default": null,
"Required": false
},
"Parameters": {
"Type": "String",
"Description": {
"en": "The parameters of the job."
},
"Default": null,
"Required": false
},
"MaxConcurrency": {
"Type": "Number",
"Description": {
"en": "The max concurrency of the job."
},
"MinValue": 1,
"MaxValue": 200,
"Default": null,
"Required": false
},
"MaxAttempt": {
"Type": "Number",
"Description": {
"en": "The max attempt of the job."
},
"Default": null,
"Required": false
},
"AttemptInterval": {
"Type": "Number",
"Description": {
"en": "The attempt interval of the job."
},
"Default": null,
"Required": false
},
"PageSize": {
"Type": "Number",
"Description": {
"en": "Advanced configuration for parallel grid tasks, the default number of sub-tasks pulled at a time is 100."
},
"Default": null,
"Required": false
},
"ConsumerSize": {
"Type": "Number",
"Description": {
"en": "The consumer size of the job."
},
"Default": null,
"Required": false
},
"QueueSize": {
"Type": "Number",
"Description": {
"en": "The queue size of the job."
},
"Default": null,
"Required": false
},
"DispatcherSize": {
"Type": "Number",
"Description": {
"en": "The dispatcher size of the job."
},
"Default": null,
"Required": false
},
"TimeType": {
"Type": "Number",
"Description": {
"en": "The time type of the job.\ncron:1\nfixed_rate:3\nsecond_delay:4\none_time :5\napi:100\nnone:-1"
},
"AllowedValues": [
1,
3,
4,
5,
100,
-1
],
"Required": true
},
"TimeExpression": {
"Type": "String",
"Description": {
"en": "The time expression of the job."
},
"Default": null,
"Required": false
},
"Calendar": {
"Type": "String",
"Description": {
"en": "The calendar of the job."
},
"Default": null,
"Required": false
},
"DataOffset": {
"Type": "Number",
"Description": {
"en": "The data offset of the job."
},
"Default": null,
"Required": false
},
"Timezone": {
"Type": "String",
"Description": {
"en": "The timezone of the job."
},
"Default": null,
"Required": false
},
"TimeoutEnable": {
"Type": "Boolean",
"Description": {
"en": "Whether timeout is enabled for the job."
},
"Default": null,
"Required": false
},
"Timeout": {
"Type": "Number",
"Description": {
"en": "The timeout of the job."
},
"Default": null,
"Required": false
},
"TimeoutKillEnable": {
"Type": "Boolean",
"Description": {
"en": "Whether timeout kill is enabled for the job."
},
"Default": null,
"Required": false
},
"FailEnable": {
"Type": "Boolean",
"Description": {
"en": "Whether fail is enabled for the job."
},
"Default": null,
"Required": false
},
"FailTimes": {
"Type": "Number",
"Description": {
"en": "The fail times of the job."
},
"Default": null,
"Required": false
},
"MissWorkerEnable": {
"Type": "Boolean",
"Description": {
"en": "Whether miss worker is enabled for the job."
},
"Default": null,
"Required": false
},
"SuccessNoticeEnable": {
"Type": "Boolean",
"Description": {
"en": "Whether success notice is enabled for the job."
},
"Default": null,
"Required": false
},
"SendChannel": {
"Type": "String",
"Description": {
"en": "The send channel of the job."
},
"Default": null,
"Required": false
},
"TaskMaxAttempt": {
"Type": "Number",
"Description": {
"en": "The task max attempt of the job."
},
"Default": null,
"Required": false
},
"TaskAttemptInterval": {
"Type": "Number",
"Description": {
"en": "The task attempt interval of the job."
},
"Default": null,
"Required": false
},
"ContactInfo": {
"Description": {
"en": "The contact info of the job."
},
"Required": false,
"Default": null,
"Type": "Json",
"MaxLength": 10,
"AssociationProperty": "List[Parameters]",
"AssociationPropertyMetadata": {
"Parameters": {
"UserPhone": {
"Type": "String",
"Description": {
"en": "The user phone in contact info."
},
"Default": null,
"Required": false
},
"UserName": {
"Type": "String",
"Description": {
"en": "The user name in contact info."
},
"Default": null,
"Required": false
},
"UserMail": {
"Type": "String",
"Description": {
"en": "The user mail in contact info."
},
"Default": null,
"Required": false
},
"Ding": {
"Type": "String",
"Description": {
"en": "The ding in contact info."
},
"Default": null,
"Required": false
}
}
}
},
"XAttrs": {
"Description": {
"en": "The extended attributes of the job."
},
"Required": false,
"Default": null,
"Type": "Json"
},
"Priority": {
"Type": "Number",
"Description": {
"en": "The priority of the job."
},
"AllowedValues": [
1,
5,
10,
15
],
"Default": null,
"Required": false
}
},
"Resources": {
"Job": {
"Type": "ALIYUN::SchedulerX::Job",
"Properties": {
"Namespace": {
"Ref": "Namespace"
},
"NamespaceSource": {
"Ref": "NamespaceSource"
},
"GroupId": {
"Ref": "GroupId"
},
"JobType": {
"Ref": "JobType"
},
"Name": {
"Ref": "Name"
},
"Description": {
"Ref": "Description"
},
"ExecuteMode": {
"Ref": "ExecuteMode"
},
"ClassName": {
"Ref": "ClassName"
},
"Content": {
"Ref": "Content"
},
"Parameters": {
"Ref": "Parameters"
},
"MaxConcurrency": {
"Ref": "MaxConcurrency"
},
"MaxAttempt": {
"Ref": "MaxAttempt"
},
"AttemptInterval": {
"Ref": "AttemptInterval"
},
"PageSize": {
"Ref": "PageSize"
},
"ConsumerSize": {
"Ref": "ConsumerSize"
},
"QueueSize": {
"Ref": "QueueSize"
},
"DispatcherSize": {
"Ref": "DispatcherSize"
},
"TimeType": {
"Ref": "TimeType"
},
"TimeExpression": {
"Ref": "TimeExpression"
},
"Calendar": {
"Ref": "Calendar"
},
"DataOffset": {
"Ref": "DataOffset"
},
"Timezone": {
"Ref": "Timezone"
},
"TimeoutEnable": {
"Ref": "TimeoutEnable"
},
"Timeout": {
"Ref": "Timeout"
},
"TimeoutKillEnable": {
"Ref": "TimeoutKillEnable"
},
"FailEnable": {
"Ref": "FailEnable"
},
"FailTimes": {
"Ref": "FailTimes"
},
"MissWorkerEnable": {
"Ref": "MissWorkerEnable"
},
"SuccessNoticeEnable": {
"Ref": "SuccessNoticeEnable"
},
"SendChannel": {
"Ref": "SendChannel"
},
"TaskMaxAttempt": {
"Ref": "TaskMaxAttempt"
},
"TaskAttemptInterval": {
"Ref": "TaskAttemptInterval"
},
"ContactInfo": {
"Ref": "ContactInfo"
},
"XAttrs": {
"Ref": "XAttrs"
},
"Priority": {
"Ref": "Priority"
}
}
}
},
"Outputs": {
"JobId": {
"Value": {
"Fn::GetAtt": [
"Job",
"JobId"
]
},
"Description": "The ID of the job."
}
}
}