閱讀923 返回首頁    go 小米MIX

創建作業__SDK接口說明_Python版SDK_批量計算-阿裏雲

create_job

參數說明：

所有類型的參數將被轉換為包含屬性信息的字典對象。

參數 類型 描述
job_desc JobDescription object, str, dict 作業的簡單描述和作業對象中各個任務的描述信息，以及各個任務之間的DAG依賴關係

返回值說明：

create_job 方法將返回一個CreateResponse對象, 以下是 CreateResponse 對象的屬性。可以通過 response.Id 的方式獲取新任務的ID。

屬性 類型 描述
Id str 新任務的任務標識符

e.g.

  1. try:
  2.     # Init a Client object.
  3.     client = ...
  5.     # Refer to JobDescription.
  6.     job_desc = JobDescription(...)
  8.     job = client.create_job(job_desc)
  9.     # Print out the job id.
  10.     print (job.Id)
  11. except ClientError, e:
  12.     print (e)

（1）JobDescription 類

參數說明：

參數 類型 描述
properties dict, str, JobDescription object 包含作業描述信息的對象

屬性說明：

序號 屬性 類型 描述
1. Name str 作業名稱
2. Description str 作業的簡短描述信息
3. Priority int 優先級用一個[0,1000]範圍內的整數指定，數值越高表示作業調度時的優先級越高
4. Notification dict 消息通知配置，可以配置MNS服務的Topic和Job相關事件
5. JobFailOnInstanceFail bool Instance失敗是否直接使Job失敗
6. AutoRelease boolean 表示job運行成功自動會被立即釋放(刪除)掉,默認為 False
7. Type str 目前僅支持有向無環圖（directed acycline graph，DAG）形式描述任務
8. DAG dict, DAG object DAG描述

（2）DAG 類

參數說明：

參數 類型 描述
properties dict, str, DAG object 所有任務的映射以及任務間依賴關係的描述信息

屬性說明：

序號 屬性 類型 描述
1. Tasks dict 所有任務名與任務描述的映射關係
2. Dependencies dict 所有任務間的相互依賴關係

方法說明 ：

序號 方法 描述
1. add_task(task_name, task) 增加一個任務
2. get_task(task_name) 通過任務名獲取任務信息
3. delete_task(task_name) 刪除某個任務

e.g.

  1. # Refer to the TaskDescription class. 
  2. find_task = TaskDescription(...) 
  4. task_dag = DAG()
  5. task_dag.add_task(task_name='Find', task=find_task)
  6. task_dag.Dependencies = {}

（3） TaskDescription 類

參數說明：

參數 類型 描述
properties dict, str, TaskDescription object 單個任務的描述信息

屬性說明：

序號 屬性 類型 描述
1. Parameters dict, Parameters object 任務參數詳情
2. InputMapping dict OSS到本地路徑的映射
3. OutputMapping dict 本地路徑到OSS的映射
4. LogMapping dict 本地日誌路徑對OSS映射
5. Timeout int 任務超時時間
6. InstanceCount int 任務中實例的個數，正數
7. MaxRetryCount int 最大重試次數，默認為0
8. ClusterId str 集群標識符
9. AutoCluster dict, AutoCluster object 匿名集群，和集群標示符最多隻能指定一個

e.g.

  1. echo_task = TaskDescription()
  3. # Create map task.
  4. # Refer to Parameters documentation.
  5. echo_task.Parameters.Command.CommandLine = "echo Batchcompute Service"
  6. echo_task.Parameters.Command.PackagePath = ""
  7. echo_task.Parameters.StdoutRedirectPath = "oss://xxx/xxx/"
  8. echo_task.Parameters.StderrRedirectPath = "oss://xxx/xxx/"
  9. echo_task.Timeout = 86400 # 1-day 
  10. echo_task.InstanceCount = 3
  11. echo_task.MaxRetryCount = 1
  13. # cluster_id is a cluster created in batchcompute service before.
  14. echo_task.ClusterId = cluster_id
  15. # You can now add this task description to a DAG object through its add_task method.

（4） Parameters 類

參數說明：

參數 類型 描述
properties dict, str, Parameters object 任務參數的描述信息

屬性說明：

序號 屬性 類型 描述
1. Command dict, Command object 用戶程序相關命令行參數
2. InputMappingConfig dict, InputMappingConfig object NFS掛載服務配置項
3. StdoutRedirectPath str 標準輸出的OSS路徑
4. StderrRedirectPath str 標準錯誤的OSS路徑

（5） AutoCluster 類

參數說明：

參數 類型 描述
properties dict, str, AutoCluster object 匿名集群信息

屬性說明：

序號 屬性 類型 描述
1. ECSImageId str ECS鏡像ID，可以使用係統提供的鏡像
2. InstanceType str 實例規格，實例類型
3. ResourceType str 資源類型，目前僅支持默認的: “OnDemand”
4. UserData dict 一個KeyValue映射，用戶自定義的信息，使用ECS的metaserver獲取
5. Configs Configs object 集群的配置信息, 詳見4.13 節中ClusterDescription的介紹

（6） Command 類

參數說明：

參數 類型 描述
properties dict, str, Command object 用戶程序相關命令行參數

屬性說明：

序號 屬性 類型 描述
1. CommandLine str 執行用戶程序的命令
2. PackagePath str 用戶程序所在OSS路徑
3. EnvVars dict 用戶程序執行時的環境變量

（7） InputMappingConfig 類

參數說明：

參數 類型 描述
properties dict, str, InputMappingConfig object NFS掛載服務配置項

屬性說明：

序號 屬性 類型 描述
1. Locale str OSS object掛載到本地時使用的字符集。可選範圍包括GBK、GB2312-80、BIG5、ANSI、EUC-JP、EUC-TW、EUC-KR、SHIFT-JIS、KSC5601等
2. Lock bool NFS掛載服務是否支持網絡文件鎖

（8） Notification 類

參數說明：

參數 類型 描述
properties dict, str, Command object 用戶程序相關命令行參數

屬性說明：

序號 屬性 類型 描述
1. Topic Topic Object 消息Topic

（9） Topic 類

參數說明：

參數 類型 描述
properties dict, str, Command object 用戶程序相關命令行參數

屬性說明：

序號 屬性 類型 描述
1. Endpoint str MNS區域endpoint，格式如: https://${your_user_id}.mns.${region}-internal.aliyuncs.com/ ，請盡量使用內網Endpoint。
2. Name str Topic名稱。
3. Events list 事件列表，請填寫cluster相關的事件名。

最後更新：2016-12-19 14:06:54

  上一篇：go Client類構造方法__SDK接口說明_Python版SDK_批量計算-阿裏雲
  下一篇：go 修改集群期望實例數__SDK接口說明_Python版SDK_批量計算-阿裏雲