「pione-client」の版間の差分
提供: Eospedia
行164: | 行164: | ||
== 実行例 == | == 実行例 == | ||
=== オプション必須項目のみの場合 === | === オプション必須項目のみの場合 === | ||
+ | 引数に[[PIONE定義書]]を指定して実行します。<br> | ||
<pre> | <pre> | ||
+ | $ pione-client HelloWorld.pione | ||
+ | ==> &Anonymous:Root([],{}) | ||
+ | --> Rule Application: &Anonymous:Root([],{}) | ||
+ | --> Distribution: &Anonymous:Root([],{}) | ||
+ | >>> &Anonymous:Main([],{}) | ||
+ | ==> &Anonymous:Main([],{}) | ||
+ | SH ------------------------------------------------------------ | ||
+ | SH echo "Hello PIONE world !" > message.txt | ||
+ | SH ------------------------------------------------------------ | ||
+ | <-- Distribution: &Anonymous:Root([],{}) | ||
+ | <== &Anonymous:Main([],{}) | ||
+ | <-- Rule Application: &Anonymous:Root([],{}) | ||
+ | <== &Anonymous:Root([],{}) | ||
+ | $ ls ./process/ | ||
+ | output pione-process.log | ||
</pre> | </pre> | ||
+ | -b指定なしなので、processディレクトリが作成され、その中に入力(今回は無い)、出力、ログが格納されます。<br> | ||
+ | <br> | ||
+ | |||
+ | === オプション -b === | ||
+ | -bにてディレクトリ名を指定して実行します。<br> | ||
+ | <pre> | ||
+ | $ pione-client HelloWorld.pione -b BaseDir | ||
+ | ==> &Anonymous:Root([],{}) | ||
+ | --> Rule Application: &Anonymous:Root([],{}) | ||
+ | --> Distribution: &Anonymous:Root([],{}) | ||
+ | >>> &Anonymous:Main([],{}) | ||
+ | ==> &Anonymous:Main([],{}) | ||
+ | SH ------------------------------------------------------------ | ||
+ | SH echo "Hello PIONE world !" > message.txt | ||
+ | SH ------------------------------------------------------------ | ||
+ | <== &Anonymous:Main([],{}) | ||
+ | <-- Distribution: &Anonymous:Root([],{}) | ||
+ | <-- Rule Application: &Anonymous:Root([],{}) | ||
+ | <== &Anonymous:Root([],{}) | ||
+ | $ ls BaseDir/ | ||
+ | output pione-process.log | ||
+ | </pre> | ||
+ | BaseDirディレクトリが作成され、その中に結果などが格納されています。<br> | ||
+ | <br> | ||
+ | |||
+ | === オプション -i === | ||
+ | -iにて入力データ用のディレクトリ名を指定して実行します。<br> | ||
+ | <br> | ||
+ | |||
+ | (Multiplying.pione)<br> | ||
+ | <pre> | ||
+ | Rule Main | ||
+ | input 'test.in' | ||
+ | output 'test.out' | ||
+ | Action | ||
+ | awk '{ print $1*2 }' {$I[1]} > {$O[1]} | ||
+ | End | ||
+ | </pre> | ||
+ | 上記の[[PIONE定義書]]は入力データtest.inを必要としていますので、test.inのディレクトリ名を相対パスで設定します。<br> | ||
+ | <br> | ||
+ | |||
+ | MultiplyingInput内 | ||
+ | <pre> | ||
+ | $ ls MultiplyingInput | ||
+ | test.in | ||
+ | </pre> | ||
+ | <br> | ||
+ | |||
+ | 実行結果<br> | ||
+ | <pre> | ||
+ | $ pione-client Multiplying.pione -i MultiplyingInput/ | ||
+ | ==> &Anonymous:Root([.DS_Store,test.in],{}) | ||
+ | --> Rule Application: &Anonymous:Root([.DS_Store,test.in],{}) | ||
+ | --> Distribution: &Anonymous:Root([.DS_Store,test.in],{}) | ||
+ | >>> &Anonymous:Main([test.in],{}) | ||
+ | ==> &Anonymous:Main([test.in],{}) | ||
+ | SH ------------------------------------------------------------ | ||
+ | SH awk '{ print $1*2 }' test.in > test.out | ||
+ | SH ------------------------------------------------------------ | ||
+ | <-- Distribution: &Anonymous:Root([.DS_Store,test.in],{}) | ||
+ | <== &Anonymous:Main([test.in],{}) | ||
+ | <-- Rule Application: &Anonymous:Root([.DS_Store,test.in],{}) | ||
+ | <== &Anonymous:Root([.DS_Store,test.in],{}) | ||
+ | $ ls process/ | ||
+ | input output pione-process.log | ||
+ | $ ls process/input/ | ||
+ | test.in | ||
+ | </pre> | ||
+ | MultiplyingInput内のデータを入力としてprocess/input内にコピーし、処理を実行しています。<br> | ||
<br> | <br> |
2014年12月11日 (木) 06:02時点における版
pione-clientとはpione定義書やパッケージから処理を実行するPIONEのコマンドです。
オプション一覧
オプション | 型 | デフォルト | 説明 |
---|---|---|---|
引数 | location | 必須 | 実行するPIONE定義書またはPIONEパッケージ |
-b | LOCATION | ./process/ | 処理のベースディレクトリ |
--client-ui | TYPE | Type of the client's user interface | |
--communication-address | URI | プロセス間通信で使用するIPアドレス:ポート番号 | |
--dry-run | なし | なし | ドライランモード |
--features | FEATURES | 特性 | |
--file-cache-method | NAME | simple | ファイルキャッシュ方式名: simple, no_cache |
--file-sliding | [BOOLEAN] | ファイルスライド処理 | |
-i | LOCATION | Set input directory | |
--notification-receiver | URI | Receiver address that notifications are received at | |
--notification-target | URI | Target address that notifications are sent to | |
--params | Set user parameters(--params="{Var:1,...}") | ||
--parent-front | URI | set parent front URI | |
--rehearse | [SCENARIO] | rehearse the scenario | |
--request-from | URI | URI that the client requested the job from | |
--request-task-worker | N | Set request number of task workers | |
--session-id | ID | Session id of the job | |
--stand-alone | なし | なし | Turn on stand alone mode |
--stream | [BOOLEAN] | Turn on/off stream mode | |
-t | N | Set task worker size that this process creates | |
--timeout | SEC | timeout processing after SEC | |
--color | BOOLEAN | true | 出力結果の文字に色を付ける |
--debug | [TYPE] | system | デバッグモードで実行 |
-h | [FORMAT] | txt | ヘルプを表示 |
-v | なし | なし | バージョンを表示 |