updateJobExecuteConfig

印刷する
共有
PDF

記事の要約

この要約は役に立ちましたか?

ご意見ありがとうございます

ジョブ実行オプションを更新します。

PUT https://dataflow.apigw.ntruss.com/api/v1/jobs/{jobId}/executions

リクエスト

リクエストパラメータ

パラメータ名	必須の有無	タイプ	制限事項	説明
jobId	Yes	String		ジョブ ID

リクエストボディ

パラメータ名	必須の有無	タイプ	制限事項	説明
jobCondition.workerType	No	String	DEFAULT	Workerタイプ
jobCondition.numWorker	No	Number	2~10	Worker数
jobCondition.timeout	No	Number	デフォルト: 360分、最大: 1440分(24時間)	実行 Timeout
jobCondition.nrn	Yes	String		ポリシー NRN
jobCondition.scriptPath	Yes	String		実行スクリプトの保存パス
jobCondition.logPath	Yes	String		実行ログの保存パス

レスポンス

フィールド名	タイプ	説明
jobId	String	ジョブ ID
name	String	ジョブ名
description	String	ジョブの説明
type	String	ジョブタイプ
status	String	ジョブの状態
nodes[].id	Number	ノード ID
nodes[].name	String	ノード名
nodes[].type	String	ノードタイプ
nodes[].parentNodeIds	Array	上位ノード ID
runCondtion.workerType	String	Workerタイプ
runCondition.numWorker	Number	Worker数
runCondition.timeout	Number	実行タイムアウト
runCondition.nrn	String	ポリシー NRN
runCondition.scriptPath	String	実行スクリプトの保存パス
runCondition.logPath	String	実行ログの保存パス
createdDate	String	ジョブ作成日
updatedDate	String	最終アップデート

レスポンスステータス

HTTP Status	Desc
200	OK(更新完了)
400	Bad Request
401	Unauthorized
403	Forbidden
404	Not Found
500	Internal Server Error

例

リクエスト例

PUT /api/v1/jobs/5Yns7JgRt25f/executions

Host: dataflow.apigw.ntruss.com
x-ncp-iam-access-key: {Access key}
x-ncp-apigw-signature-v2: {API GW signature}
x-ncp-apigw-timestamp: {timestamp}

{
    "jobCondition": {
        "workerType": "DEFAULT",
        "numWorker": 2,
        "numRetry": 3,
        "timeout": 360,
        "parameters": {},
        "nrn": "nrn:PUB:IAM::0000:Role/000000-b123-11aa-b1b1-053256a72429",
        "scriptPath": "dataflow-172686404/scripts/",
        "logPath": "dataflow-172686404/sparkHistoryLogs/"
    }
}

レスポンス例

{
      "jobId": "5Yns7JgRt25f",
      "name": "data-flow",
      "description": "",
      "type": "DATAFLOW",
      "status": "RUNNABLE",
      "nodes": [
        {
          "type": "SOURCE_OBS",
          "id": 1697776914576,
          "name": "Object Storage",
          "parentNodeIds": [],
          "regionNo": "1",
          "bucketName": "aitems",
          "prefix": "dataflow1",
          "dataType": "CSV",
          "fieldList": [
            {
              "name": "id",
              "type": "string",
              "properties": []
            },
            {
              "name": "name",
              "type": "string",
              "properties": []
            },
            {
              "name": "description",
              "type": "string",
              "properties": []
            }
          ]
        },
        {
          "type": "TRANSFORM_FILTER",
          "id": 1697776942407,
          "name": "フィルタ",
          "parentNodeIds": [
            1697776914576
          ],
          "filterType": "AND",
          "filterConditionList": [
            {
              "name": "name",
              "operator": "EQ",
              "value": "A"
            }
          ]
        },
        {
          "type": "TARGET_OBS",
          "id": 1697776948956,
          "name": "Object Storage",
          "parentNodeIds": [
            1697776942407
          ],
          "regionNo": "1",
          "bucketName": "aitems",
          "prefix": "dataflow1",
          "dataType": "CSV",
          "updateType" : "OVERWRITE",
          "fieldList": [
            {
              "name": "id",
              "type": "string",
              "properties": []
            },
            {
              "name": "name",
              "type": "string",
              "properties": []
            },
            {
              "name": "description",
              "type": "string",
              "properties": []
            }
          ]
        }
      ],
      "runCondition": {
        "workerType": "DEFAULT",
        "numWorker": 2,
        "timeout": 360,
        "nrn": "nrn:PUB:IAM::0000:Role/000000-b123-11aa-b1b1-053256a72429",
        "scriptPath": "dataflow-****/scripts/",
        "logPath": "dataflow-****/sparkHistoryLogs/"
      },
      "createdDate": "2023-10-20T13:45:15.000",
      "updatedDate": "2023-10-20T13:46:56.000"
    }

この記事は役に立ちましたか?

What's Next

getTriggers

リクエスト
レスポンス
例