调用 CreateFlowJob 接口创建数据开发作业

调试

您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。

请求参数

名称 类型 是否必选 示例值 描述
Action String CreateFlowJob

系统规定参数。取值:CreateFlowJob。

Description String 这是一个数据开发作业描述

作业的描述。

Name String my_shell_job

作业的名称。

ProjectId String FP-257A173659F59685

项目ID。

RegionId String cn-hangzhou

地域ID。

Type String SHELL

作业类型,目前支持:MR、SPARK、HIVE_SQL、HIVE、PIG、SQOOP、SPARK_SQL、SPARK_STREAMING、SHELL。

Adhoc Boolean false

是否临时查询。

ClusterId String C-A23BD131A862F184

集群ID。

EnvConf String {"key":"value"}

环境变量设置。

FailAct String CONTINUE

失败策略,支持:

  • CONTINUE(跳过)。
  • STOP(停止工作流)。
MaxRetry Integer 5

最大重试次数,0

  • 5。
Mode String YARN

模型模式,支持:YARN、LOCAL。

  • YARN: 将作业包装成一个launcher提交至YARN中执行。
  • LOCAL: 作业直接在机器上以进程方式运行。
MonitorConf String {"inputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic","consumer.group":"kafka_consumer_group"}],"outputs":[{"type":"KAFKA","clusterId":"C-1234567","topics":"kafka_topic"}]}

监控配置,只有SPARK_STREAMING类型作业支持。

ParamConf String {"date":"${yyyy-MM-dd}"}

参数设置。

Params String ls -l

作业内容。

ParentCategory String FC-5BD9575E34623940

父目录ID。

ResourceList.N.Alias String demo.jar

资源的别名。

ResourceList.N.Path String oss://path/demo.jar

资源的路径, 支持OSSHDFS

RetryInterval Long 200

重试间隔 0-300(秒)。

RunConf String {"priority":1,"userName":"hadoop","memory":2048,"cores":1}

运行配置 :

  • priority: 优先级。
  • userName: 任务linux提交用户。
  • memory: 内存,单位为MB。
  • cores:核数。

返回数据

名称 类型 示例值 描述
Id String FJ-A23BD131A862F184

作业 ID

RequestId String 1549175a-6d14-4c8a-89f9-5e28300f6d7e

请求 ID

示例

请求示例


http(s)://[Endpoint]/?Action=CreateFlowJob
&Description=这是一个数据开发作业描述
&Name=my_shell_job
&ProjectId=FP-257A173659F59685
&RegionId=cn-hangzhou
&ResourceList.1.Path=oss://path/demo.jar
&Type=SHELL
&<公共请求参数>

正常返回示例

XML 格式

<CreateFlowJobResponse>
	  <RequestId>2670BCFB-925D-4C3E-9994-8D12F7A9F538</RequestId>
	  <Id>FJ-BBCAE48B90CC****</Id>
</CreateFlowJobResponse>

JSON 格式

{
	"RequestId":"2670BCFB-925D-4C3E-9994-8D12F7A9F538",
	"Id":"FJ-BBCAE48B90CC****"
}

错误码

访问错误中心查看更多错误码。