この操作は、ジョブ作成時に呼び出すことができます。

デバッグ

OpenAPI Explorer は署名値を自動的に計算します。 ご参考までに、この操作は、OpenAPI Explorer で呼び出すことを推奨します。 OpenAPI Explorer は、各種 SDK に用意されているサンプルコードを動的に生成します。

リクエストパラメーター

パラメーター タイプ 必須 説明
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

ノードインスタンスの操作に失敗したときに実行する操作です。 有効値:

  • CONTINUE: ノードのインスタンスをスキップします。
  • STOP: ワークフローインスタンスを停止します。
MaxRetry Integer いいえ 5

障害が生じた場合にノードインスタンスを実行する最大再試行回数です。

  • 有効値: 0 ~ 5 です。
Mode String いいえ YARN

ジョブの送信モードです。 有効な値: YARN と LOCAL です。

  • 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: ジョブに割り当てられた vCPU の数です。

レスポンスパラメーター

パラメーター タイプ 説明
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 エラーセンター」をご参照ください。