Creating a Job in a Specified Cluster
Function
This API is used to create a job in a specified cluster.
URI
POST /v1.1/{project_id}/clusters/{cluster_id}/cdm/job
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
project_id |
Yes |
String |
Project ID |
cluster_id |
Yes |
String |
Cluster ID |
Request Parameters
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
X-Auth-Token |
Yes |
String |
User token. It can be obtained by calling the IAM API (value of X-Subject-Token in the response header). |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
jobs |
Yes |
Array of Job objects |
Job list. For details, see the descriptions of jobs parameters. |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
job_type |
No |
String |
Job type
Enumeration values:
|
from-connector-name |
Yes |
String |
Source link type |
to-config-values |
Yes |
ConfigValues object |
Destination link parameter configuration |
to-link-name |
Yes |
String |
Destination link name |
driver-config-values |
Yes |
ConfigValues object |
Job parameter configuration |
from-config-values |
Yes |
ConfigValues object |
Source link parameter configuration |
to-connector-name |
No |
String |
Destination link type |
name |
No |
String |
Job name, which contains 1 to 240 characters Minimum: 1 Maximum: 240 |
from-link-name |
No |
String |
Source link name |
creation-user |
No |
String |
User who created the job |
creation-date |
No |
Long |
Time when the job was created, accurate to millisecond |
update-date |
No |
Long |
Time when the job was last updated, accurate to millisecond |
is_incre_job |
No |
Boolean |
Incremental or not |
flag |
No |
Integer |
Flag |
files_read |
No |
Integer |
Number of read files |
update-user |
No |
String |
User who last updated the job |
external_id |
No |
String |
External ID |
type |
No |
String |
Task type |
execute_start_date |
No |
Long |
Execution start date |
delete_rows |
No |
Integer |
Number of deleted rows |
enabled |
No |
Boolean |
Whether to activate the link |
bytes_written |
No |
Long |
Number of written bytes |
id |
No |
Integer |
Job ID |
is_use_sql |
No |
Boolean |
Whether to use SQL statements |
update_rows |
No |
Integer |
Number of updated rows |
group_name |
No |
String |
Group name |
bytes_read |
No |
Long |
Number of read bytes |
execute_update_date |
No |
Long |
Execution update date |
write_rows |
No |
Integer |
Number of written rows |
rows_written |
No |
Integer |
Number of written rows |
rows_read |
No |
Long |
Number of rows that are read |
files_written |
No |
Integer |
Number of written files |
is_incrementing |
No |
Boolean |
Incremental or not |
execute_create_date |
No |
Long |
Execution creation date |
status |
No |
String |
Job execution status
|
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
configs |
Yes |
Array of configs objects |
The data structures of source link parameters, destination link parameters, and job parameters are the same. However, the inputs parameter varies. For details, see the descriptions of configs parameters. |
extended-configs |
No |
extended-configs object |
Extended configuration. For details, see the descriptions of extended-configs parameters. |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
name |
No |
String |
Name |
value |
No |
String |
Value |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
name |
No |
String |
Name |
value |
No |
String |
Value |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
inputs |
Yes |
Array of Input objects |
Input parameter list. Each element in the list is in name,value format. For details, see the descriptions of inputs parameters. In the from-config-values data structure, the value of this parameter varies with the source link type. For details, see section "Source Job Parameters" in the Cloud Data Migration User Guide. In the to-cofig-values data structure, the value of this parameter varies with the destination link type. For details, see section "Destination Job Parameters" in the Cloud Data Migration User Guide. For details about the inputs parameter in the driver-config-values data structure, see the job parameter descriptions. |
name |
Yes |
String |
Configuration name. The value is fromJobConfig for a source job, toJobConfig for a destination job, and linkConfig for a link. |
id |
No |
Integer |
Configuration ID |
type |
No |
String |
Configuration type |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
name |
Yes |
String |
Parameter name |
value |
Yes |
String |
Parameter value |
type |
No |
String |
Value type |
Parameter |
Mandatory |
Type |
Description |
---|---|---|---|
name |
No |
String |
Name |
value |
No |
String |
Value |
Response Parameters
Status code: 200
Parameter |
Type |
Description |
---|---|---|
name |
String |
Job name |
validation-result |
Array of JobValidationResult objects |
Check result
|
Parameter |
Type |
Description |
---|---|---|
message |
String |
Error message |
status |
String |
ERROR,WARNING Enumeration values:
|
Status code: 400
Parameter |
Type |
Description |
---|---|---|
code |
String |
Return code |
errCode |
String |
Error code |
message |
String |
Error message |
externalMessage |
String |
Additional information |
Example Requests
POST /v1.1/1551c7f6c808414d8e9f3c514a170f2e/clusters/6ec9a0a4-76be-4262-8697-e7af1fac7920/cdm/job { "jobs" : [ { "job_type" : "NORMAL_JOB", "from-connector-name" : "elasticsearch-connector", "to-config-values" : { "configs" : [ { "inputs" : [ { "name" : "toJobConfig.streamName", "value" : "dis-lkGm" }, { "name" : "toJobConfig.separator", "value" : "|" }, { "name" : "toJobConfig.columnList", "value" : "1&2&3" } ], "name" : "toJobConfig" } ] }, "to-link-name" : "dis", "driver-config-values" : { "configs" : [ { "inputs" : [ { "name" : "throttlingConfig.numExtractors", "value" : "1" }, { "name" : "throttlingConfig.submitToCluster", "value" : "false" }, { "name" : "throttlingConfig.numLoaders", "value" : "1" }, { "name" : "throttlingConfig.recordDirtyData", "value" : "false" } ], "name" : "throttlingConfig" }, { "inputs" : { }, "name" : "jarConfig" }, { "inputs" : [ { "name" : "schedulerConfig.isSchedulerJob", "value" : "false" }, { "name" : "schedulerConfig.disposableType", "value" : "NONE" } ], "name" : "schedulerConfig" }, { "inputs" : { }, "name" : "transformConfig" }, { "inputs" : [ { "name" : "retryJobConfig.retryJobType", "value" : "NONE" } ], "name" : "retryJobConfig" } ] }, "from-config-values" : { "configs" : [ { "inputs" : [ { "name" : "fromJobConfig.index", "value" : "52est" }, { "name" : "fromJobConfig.type", "value" : "est_array" }, { "name" : "fromJobConfig.columnList", "value" : "array_f1_int:long&array_f2_text:string&array_f3_object:nested" }, { "name" : "fromJobConfig.splitNestedField", "value" : "false" } ], "name" : "fromJobConfig" } ] }, "to-connector-name" : "dis-connector", "name" : "es_css", "from-link-name" : "css" } ] }
Example Responses
Status code: 200
ok
{ "name" : "mysql2hive" }
Status code: 400
Request error
{ "code" : "Cdm.0104", "errCode" : "Cdm.0104", "message" : "Job name already exist or created by other.", "ternalMessage" : "Job name already exist or created by other." }
Status Codes
Status Code |
Description |
---|---|
200 |
ok |
400 |
Request error |
Error Codes
See Error Codes.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.