ラッパ，スクリプト

サンプルのプラグ@ @ンスクリプトでは“ラッパ”スクリプトを使用してindependentSubmitFcn.mとcommunicatingSubmitFcn.mの実装を簡略化しています。これらのスクリプトは必須ではありませんが，コ，ドを読みやすくするためにこれらの使用を推奨します。この表ではこれらのスクリプトを説明します。

independentSubmitFcn

独立ジョブを汎用クラスタ，に投入すると，関数independentSubmitFcn.mがmatlabクラescアントセッションで実行されます。

この関数の宣言行は次のとおりでなければなりません。

函数independentSubmitFcn(集群、工作environmentProperties)

Matlabの独立ジョブの各タスクはスケジュラの1のジョブに対応します。この関数の目的はN個のジョブをサ，ドパ，ティ製スケジュ，ラに投入することです。ここで，Nは独立ジョブ内のタスクの数です。これらの各ジョブは次を満たさなければなりません:

ワカ環境の構成-この表に,個々のタスクを実行するために,ワーカーのMATLABに設定しなければならない5つの環境変数と値を示します。

多くのスケジュラは投入コマンドの一部としてクラアント環境をコピすることをサポトしています。サポトしている場合、クライアントに以前の環境変数を設定できるため、スケジューラは設定をワーカー環境にコピーできます。サポートしていない場合は、これらの変数を転送するように投入コマンドを変更しなければなりません。

スケジュ，ラジョブを投入してMATLABワカを実行-ジョブおよびタスクに必須の5つのパラメーターがワーカー上で定義されると,適切な引数を指定してMATLAB実行可能ファイルを呼び出すことにより,タスクが実行されます。呼び出すmatlab実行可能ファescルはenvironmentProperties。MatlabExecutableに定義されます。渡す引数はenvironmentProperties。MatlabArgumentsに定義されます。

Slurmスケジュラ用サンプルスクリプト-このスクリプトは,共有ファイルシステムをもつ粘ス很多ケジューラ用の基本的な投入関数を示します。より詳細な例にいては，サンプルのプラグ@ @ンスクリプトを参照してください。

函数independentSubmitFcn(集群、工作environmentProperties)%指定所需的环境变量。setenv (“PARALLEL_SERVER_DECODE_FUNCTION”，“parallel.cluster.generic.independentDecodeFcn”）;setenv (“PARALLEL_SERVER_STORAGE_CONSTRUCTOR”, environmentProperties.StorageConstructor);setenv (“PARALLEL_SERVER_STORAGE_LOCATION”, environmentProperties.StorageLocation);setenv (“PARALLEL_SERVER_JOB_LOCATION”, environmentProperties.JobLocation);指定要在工作线程上运行的MATLAB可执行文件和参数。这些在independentJobWrapper.sh脚本中使用。setenv (“PARALLEL_SERVER_MATLAB_EXE”, environmentProperties.MatlabExecutable);setenv (“PARALLEL_SERVER_MATLAB_ARGS”, environmentProperties.MatlabArguments);为ii = 1:environmentProperties。NumberOfTasks指定识别要运行的任务所需的环境变量。setenv (“PARALLEL_SERVER_TASK_LOCATION”, environmentProperties.TaskLocations{二});指定将作业提交给SLURM调度器的命令。SLURM将自动将环境变量复制到worker。commandToRun =' batch——ntasks=1 independentJobWrapper.sh'；[cmdFailed, cmdOut] = system(commandToRun);结束结束

前述の例はシンプルなbashスクリプトindependentJobWrapper.shをスケジュ，ラに送信します。independentJobWrapper.shスクリプトは次の環境変数を使用してmatlab実行可能ファescルと引数を埋め込みます。

＃/ bin / sh# PARALLEL_SERVER_MATLAB_EXE - MATLAB可执行的来使用# PARALLEL_SERVER_MATLAB_ARGS - MATLABarg游戏来使用执行" $ {PARALLEL_SERVER_MATLAB_EXE} "$ {PARALLEL_SERVER_MATLAB_ARGS}

communicatingSubmitFcn

通信ジョブを汎用クラスタ，に投入すると，関数communicatingSubmitFcn.mがmatlabクラescアントセッションで実行されます。

この関数の宣言行は次のとおりでなければなりません。

函数communicatingSubmitFcn(集群、工作environmentProperties)

この関数の目的はスケジュ，ラに単一のジョブを投入することです。このジョブは次を満たさなければなりません。

ワカ環境の構成-この表に,通信ジョブのタスクを実行するためにワーカーのMATLABに設定しなければならない4つの環境変数と値を示します。

多くのスケジュラは投入コマンドの一部としてクラアント環境をコピすることをサポトしています。サポトしている場合、クライアントに以前の環境変数を設定できるため、スケジューラは設定をワーカー環境にコピーできます。サポートしていない場合は、これらの変数を転送するように投入コマンドを変更しなければなりません。

スケジュラジョブを投入してmpiプロセスを起動-ジョブの4の必須パラメタを定義した後，mpiexecを使用してN個のワ，カ，matlabプロセスを起動し，ジョブを実行します。mpiexecは并行计算工具箱™に付属のソフトウェアで,ワーカーのMATLABプロセス間の通信を可能にするメッセージパッシングインターフェイス(MPI)規格を実装しています。mpiexecの詳細にいては，Mpichのホ，ムペ，ジを参照してください。

ジョブを実行するには，ジョブをスケジュ，ラに投入しなければなりません。スケジュ，ラは次の手順を実行します。matlabrootはワカノド上のmatlabンストルの場所を指す点に注意してください。

Slurmスケジュラ用サンプルスクリプト-次のスクリプトは,共有ファイルシステムをもつ粘ス很多ケジューラ用の基本的な投入関数を示します。

投入されるジョブはbashスクリプトcommunicatingJobWrapper.shに含まれています。このスクリプトは，スケジュラジョブを投入してmpiプロセスを起動のslurmスケジュ，ラに関連するステップを実装します。より詳細な例にいては，サンプルのプラグ@ @ンスクリプトを参照してください。

函数communicatingSubmitFcn(集群、工作environmentProperties)指定四个所需的环境变量。setenv (“PARALLEL_SERVER_DECODE_FUNCTION”，“parallel.cluster.generic.communicatingDecodeFcn”）;setenv (“PARALLEL_SERVER_STORAGE_CONSTRUCTOR”, environmentProperties.StorageConstructor);setenv (“PARALLEL_SERVER_STORAGE_LOCATION”, environmentProperties.StorageLocation);setenv (“PARALLEL_SERVER_JOB_LOCATION”, environmentProperties.JobLocation);指定要在工作线程上运行的MATLAB可执行文件和参数。指定MATLAB安装在集群节点上的位置。这些在communicatingJobWrapper.sh脚本中使用。setenv (“PARALLEL_SERVER_MATLAB_EXE”, environmentProperties.MatlabExecutable);setenv (“PARALLEL_SERVER_MATLAB_ARGS”, environmentProperties.MatlabArguments);setenv (“PARALLEL_SERVER_CMR”, cluster.ClusterMatlabRoot);numberOfTasks = environmentProperties.NumberOfTasks;指定向SLURM调度程序提交作业的命令%请求的进程与作业中的任务一样多。SLURM将自动将环境变量复制到worker。commandToRun = sprintf('sbatch——ntasks=%d communicatingJobWrapper.sh', numberOfTasks);[cmdFailed, cmdOut] = system(commandToRun);结束

getJobStateFcn

汎用クラスタ，で作成されたジョブの状態をクエリすると，関数getJobStateFcn.mがmatlabクラescアントセッションで実行されます。この関数の宣言行は次のとおりでなければなりません。

函数state = getJobStateFcn(cluster,job,state)

サードパーティ製スケジューラを使用している場合,スケジューラは,ローカルジョブストレージからツールボックスが使用できる情報よりも新しいジョブ関連情報をもつ可能性があります。この状況は特に,非共有のファイルシステムを使用している場合(リモートファイルシステムがローカルデータの場所への大規模データファイルの伝播が遅い可能性がある場合)に当てはまります。

スケジュ，ラから情報を取得するには，クラスタ，の(PluginScriptsLocation)に関数getJobStateFcn.mを追加します。

この関数に渡される状態は，ロ，カルジョブストレ，ジから派生した状態です。これにより,この関数の本体がスケジューラをクエリしてジョブのより正確な状態を判定し,保存された状態の代わりに返すことができます。この目的で作成された関数は，ジョブオブジェクトの状態の有効な値を返さなければなりません。使用できる値は“等待”、“排队”、“奔跑”、“完成”，または“失败”です。

Matlabタスクを対応するスケジュラジョブidとペアにする手順にいては，汎用スケジュ，ラによるジョブの管理を参照してください。

cancelJobFcn

汎用クラスタで作成されたジョブをキャンセルすると，matlabクラアントセッションで関数cancelJobFcn.mが実行されます。この関数の宣言行は次のとおりでなければなりません。

函数OK = canceljobbfcn (cluster,job)

汎用スケジューラインターフェイスを使用して作成されたジョブをキャンセルすると,既定でこのアクションはストレージ内のジョブデータにのみ影響します。スケジューラ上の対応するジョブをキャンセルするには,いつ何を実行するかに関する命令をスケジューラに指示しなければなりません。このためには，クラスタ，の(PluginScriptsLocation)に関数cancelJobFcn.mを追加します。

これにより,この関数の本体がスケジューラにコマンド(キューから対応するジョブを削除する,など)を送信できます。この関数は,スケジューラのジョブのキャンセルの成功または失敗を示す逻辑スカラーを返さなければなりません。

Matlabタスクを対応するスケジュラジョブidとペアにする手順にいては，汎用スケジュ，ラによるジョブの管理を参照してください。

cancelTaskFcn

汎用クラスタ，で作成されたタスクをキャンセルすると，関数cancelTaskFcn.mがmatlabクラescアントセッションで実行されます。この関数の宣言行は次のとおりでなければなりません。

函数OK = cancelTaskFcn(cluster,task)

汎用スケジューラインターフェイスを使用して作成されたタスクをキャンセルすると,既定でストレージ内のタスクデータのみが影響を受けます。スケジューラ上の対応するジョブをキャンセルするには,いつ何を実行するかに関する命令をスケジューラに指示しなければなりません。このためには，クラスタ，の(PluginScriptsLocation)に関数cancelTaskFcn.mを追加します。

これにより,この関数の本体がスケジューラにコマンド(スケジューラのキューから対応するジョブを削除する,など)を送信できます。この関数は,スケジューラのジョブのキャンセルの成功または失敗を示す逻辑スカラーを返さなければなりません。

Matlabタスクを対応するスケジュラジョブidとペアにする手順にいては，汎用スケジュ，ラによるジョブの管理を参照してください。

deleteJobFcn

汎用クラスタ，を使用して作成されたジョブを削除すると，deleteJobFcn.m関数がmatlabクラescアントセッションで実行されます。この関数の宣言行は次のとおりでなければなりません。

函数deleteTaskFcn(集群,任务)

汎用スケジューラインターフェイスを使用して作成されたジョブを削除すると,既定でストレージ内のジョブデータのみが影響を受けます。スケジューラ上の対応するジョブを削除するには,いつ何を実行するかに関する命令をスケジューラに指示しなければなりません。このためには，クラスタ，の(PluginScriptsLocation)に関数deleteJobFcn.mを追加します。

これにより,この関数の本体がスケジューラにコマンド(キューから対応するジョブを削除する,など)を送信できます。

Matlabタスクを対応するスケジュラジョブidとペアにする手順にいては，汎用スケジュ，ラによるジョブの管理を参照してください。

deleteTaskFcn

汎用クラスタを使用して作成されたタスクを削除すると，matlabクラアントセッションで関数deleteTaskFcn.mが実行されます。この関数の宣言行は次のとおりでなければなりません。

函数deleteTaskFcn(集群,任务)

汎用スケジューラインターフェイスを使用して作成されたタスクを削除すると,既定でストレージ内のタスクデータのみが影響をうけます。スケジューラ上の対応するジョブを削除するには,いつ何を実行するかに関する命令をスケジューラに指示しなければなりません。このためには，クラスタ，の(PluginScriptsLocation)に関数deleteTaskFcn.mを追加します。

これにより,この関数の本体がスケジューラにコマンド(スケジューラのキューから対応するジョブを削除する,など)を送信できます。

Matlabタスクを対応するスケジュラジョブidとペアにする手順にいては，汎用スケジュ，ラによるジョブの管理を参照してください。

postConstructFcn

Matlabにクラスタのンスタンスを作成した後，Matlabクラアントセッションで関数postConstructFcn.mが実行されます。たとえば，次のコ，ド行はクラスタ，の，“myProfile”クラスタプロファルに関連付けられた関数postConstructFcnを実行します。

C = parcluster(“myProfile”）;

関数postConstructFcnの宣言行は次のとおりでなければなりません。

函数postConstructFcn(集群)

クラスタ，の使用前にそのカスタム構成を実行する必要がある場合は，クラスタ，のPluginScriptsLocationに関数postConstructFcn.mを追加します。この関数の本体には，必要な任意の追加ステップを含めることができます。

クラスタ、プロファ、ジャ、からのAdditionalPropertiesの設定

前述の例のスクリプトを変更して，汎用クラスタ，プロファ，ルにAdditionalPropertiesのエントリを追加し，使用するノ，ドのリストを指定できます。これにより,プラグインスクリプトに追加されたカスタマイズをドキュメント化する方法が,クラスタープロファイルを共有するすべてのユーザーに提供されます。

节点列表プロパティをクラスタプロファルに追加するには次を行います。

MATLABコマンドラ▪▪ンからのAdditionalPropertiesの設定

ユザカスタマゼションの追加のスクリプトを変更して,ジョブの投入前にクラスターオブジェクトの適切なプロパティを設定することで,MATLABコマンドラインからノードのリストを編集できます。

C = parcluster;c.AdditionalProperties.NodeList =“gpuNodeName”；J = c.batch(“myScript”）;

AdditionalPropertiesオブジェクトを表示して，現在定義されているすべてのプロパティとその値を確認します。

>> c.AdditionalProperties ans = AdditionalProperties with properties: ClusterHost: 'myClusterHost' NodeList: 'gpuNodeName' RemoteJobStorageLocation: '/tmp/jobs'

ジョブスケジュ，ラデ，タの保存

この例では，関数independentSubmitFcn.mを変更して，slurmスケジュ，ラに送信された各コマンドの出力を解析する方法を説明します。正規表現を使用して各タスクのスケジュラジョブidを抽出し，setJobClusterDataを使用して保存できます。

模式从SLURM间歇输出中提取调度器作业IDsearchPattern =＇．*提交批处理作业([0-9]+).*'；jobIDs = cell(numberOfTasks, 1);为ii = 1:numberOfTasks setenv(“PARALLEL_SERVER_TASK_LOCATION”, environmentProperties.TaskLocations{二});commandToRun =' batch——ntasks=1 independentJobWrapper.sh'；[cmdFailed, cmdOut] = system(commandToRun);jobIDs{ii} = regexp(cmdOut, searchPattern，“令牌”，“一次”）;结束%在作业集群数据上设置作业id集群。setJobClusterData(工作、结构(“ClusterJobIDs”, {jobIDs}));

ジョブスケジュ，ラデ，タの取得

この例ではcancelJobFcn.mを変更して，slurmスケジュ，ラ上の対応するジョブをキャンセルします。この例では，getJobClusterDataを使用してジョブスケジュ，ラデ，タを取得します。

函数OK = canceljobbfcn (cluster, job)获取此作业的调度程序信息。data = cluster.getJobClusterData(job);jobIDs = data.ClusterJobIDs;为ii = 1:长度(jobIDs)告诉SLURM调度程序取消作业。commandToRun = sprintf(“scancel“% s”, jobIDs{二});[cmdFailed, cmdOut] = system(commandToRun);结束OK = true;