| On this page |
概要
プロセス外でクックするワークアイテム(ジョブ)は、データまたはステータスをPDGに送り返したい事が多いです。 PDG Schedulerは、ジョブが開始した時期とジョブスクリプトの実行内容に関係なくそのジョブが成功したのか失敗したのかを追跡することができます。 しかし、そのジョブが出力ファイルを生成する際に、PDG側にその情報を知らせる必要があれば、このAPIを使ってPDGにその情報を送り返してください。 出力ファイルだけでなく、このAPIを使用して実行中のワークアイテムにアトリビュートを書き出すこともできます。
Job APIは主に2つのPythonモジュールで構成されています:
-
pdgjson.pyには、pdg.WorkItemに相当するハイレベルAPIが用意されています。このモジュールを使用することで、ワークアイテムアトリビュートと入力/出力ファイルの読み書きをすることができます。これが推奨されているAPIです。 -
pdgcmd.pyには、そのpdgjson.pyで使用されているローレベルAPIが用意されています。必要に応じてこのモジュールも使用することができます。
これら2つのPythonモジュールは、PDG Schedulerによって自動的に$PDG_TEMP/scripts下にコピーされます。
基本的な使い方
Pythonモジュール |
挙動 |
|---|---|
|
PDGで利用可能なAPIと同様のハイレベル 例 from pdgjson import WorkItem # `$PDG_TEMP/data/workitem.json`にシリアライズ化されたデータからWorkItemオブジェクトを作成します。 work_item = WorkItem.fromJobEnvironment() # 実行中のワークアイテムからアトリビュート値を読み込みます。 val = work_item.attribValue('myintattrib') # ネットワークコールを介してデータをPDGワークアイテムに送り返します。 work_item.setStringAttrib('runtime_attrib', 'test value', 0) work_item.addResultData('/tmp/myoutput.txt') |
|
RPC関数コールを介してPDGと通信するローレベルAPIが用意されています。 例 from pdgcmd import reportResultData # ネットワークコールを介してデータをPDGワークアイテムに送り返します。 pdgcmd.setStringAttrib('runtime_attrib', 'test value', 0) pdgcmd.reportResultData('/tmp/myoutput.txt') |
pdgcmd関数
メソッド
reportResultData(result_data, item_name=None, server_addr=None, result_data_tag="", subindex=-1, and_success=False, to_stdout=True, duration=0.0, hash_code=0)
ワークスクリプトがファイル(または複数ファイル)を生成する場合、この関数を使ってその結果(s)を報告することができます。
すると、これらのファイルがワークアイテム上のOutputファイルとして追加されます。
Note
以下の他の関数を使用すれば、同じようにアトリビュートを書き出すことができます。
result_data
出力ファイル名、または、出力ファイルパスのリスト。
item_name
この結果を生成したワークアイテムの名前。 この引数を省略すると、この関数は環境変数を照会するようになります。
server_addr
報告先のResultサーバーのIPアドレスを含んだ文字列。 この引数を省略すると、この関数は環境変数を照会するようになります。
result_data_tag
出力ファイル(s)に使用するタイプタグ文字列。例えば、file/geoです。
and_success
これをTrueにすると、この関数コールは、出力ファイルの設定だけでなく、ワークアイテムの状態も Success に設定します。
duration
and_success=Trueに設定すると、ここには、ワークスクリプトの総実行時間(秒を示した浮動小数点値)を設定することができます。
これを設定しなかった場合、workItemStartCook RPCからジョブ終了までの時間をPDGが自動的に計算するようになります。
delocalizePath(local_path)
→ str
Path Mappingが無効な時(スケジューラUIでNoneに設定した時)、この関数は、指定されたパスを__PDG_DIR__をルートにしたパスに変換します(非ローカル化)。
これには、PDG_DIR環境変数が存在している必要があります。
local_path
非ローカル化したいローカルパス。
makeDirSafe(local_path)
→ str
ディレクトリが存在しなければ、ディレクトリを作成します。これは、同じディレクトリの作成が同時に起こらないように安全に行なわれます。
local_path
ディレクトリパス。
localizePath(deloc_path)
→ str
指定したパスをローカル化します。
Path Mappingが無効な時、__PDG*で始まるトークンの置換が行なわれます。
Path Mappingが有効な時、このパスがローカルファイルシステムにマッピングされます。
さらに、環境変数も展開されます。
deloc_path
ローカル化するパス。
waitUntilReady(item_name, subindex, server_addr=None)
バッチサブアイテムがクックを開始できるようになるまでブロック(待機)します。
バッチワークアイテムが最初のフレームの準備が整った時にクックを開始するように設定されていれば、指定したフレームでクックが完全に開始できるように、そのフレームで上流の依存関係すべてが完了したことをPDGに問い合わせて確認する必要があります。
item_name
バッチワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス(バッチ内のワークアイテムのインデックス)。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
getWorkItemJSON(item_name, subindex, server_addr=None)
→ str
指定したワークアイテムをシリアライズ化したJSONを含んだ文字列を返します。
これを使用することで、指定したバッチサブアイテムのフルワークアイテムデータがjust-in-timeで取得されるので、フレームのクックを開始する前にそのバッチサブアイテムをHoudini内のアクティブワークアイテムとして設定することができます。
item_name
バッチワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス(バッチ内のワークアイテムのインデックス)。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
workItemSuccess(item_name, subindex=-1, server_addr=None, to_stdout=True)
指定したワークアイテムが成功したことを報告します。
Note
通常ではスケジューラが処理の戻りコードを見て失敗/成功を判断するので、ワークアイテムがこれを使用する必要は ありません 。
item_name
ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
to_stdout
これがTrueの時、RPCを実行するだけでなく、情報がstdoutにプリントされます。
workItemFailed(item_name, subindex=-1, server_addr=None, to_stdout=True)
指定したワークアイテムが失敗したことを報告します。
Note
通常ではスケジューラが処理の戻りコードを見て失敗/成功を判断するので、ワークアイテムがこれを使用する必要は ありません 。
item_name
ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
to_stdout
これがTrueの時、RPCを実行するだけでなく、情報がstdoutにプリントされます。
workItemStartCook(item_name, subindex=-1, server_addr=None, to_stdout=True)
指定したワークアイテムがクックを開始したことを報告します。
Note
通常ではLocal Schedulerはそのワークアイテムがクックを開始したことを既に知っているわけで、そして、他のファームスケジューラは一般的にはジョブを呼び出す前にこのコールを作成するラッパースクリプトを持っているので、ワークアイテムがこれを使用する必要は ありません 。
item_name
ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
to_stdout
これがTrueの時、RPCを実行するだけでなく、情報がstdoutにプリントされます。
setStringAttribArray(attr_name, attr_value, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
文字列の配列。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setIntAttribArray(attr_name, attr_value, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
数値の配列。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setFloatAttribArray(attr_name, attr_value, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
数値の配列。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setFileAttribArray(attr_name, attr_value, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
pdgjson.Fileオブジェクトの配列。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setPyObjectAttrib(attr_name, attr_value, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
文字列でシリアライズ化されたPythonオブジェクト。
デフォルトでは、eval()を使ってアンシリアライズ化可能なrepr()が返すPythonオブジェクトを使用します。
しかし、[pdg.TypeRegistry#pySerializationModule]を設定すれば、独自のフォーマットを使用することができます。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setStringAttrib(attr_name, attr_value, attr_index, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
文字列値。
attr_index
アトリビュートの値配列内の値のインデックス。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setIntAttrib(attr_name, attr_value, attr_index, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
数値。
attr_index
アトリビュートの値配列内の値のインデックス。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setFloatAttrib(attr_name, attr_value, attr_index, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
数値。
attr_index
アトリビュートの値配列内の値のインデックス。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
setFileAttrib(attr_name, attr_value, attr_index, item_name=None, subindex=-1, server_addr=None)
コールバックサーバーを介してPDG内のワークアイテムにアトリビュートデータを書き出します。
attr_name
作成または更新するアトリビュートの名前。
attr_value
A pdgjson.File object.
attr_index
アトリビュートの値配列内の値のインデックス。
item_name
(オプション)ワークアイテムの名前。
subindex
バッチワークアイテムのサブインデックス。 -1 は、そのワークアイテムがバッチサブアイテムで ない ことを意味します。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
warning(message, item_name=None, server_addr=None)
指定したワークアイテムのノードに警告メッセージを添付します。
message
表示する文字列メッセージ
item_name
(オプション)ワークアイテムの名前。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
reportServerStarted(servername, pid, host, port, proto_type, log_fname, item_name=None, server_addr=None)
共有サーバーが起動したことを報告します。
これは、共有サーバーのインスタンスが起動を開始した時にCommand Chain Serverノードで使用します。
servername
サーバーの名前。
pid
サーバープロセスの数値的なプロセスID(PID)。
host
共有サーバーが起動されているマシンのホスト名。
port
共有サーバーがリッスンする数値的なポート番号。
proto_type
この共有サーバーに関連付けられているプロトコル。
log_fname
この共有サーバーが使用しているログファイルのパス。
item_name
(オプション)ワークアイテムの名前。
server_addr
(オプション)host:portの形式のPDG Resultサーバーアドレス。
