包装脚本

示例插件脚本使用包装纸简化实现的脚本独立人员和communicatingSubmitFcn.m．但是，不需要这些脚本，但是，使用它们是一种很好的做法，使您的代码更可读。此表介绍了这些脚本：

independentSubmitFcn

当您向通用集群提交独立作业时，独立人员函数在MATLAB客户端会话中执行。

这个函数的声明行必须是:

功能independentSubmitFcn(集群、工作environmentProperties)

Matlab独立作业中的每个任务对应于调度程序上的单个作业。此功能的目的是提交N工作到您的第三方调度程序，其中N是独立作业中的任务数。每项工作必须：

配置工作环境。此表确定了运行单个任务必须在worker MATLAB上设置的五个环境变量和值：

许多调度器支持将复制客户端环境作金宝app为提交命令的一部分。如果是这样，您可以在客户端中设置以前的环境变量，以便调度器可以将它们复制到工作环境中。如果没有，则必须修改提交命令以转发这些变量。

提交要运行的调度程序作业马铃薯工人。一旦在worker上定义了给定作业和任务的5个必需参数，就可以通过调用MATLAB可执行文件来运行该任务。要调用的MATLAB可执行文件定义在environmentProperties.Matlab可执行文件．要传递的参数定义在environmentProperties.MatlabArguments．

SLURM调度器的示例脚本。这个脚本显示了带有共享文件系统的SLURM调度器的基本提交函数。有关更完整的示例，请参见示例插件脚本．

功能independentSubmitFcn(集群、工作environmentProperties)％指定所需的环境变量。setenv (“PARALLEL_SERVER_DECODE_FUNCTION”，“parallel.cluster.generic.independentDecodeFcn”）;setenv (“并行\u服务器\u存储\u构造函数”, environmentProperties.StorageConstructor);setenv (“PARALLEL_SERVER_STORAGE_LOCATION”，forionalproperties.storageLocation）;setenv ('parallel_server_job_location'，EnvironyProperties.joBlocation）;指定要在worker上运行的MATLAB可执行文件和参数。%这些在independentJobWrapper.sh脚本中使用。setenv (“PARALLEL_SERVER_MATLAB_EXE”，环境预备..matlabexecutable）;setenv ('parallel_server_matlab_args', environmentProperties.MatlabArguments);为II = 1：EnvironalProperties.numberoftasks%指定标识要运行的任务所需的环境变量。setenv ('parallel_server_task_location', environmentProperties.TaskLocations{二});%指定将作业提交给SLURM调度程序的命令。% SLURM将自动将环境变量复制到workers。commandToRun ='sbatch --ntasks = 1独立jobwrapper.sh'；[cmdFailed, cmdOut] = system(commandrun);结束结束

前面的示例提交了一个简单的bash脚本，independentJobWrapper.sh，给调度员。的independentJobWrapper.sh脚本使用环境变量嵌入MATLAB可执行文件和参数：

＃/ bin / sh#并行服务器MATLAB EXE-MATLAB可执行的到使用#PARALLEL_SERVER_MATLAB_ARGS-MATLABarg游戏到使用执行“$ {parallel_server_matlab_exe}”$ {PARALLEL_SERVER_MATLAB_ARGS}

communicatingSubmitFcn

当您向通用集群提交通信作业时communicatingSubmitFcn.m函数在MATLAB客户端会话中执行。

这个函数的声明行必须是:

功能communicatingsubmitfcn（群集，工作，环境议程）

此函数的目的是向调度程序提交单个作业。这个工作必须:

配置工作环境。该表确定了运行通信作业的任务时必须在worker MATLAB上设置的四个环境变量和值:

许多调度器支持将复制客户端环境作金宝app为提交命令的一部分。如果是这样，您可以在客户端中设置以前的环境变量，以便调度器可以将它们复制到工作环境中。如果没有，则必须修改提交命令以转发这些变量。

提交计划程序作业以启动MPI进程。定义给定作业的四个必需参数后，通过启动运行您的作业N工人Matlab流程使用mpiexec．mpiexec软件与并行计算工具箱™一起提供，它可以实现消息传递接口（MPI）标准，以允许Worker Matlab进程之间的通信。有关的更多信息mpiexec，看看MPICH主页．

要运行您的工作，您必须将作业提交到调度程序，执行以下步骤。注意matlabroot.指工作节点上的MATLAB安装位置。

SLURM调度器的示例脚本。下面的脚本显示了带有共享文件系统的SLURM调度器的基本提交函数。

提交的作业包含在Bash脚本中，communicatedjobwrapper.sh.．此脚本实现相关步骤提交调度程序作业以启动MPI进程对于幻灯管调度程序。有关更完整的示例，请参见示例插件脚本．

功能communicatingsubmitfcn（群集，工作，环境议程）%指定四个必需的环境变量。setenv (“PARALLEL_SERVER_DECODE_FUNCTION”，“parallel.cluster.generic.communicatingDecodeFcn”）;setenv (“并行\u服务器\u存储\u构造函数”, environmentProperties.StorageConstructor);setenv (“PARALLEL_SERVER_STORAGE_LOCATION”，forionalproperties.storageLocation）;setenv ('parallel_server_job_location'，EnvironyProperties.joBlocation）;指定要在worker上运行的MATLAB可执行文件和参数。%指定群集节点上MATLAB安装的位置。%这些在通信的jobwrapper .sh脚本中使用。setenv (“PARALLEL_SERVER_MATLAB_EXE”，环境预备..matlabexecutable）;setenv ('parallel_server_matlab_args', environmentProperties.MatlabArguments);setenv (“PARALLEL_SERVER_CMR”，cluster.clustermatlabroot）;numberoftasks = EnvironalProperties.numberoftasks;％指定将作业提交给Slurm Scheduler的命令%请求与作业中的任务数量相同的进程。% SLURM将自动将环境变量复制到workers。commandToRun = sprintf (“sbatch——ntasks = % d communicatingJobWrapper.sh ', numberOfTasks);[cmdFailed, cmdOut] = system(commandrun);结束

getjobstatefcn.

查询使用泛型群集创建的作业的状态时，getJobStateFcn.m函数在MATLAB客户端会话中执行。这个函数的声明行必须是:

功能state=getJobStateFcn（集群、作业、状态）

当使用第三方计划程序时，计划程序可能拥有比工具箱从本地作业存储位置可用的更多有关作业的最新信息。如果使用非共享文件系统，这种情况尤其如此，远程文件系统可能会在将大型数据文件传播回本地数据位置时速度较慢。

要从调度程序检索信息，请添加一个调用的函数getJobStateFcn.m到插件脚本位置你的集群。

传递给该函数的状态是从本地作业存储派生的状态。然后，该函数体可以查询调度程序，以确定作业的更准确的状态，并在存储状态的位置返回该状态。为此目的编写的函数必须返回作业对象状态的有效值。允许的值是'待办的'，“排队”，“跑步”，“完成”， 要么'失败的'．

有关将MATLAB任务与其相应的调度程序作业ID配对的说明，请参见使用通用调度程序管理作业．

canceljobfcn.

当您取消使用泛型群集创建的作业时，cancelJobFcn.m函数在MATLAB客户端会话中执行。这个函数的声明行必须是:

功能好吧= cancelJobFcn(集群,工作)

取消使用通用计划程序界面创建的作业时，默认情况下，此操作仅影响存储器中的作业数据。若要取消计划程序上的相应作业，必须向计划程序提供有关执行内容和时间的说明。为此，添加一个名为cancelJobFcn.m到插件脚本位置你的集群。

然后，此函数的主体可以向调度程序发送命令，例如，从队列中删除相应的作业。函数必须返回一个逻辑标量，指示取消调度程序上作业的成功或失败。

有关将MATLAB任务与其相应的调度程序作业ID配对的说明，请参见使用通用调度程序管理作业．

cancelTaskFcn

取消使用常规群集创建的任务时canceltaskfcn.m.m.函数在MATLAB客户端会话中执行。这个函数的声明行必须是:

功能OK = CANCOTTASKFCN（群集，任务）

当您取消使用通用调度器接口创建的任务时，默认情况下，这只影响存储中的任务数据。若要取消调度程序上的相应作业，必须向调度程序提供关于做什么以及何时做的说明。为此，添加一个被调用的函数canceltaskfcn.m.m.到插件脚本位置你的集群。

然后，该函数体可以向调度程序发送命令，例如，从调度程序队列中删除相应的作业。该函数必须返回一个逻辑标量，指示在调度器上取消作业的成功或失败。

有关将MATLAB任务与其相应的调度程序作业ID配对的说明，请参见使用通用调度程序管理作业．

deleteJobFcn

删除使用泛型群集创建的作业时，deletejobfcn.m.函数在MATLAB客户端会话中执行。这个函数的声明行必须是:

功能DELOTETASKFCN（群集，任务）

默认情况下，删除使用通用调度程序接口创建的作业时，这仅影响存储中的作业数据。要删除调度程序上的相应作业，您必须提供有关该做什么以及何时对调度程序执行的说明。为此，添加一个被调用的函数deletejobfcn.m.到插件脚本位置你的集群。

然后，该函数的主体可以向调度器发送命令，例如，以从调度程序队列中删除相应的作业。

有关将MATLAB任务与其相应的调度程序作业ID配对的说明，请参见使用通用调度程序管理作业．

删除任务FCN

当您删除使用泛型群集创建的任务时，deleteTaskFcn.m函数在MATLAB客户端会话中执行。这个函数的声明行必须是:

功能DELOTETASKFCN（群集，任务）

删除使用通用调度程序界面创建的任务时，默认情况下，这仅影响存储中的任务数据。要在调度程序上删除相应的作业，您必须提供有关该做什么以及何时将其执行到调度程序的说明。为此，添加一个被调用的函数deleteTaskFcn.m到插件脚本位置你的集群。

然后，该函数体可以向调度程序发送命令，例如，从调度程序队列中删除相应的作业。

有关将MATLAB任务与其相应的调度程序作业ID配对的说明，请参见使用通用调度程序管理作业．

postconstructfcn.

在MATLAB中创建集群实例后施工后CN.m函数在MATLAB客户端会话中执行。例如，以下代码行创建了群集的实例并运行postconstructfcn.与之相关的功能“myProfile”群简介:

c = parcluster ('我的简历'）;

宣言线postconstructfcn.函数必须:

功能postConstructFCN（群集）

如果在使用集群之前需要对其执行自定义配置，请添加一个名为施工后CN.m到插件脚本位置你的集群。这个函数体可以包含您需要的任何额外的设置步骤。

从群集概要文件管理器设置附加属性

在上一个示例中对脚本的修改，可以添加一个AdditionalProperties进入您的通用群集配置文件以指定要使用的节点列表。这提供了一种在您共享群集配置文件的任何人的版本中添加到插件脚本的自定义的方法。

要添加节点主义者属性到您的群集个人资料：

属性设置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'

保存作业调度程序数据

这个例子展示了如何修改独立人员函数解析提交给Slurm Scheduler的每个命令的输出。您可以使用正则表达式来提取每个任务的调度程序作业ID，然后将其存储使用setJobClusterData．

从SLURM sbatch输出中提取调度程序作业ID的模式searchPattern ='。*提交批处理作业（[0-9] +）。*'；jobIDs = cell(numberOfTasks, 1);为II = 1：numberoftasks setEnv（'parallel_server_task_location', environmentProperties.TaskLocations{二});commandToRun ='sbatch --ntasks = 1独立jobwrapper.sh'；[cmdFailed, cmdOut] = system(commandrun);jobids {ii} = regexp（cmdout，searchpattern，“令牌”，“一次”）;结束％在作业群集数据上设置作业IDsetJobClusterData（作业，结构('clusterjobids', {jobIDs}));

检索作业计划程序数据

这个例子修改了cancelJobFcn.m取消SLURM调度程序上相应的作业。本例使用getJobClusterData检索作业计划程序数据。

功能OK = CANCELJOBFCN（群集，作业）％获取此作业的计划程序信息data = cluster.getjobclusterData（作业）;jobids = data.clusterjobids;为II = 1：长度（乔迪斯）％告诉Slurm Scheduler取消作业commandToRun = sprintf (“scancel“% s”，乔迪斯{II}）;[cmdFailed, cmdOut] = system(commandrun);结束好的=真;