パラメーターの説明
すべてのパラメータークラスは、属性情報を含む辞書オブジェクトに変換されます。
パラメーター | タイプ | 説明 |
job_desc | JobDescription オブジェクト、str、dict | ジョブの簡単な説明、ジョブオブジェクトの各タスクの説明、およびタスク間の DAG 依存関係 |
レスポンスの説明
create_job メソッドは、CreateResponse オブジェクトを返します。以下に、CreateResponse オブジェクトの属性を示します。response.Id を使用して、新しいジョブの ID を取得できます。
属性 | タイプ | 説明 |
Id | str | 新しいジョブの ID |
例:
try:
// Client オブジェクトを初期化します。
client = ...
// JobDescription を参照します。
job_desc = JobDescription(...)
job = client.create_job(job_desc)
// ジョブ ID を出力します。
print (job.Id)
except ClientError, e:
print (e)JobDescription クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、JobDescription オブジェクト | ジョブの説明を含むオブジェクト |
属性の説明
属性 | タイプ | 説明 |
Name | str | ジョブ名 |
Description | str | ジョブの簡単な説明 |
Priority | int | 値は 0 から 1000 までの整数です。値が大きいほど優先度が高くなります。 |
Notification | dict | 通知設定。MNS のトピックまたはジョブ関連イベントを設定できます。 |
JobFailOnInstanceFail | bool | インスタンスの障害が関連ジョブの障害を引き起こすかどうかを指定します。 |
AutoRelease | boolean | ジョブの正常な実行後に、システムがジョブを自動的に解放（削除）するかどうかを指定します。デフォルト値: False |
Type | str | 現在、タスクは有向非巡回グラフ (DAG) の形式でのみ記述できます。 |
DAG | dict、DAG オブジェクト | DAG の説明 |
2. DAG クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、DAG オブジェクト | すべてのタスクのマッピングとタスク間の依存関係の説明 |
属性の説明
属性 | タイプ | 説明 |
Tasks | dict | すべてのタスク名とタスクの説明のマッピング |
Dependencies | dict | すべてのタスク間の依存関係 |
メソッドの説明
メソッド | 説明 |
add_task(task_name, task) | タスクを追加します。 |
get_task(task_name) | タスク名に基づいて、タスクに関する情報を取得します。 |
delete_task(task_name) | タスクを削除します。 |
例:
// TaskDescription クラスを参照します。
find_task = TaskDescription(...)
task_dag = DAG()
task_dag.add_task(task_name='Find', task=find_task)
task_dag.Dependencies = {}3. TaskDescription クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、TaskDescription オブジェクト | 単一タスクの説明 |
属性の説明
属性 | タイプ | 説明 |
Parameters | dict、Parameters オブジェクト | タスクパラメーターの詳細 |
InputMapping | dict | OSS ディレクトリからローカルディレクトリへのマッピング |
OutputMapping | dict | ローカルディレクトリから OSS ディレクトリへのマッピング |
LogMapping | dict | ローカルログディレクトリから OSS ディレクトリへのマッピング |
Timeout | int | タスクタイムアウト |
InstanceCount | int | タスク内のインスタンス数。正の整数です。 |
MaxRetryCount | int | 最大再試行回数。デフォルト値: 0 |
ClusterId | str | クラスター ID |
Mounts | dict、Mounts オブジェクト | インスタンスのネットワークマウント設定。Mounts によって記述されます。現在、NAS マウントと OSS マウントがサポートされています。 |
AutoCluster | dict、AutoCluster オブジェクト | autoCluster と clusterId のいずれか 1 つのみを選択できます。 |
例:
echo_task = TaskDescription()
// マップタスクを作成します。
// パラメーターのドキュメントを参照してください。
echo_task.Parameters.Command.CommandLine = "echo Batchcompute Service"
echo_task.Parameters.Command.PackagePath = ""
echo_task.Parameters.StdoutRedirectPath = "oss://xxx/xxx/"
echo_task.Parameters.StderrRedirectPath = "oss://xxx/xxx/"
echo_task.Timeout = 86400 // 1 日
echo_task.InstanceCount = 3
echo_task.MaxRetryCount = 1
// cluster_id は、以前に BatchCompute サービスで作成されたクラスターです。
echo_task.ClusterId = cluster_id
// このタスクの説明を、add_task メソッドを使用して DAG オブジェクトに追加できるようになりました。4. Parameters クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Parameters オブジェクト | タスクパラメーターの説明 |
属性の説明
属性 | タイプ | 説明 |
Command | dict、Command オブジェクト | ユーザー プログラムに関連するコマンドライン パラメーター |
InputMappingConfig | dict、InputMappingConfig オブジェクト | NFS マウントサービスの構成 |
StdoutRedirectPath | str | 標準出力がリダイレクトされる OSS ディレクトリ |
StderrRedirectPath | str | 標準エラーがリダイレクトされる OSS ディレクトリ |
5. AutoCluster クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、AutoCluster オブジェクト | AutoCluster 情報 |
属性の説明
属性 | タイプ | 説明 |
ECSImageId | str | ECS イメージ ID。システムが提供するイメージを使用できます。 |
InstanceType | str | インスタンスタイプ |
ResourceType | str | リソースタイプ。現在、OnDemand タイプと Spot タイプがサポートされています。デフォルト値: OnDemand |
UserData | dict | ユーザーが定義し、ECS インスタンスのメタサーバーを使用して取得するキーと値のマッピング |
Configs | Configs オブジェクト | クラスター構成。詳細については、セクション 4.13 の ClusterDescription の説明を参照してください。 |
SpotStrategy | str | インスタンスのスポット戦略。ResourceType が Spot の場合にのみ有効になります。値: SpotWithPriceLimit (スポットインスタンスの最大価格を設定) および SpotAsPriceGo (システムが価格を自動的に提供し、最大値は従量課金制価格)。 |
SpotPriceLimit | float | インスタンスの 1 時間あたりの最大価格 (コア時間あたりの価格ではなく、各インスタンスタイプの価格)。値には最大 3 つの小数を含めることができます。SpotStrategy が SpotWithPriceLimit の場合に有効になります。 |
ReserveOnFail | bool | タスクが失敗した場合、関連する VM は解放されず、ユーザーがジョブを削除するまで、これらのリソースの料金が引き続き課金されます。デフォルト値は False です。調査でのみ使用されます。 |
6. Command クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、InputMappingConfig オブジェクト | NFS マウントサービスの構成 |
属性の説明
属性 | タイプ | 説明 |
CommandLine | str | ユーザー プログラムを実行するためのコマンドを指定します。 |
PackagePath | str | ユーザー プログラムが存在する OSS ディレクトリ |
EnvVars | dict | ユーザー プログラムを実行するための環境変数 |
7. InputMappingConfig クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、InputMappingConfig オブジェクト | NFS マウントサービスの構成 |
属性の説明
属性 | タイプ | 説明 |
Locale | str | OSS オブジェクトがローカルサーバーにマウントされるときに使用される文字セット。オプションの値には、GBK、GB2312-80、BIG5、ANSI、EUC-JP、EUC-TW、EUC-KR、SHIFT-JIS、および KSC5601 が含まれます。 |
Lock | bool | NFS マウントサービスがネットワークファイルロックをサポートするかどうかを指定します。 |
8. Notification クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Command オブジェクト | ユーザー プログラムに関連するコマンドライン パラメーター |
属性の説明
属性 | タイプ | 説明 |
Topic | Topic オブジェクト | メッセー ジトピック |
9. Topic クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Command オブジェクト | ユーザー プログラムに関連するコマンドライン パラメーター |
属性の説明
属性 | タイプ | 説明 |
Endpoint | str | MNS リージョンのエンドポイント。形式は http://${your_user_id}.mns.${region}-internal.aliyuncs.com/ です。可能な限りイントラネットエンドポイントを使用してください。 |
Name | str | トピック名 |
Events | list | イベントのリスト。クラスター関連のイベントを入力してください。 |
10. Mounts クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Command オブジェクト | クラスターが作成されるときのネットワークディスクマウント構成 |
属性の説明
属性 | タイプ | 説明 |
Entries | array | ネットワークディスクマウントポイントのリスト。MountPoint によって記述されます。 |
Locale | str | OSS または NAS ストレージがマウントされるときに使用される言語 |
Lock | bool | OSS または NAS ストレージがマウントされるときにファイルロックがサポートされるかどうかを指定します。 |
NAS | dict | NAS 構成 |
OSS | dict | OSS 構成 |
11. MountPoint クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Command オブジェクト | ネットワークマウントポイント |
属性の説明
属性 | タイプ | 説明 |
Source | str | ネットワークディスクマウントのソースディレクトリ。「nas://」または「oss://」で始まる文字列を指定できます。 |
Destination | str | ネットワークディスクのローカルマウントポイントディレクトリ |
WriteSupport | bool | マウントポイントが書き込み可能かどうかを指定します。 |
12. NAS クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Command オブジェクト | NAS 構成 |
属性の説明
属性 | タイプ | 説明 |
AccessGroup | list | クラスターインスタンスを追加する必要がある NAS アクセスグループ |
FileSystem | list | アクセスするファイルシステム |
13. OSS クラス
パラメーターの説明
パラメーター | タイプ | 説明 |
properties | dict、str、Command オブジェクト | OSS 構成 |
属性の説明
属性 | タイプ | 説明 |
AccessKeyId | str | OSS マウントに使用する AccessKey ID |
AccessKeySecret | str | OSS マウントに使用する AccessKeySecret |
SecurityToken | str | OSS マウントに使用するセキュリティトークン |
注: Mounts については、次の点に注意してください。ジョブレベルの Mounts 構成は、クラスターレベルの Mounts 構成を上書きします。クラスターを変更した後、RecreateInstance インターフェースを呼び出して、新しい Mounts 構成を有効にする必要があります。NAS マウント中に、ソースディレクトリは「nas:」で始まる必要があります。そうでない場合、エラーが発生します。