#author("2026-03-07T17:15:19+00:00;2025-10-24T16:51:21+00:00","default:sysosa","sysosa")
#author("2026-05-21T13:57:33+00:00","default:sysosa","sysosa")
Clusters形式

「&color(magenta){Master};」のweb画面で発行するジョブを ジョブ管理システム 経由で流せます.
ジョブ管理システム で管理されているリソースから 適切に選ばれた 計算ノードが「&color(orangered){Worker};」として働きます.


目下使用できる ジョブ管理システム は
-pbs([[OpenPBS]], [[Torque>TORQUE]]ら)
-[[slurm]]
-gridengine

となっているみたい. ここでは OpenPBS を採用しています.
slurmの場合[[cryoSPARC/sbatch]]
gridengineの場合[[cryoSPARC/sge]]

/scratchを共有できないか..[[cryoSPARC/scratch]]

***&color(magenta){master};と&color(orangered){worker};の構築 [#tfd71507]

[[cryoSPARC/Master-Worker]]と同じように構築してください.

ジョブ管理システム の枠組みで
&color(magenta){master};ノード は ジョブ発行ノード を担い、
&color(orangered){worker};ノードを 計算ノードを担います.
そのように job管理システム を構築してください.
参照 [[slurm]], [[OpenPBS]]

***テンプレートの作成 [#sa5f7bb8]

ジョブ管理システム毎の設定シート(&color(darkorange){cluster_info.json};と&color(darkorchid){cluster_script.sh};)があってそれを現場に合わせて修正して登録します.

まずはそのテンプレートを取得.

#code(nonumber){{
[cryosparc@cryosparc ~]$ cryosparcm cluster example
Writing example cluster_info.json and cluster_script.sh to current dir
Unknown cluster type. Supported templates are:
  pbs
  slurm
  gridengine
Any cluster scheduler is supported, but you may have to write your own custom submission script.
[cryosparc@cryosparc ~]$
}}

ここでは[[OpenPBS]]を使用するので「pbs」のテンプレートを頂きます。
#code(nonumber){{
[cryosparc@cryosparc ~]$ cryosparcm cluster example pbs
Writing example cluster_info.json and cluster_script.sh to current dir
[cryosparc@cryosparc ~]$
}}
すると、コマンドを実行した場所に設定ファイルのテンプレート「&color(darkorange){cluster_info.json};」と「&color(darkorchid){cluster_script.sh};」が置かれます.

テンプレート&color(darkorange){cluster_info.json};の中身は下記の通り.  &color(red){*};&size(10){***ここのpukiwikiの記述ルールの問題から「}}」を「} }」にしています***};
#code(nonumber){{
[cryosparc@cryosparc ~]$ cat cluster_info.json
{
    "name" : "pbscluster",
    "worker_bin_path" : "/path/to/cryosparc_worker/bin/cryosparcw",
    "cache_path" : "/path/to/local/SSD/on/cluster/nodes",
    "send_cmd_tpl" : "ssh loginnode {{ command } }",
    "qsub_cmd_tpl" : "qsub {{ script_path_abs } }",
    "qstat_cmd_tpl" : "qstat -as {{ cluster_job_id } }",
    "qdel_cmd_tpl" : "qdel {{ cluster_job_id } }",
    "qinfo_cmd_tpl" : "qstat -q"
}
[cryosparc@cryosparc ~]$
}}
もう一つの&color(darkorchid){cluster_script.sh};はこんな感じ.   &color(red){*};&size(10){***ここのpukiwikiの記述ルールの問題から「}}」を「} }」にしています***};
#code(nonumber){{
[cryosparc@cryosparc ~]$ cat cluster_script.sh
#!/usr/bin/env bash
#### cryoSPARC cluster submission script template for PBS
## Available variables:
## {{ run_cmd } }            - the complete command string to run the job
## {{ num_cpu } }            - the number of CPUs needed
## {{ num_gpu } }            - the number of GPUs needed.
##                            Note: The code will use this many GPUs starting from dev id 0.
##                                  The cluster scheduler has the responsibility
##                                  of setting CUDA_VISIBLE_DEVICES or otherwise enuring that the
##                                  job uses the correct cluster-allocated GPUs.
## {{ ram_gb } }             - the amount of RAM needed in GB
## {{ job_dir_abs } }        - absolute path to the job directory
## {{ project_dir_abs } }    - absolute path to the project dir
## {{ job_log_path_abs } }   - absolute path to the log file for the job
## {{ worker_bin_path } }    - absolute path to the cryosparc worker command
## {{ run_args } }           - arguments to be passed to cryosparcw run
## {{ project_uid } }        - uid of the project
## {{ job_uid } }            - uid of the job
## {{ job_creator } }        - name of the user that created the job (may contain spaces)
## {{ cryosparc_username } } - cryosparc username of the user that created the job (usually an email)
##
## What follows is a simple PBS script:

#PBS -N cryosparc_{{ project_uid } }_{{ job_uid } }
#PBS -l select=1:ncpus={{ num_cpu } }:ngpus={{ num_gpu } }:mem={{ (ram_gb*1000)|int } }mb:gputype=P100
#PBS -o {{ job_log_path_abs } }
#PBS -e {{ job_log_path_abs } }

{{ run_cmd } }

[cryosparc@cryosparc ~]$
}}
これら2つを ジョブ管理システム openPBS に適合するように修正します



***cluster_info.json [#xd24055f]
変更箇所
-name:
cryoSPARCで認識できる名称
-worker_bin_path
&color(orangered){worker};ノードでの「cryosparcw」までの絶対パス
「/home/cryosparc/cryoSPARC/cryosparc_worker/bin/cryosparcw」
-cache_path
&color(orangered){worker};ノードでの「Fast Local Storage」パス.    &size(10){指定フォルダの所有者は「cryosparc」.  指定なしはブランクとする};
「/scr/cs」
-send_cmd_tpl
「{{ command }}」
&color(magenta){master};ノードが直接qsubを実行できないシーンなら、qsubを実行できるノードに接続するコマンドを加える「ssh loginnode {{ command }}」




&color(red){*};&size(10){***ここのpukiwikiの記述ルールの問題から「}}」を「} }」にしています***};
#code(diff,nonumber){{
--- cluster_info.json.orig      2025-10-25 00:14:26.247479928 +0900
+++ cluster_info.json   2025-10-25 01:06:35.750542940 +0900
@@ -1,8 +1,8 @@
 {
     "name" : "pbscluster",
-    "worker_bin_path" : "/path/to/cryosparc_worker/bin/cryosparcw",
-    "cache_path" : "/path/to/local/SSD/on/cluster/nodes",
-    "send_cmd_tpl" : "ssh loginnode {{ command } }",
+    "worker_bin_path" : "/home/cryosparc/cryoSPARC/cryosparc_worker/bin/cryosparcw",
+    "cache_path" : "/scr/cs",
+    "send_cmd_tpl" : "{{ command } }",
     "qsub_cmd_tpl" : "qsub {{ script_path_abs } }",
     "qstat_cmd_tpl" : "qstat -as {{ cluster_job_id } }",
     "qdel_cmd_tpl" : "qdel {{ cluster_job_id } }",
}}



***cluster_script.sh [#q36925f9]
ジョブ監視システムに投入されるスクリプト文です.
openPBSなので「#PBS」とディレクティブが含まれ、要求するリソースが定義されます. 
「cluster_script.sh」はテンプレートでジョブの内容でテンプレート内の変数が上書きされジョブが発行される.

変数には
num_cpu: CPUの数
num_gpu: GPUの数
ram_gb: RAMのサイズ
とかがあります.
これらの値はジョブの設定画面で決められるものや、内部で既に決まっている場合もあります.

計算に必要なCPUの数、GPUの数、RAMのサイズが定まれば、ジョブ管理システムを経由して実行すべき計算ノードが定まり、そこにジョブが投入される次第ですね.

テンプレートの「#PBS -l」欄には「gputype=P100」とあります. これはP100を持つ計算ノード限定にジョブを流すことを意図してまして、まぁー不要. なのでここを削ります.

#code(diff,nonumber){{
--- cluster_script.sh.orig      2025-10-25 01:21:29.464702751 +0900
+++ cluster_script.sh   2025-10-25 01:21:38.559632567 +0900
@@ -22,7 +22,7 @@
 ## What follows is a simple PBS script:

 #PBS -N cryosparc_{{ project_uid } }_{{ job_uid } }
-#PBS -l select=1:ncpus={{ num_cpu } }:ngpus={{ num_gpu } }:mem={{ (ram_gb*1000)|int } }mb:gputype=P100
+#PBS -l select=1:ncpus={{ num_cpu } }:ngpus={{ num_gpu } }:mem={{ (ram_gb*1000)|int } }mb
 #PBS -o {{ job_log_path_abs } }
 #PBS -e {{ job_log_path_abs } }
}}
&color(red){*};&size(10){***ここのpukiwikiの記述ルールの問題から「}}」を「} }」にしています***};






***カスタマイズしたテンプレートの取り込み [#x8613478]

こうしてカスタマイズした&color(darkorange){cluster_info.json};と&color(darkorchid){cluster_script.sh};をシステムに登録させる.
これらのファイルが置かれた場所で「cryosparcm cluster connect」を実行します
#code(nonumber){{
[cryosparc@cryosparc ~]$ cryosparcm cluster connect
 :
Successfully added cluster lane pbscluster

(確認は下記コマンドで)
[cryosparc@cryosparc ~]$ cryosparcm cli "get_scheduler_lanes()"

(v5)
[cryosparc@cryosparc ~]$ cryosparcm cli "api.resources.find_lanes()"

(削除はcluster_info.jsonのnameを使います)
[cryosparc@cryosparc ~]$ cryosparcm cluster remove pbscluster
(あるいは)
[cryosparc@cryosparc ~]$ cryosparcm cli "remove_scheduler_lane('pbscluster')"

(v5)
[cryosparc@cryosparc ~]$ cryosparcm cli "api.resources.remove_cluster('pbscluster')"
}}


***ホスト毎にジョブを流したい [#o64a290a]

もはやジョブ管理システムではなくなっているような気がしますが、ジョブ管理システムでホスト指定でジョブを流すには
「&color(darkorchid){cluster_script.sh};」の「#PBS -l」欄で「host=gpu01」と明記します
#code(diff,nonumber){{
#PBS -l select=1:ncpus={{ num_cpu } }:ngpus={{ num_gpu } }:mem={{ (ram_gb*1000)|int } }mb:host=gpu01
}}
そして「&color(darkorange){cluster_info.json};」でnameを「cs-gpu01」とかにして登録します。

gpu02なら
#code(diff,nonumber){{
#PBS -l select=1:ncpus={{ num_cpu } }:ngpus={{ num_gpu } }:mem={{ (ram_gb*1000)|int } }mb:host=gpu02
}}
「&color(darkorange){cluster_info.json};」でnameを「cs-gpu02」として登録とかでしょうか.  &color(red){*};&size(10){***ここのpukiwikiの記述ルールの問題から「}}」を「} }」にしています***};
これでホスト指定でジョブ投入が行えます。

&size(10){これなら「master-worker」方式でもよさげですが...};



***メモ [#i6ab2782]
「&color(red){[Errno 2] No such file or directory: 'qsub': 'qsub'};」と表示されたらそれは&color(magenta){master};でqsubへのPATHが入っていない可能性がある

Clusters形式で自動起動する場合、/etc/profile.d/slurm.sh もしくは /etc/profile.d/pbs.sh を噛んで立ち上がる必要があり.
その際「cryosparc.service」で
#code(nonumber){{
ExecStart=/home/cryosparc/cryosparc_master/bin/cryosparcm start
  ↓
ExecStart=/bin/bash -l /home/cryosparc/cryosparc_master/bin/cryosparcm start
}}
とする. そうしないとsbatchやqsubコマンドが見つからずに落ちる



***メモ clusterでのpatchの当て方 [#x9457434]
master側には
#code(nonumber){{
cryosparcm patch
}}
でいいのだが、worker側にはpatchがあたらない. なので
#code(nonumber){{
cryosparcm patch --download
あるいは
cryosparcm patch --download --force
}}
にてパッチファイルを取得して、
#code(nonumber){{
cd cryosparc_worker/
cp ../cryosparc_master/cryosparc_worker_patch.tar.gz .
bin/cryosparcw patch
}}
で行う

***変数を追加 [#m4be6276]

「とある系で計算してたらメモリーが足らない」と表示された. でも「設定画面にメモリーの項目がない」とか発生する時があります.

たいていは、cryoSPARCが想定しているメモリー量よりも多くのメモリーが必要なのに、「#PBS -l」に必要量のメモリーが指定されていないために起こる現象ですね.

回避策としては「#PBS -l」にパラメータを設置します. するとcryoSPARC側がそれを察知して「設定画面」にメモリーの係数を項目として表示します. これを調整してジョブを流します.

&color(darkorchid){cluster_script.sh};の例.  ram_gb_multiplier が係数になります.
#code(nonumber){{
#!/usr/bin/env bash
#PBS -N cryosparc_{{ project_uid } }_{{ job_uid } }
#PBS -l select=1:ncpus={{ num_cpu } }:ngpus={{ num_gpu } }:mem={{ (ram_gb|float * (ram_gb_multiplier|default(1))|float)|int } }G
#PBS -o {{ job_log_path_abs } }
#PBS -e {{ job_log_path_abs } }

{{ run_cmd } }
}}
これで登録すると
cryoSPARCサービスのAdmin->Cluster Configurationが下記のようになります
&ref(2025y06m11d_023041213.png,nolink,80%);
このままでは「No cluster variables have been set.」なので「1」を入力して「set」を押下します。これで何も変更しなければデフォの値で計算が進みます
&ref(2025y06m11d_023740044.png,nolink); --> &ref(2025y06m11d_023746965.png,nolink);

これでジョブを投入する際にLaneから「pbscluster」を選ぶと下記のように「Cluster submittion script variables」が選べて、それを開いて「This job」でこのジョブの実行の際の係数を入れます。2倍で行うなら2と入力します
&ref(2025y06m11d_024146948.png,nolink); --> &ref(2025y06m11d_024200276.png,nolink);
1

トップ   編集 差分 履歴 添付 複製 名前変更 リロード   新規 一覧 検索 最終更新   ヘルプ   最終更新のRSS