この操作は、ジョブ作成時に呼び出すことができます。
デバッグ
リクエストパラメーター
パラメーター | タイプ | 必須 | 例 | 説明 |
---|---|---|---|---|
Action | String | はい | CreateFlowJob |
実行する操作です。 値を CreateFlowJob に設定します。 |
Description | String | はい | This is the description of a job |
ジョブの説明です。 |
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 |
ノードインスタンスの操作に失敗したときに実行する操作です。 有効値:
|
MaxRetry | Integer | いいえ | 5 |
障害が生じた場合にノードインスタンスを実行する最大再試行回数です。
|
Mode | String | いいえ | YARN |
ジョブの送信モードです。 有効な値: 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 |
リソースのストレージパスです。 リソースは、OSS と HDFS に保存することができます。 |
RetryInterval | Long | いいえ | 200 |
ノードインスタンスを実行するための連続した再試行の間隔です。 有効な値: 0 ~ 300 です。 単位: 秒です。 |
RunConf | String | いいえ | {"priority":1,"userName":"hadoop","memory":2048,"cores":1} |
ジョブに設定されたスケジュールパラメーターです。
|
レスポンスパラメーター
パラメーター | タイプ | 例 | 説明 |
---|---|---|---|
Id | String | FJ-A23BD131A862F184 |
ジョブの ID です。 |
RequestId | String | 1549175a-6d14-4c8a-89f9-5e28300f6d7e |
リクエストの ID です。 |
例
リクエストの例
http(s)://[Endpoint]/? Action=CreateFlowJob
&Description=This is the description of a job
&Name=my_shell_job
&ProjectId=FP-257A173659F59685
&RegionId=cn-hangzhou
&ResourceList.1.Path=oss://path/demo.jar
&Type=SHELL
&<Common request parameters>
成功レスポンス例
XML
フォーマット
<CreateFlowJobResponse>
<RequestId>2670BCFB-925D-4C3E-9994-8D12F7A9F538</RequestId>
<Id>FJ-BBCAE48B90CC****</Id>
</CreateFlowJobResponse>
JSON
フォーマット
{
"RequestId":"2670BCFB-925D-4C3E-9994-8D12F7A9F538",
"Id":"FJ-BBCAE48B90CC****"
}
エラーコード
エラーコード一覧については「API エラーセンター」をご参照ください。