WASM プロセス

process.wasm エントリは Wippy プロセスホスト配下で WASM モジュールを実行し、生成、監視、監督付きシャットダウンを提供します。

分類: プロセス設定およびライフサイクルリファレンス。 バイナリを使用するブロックでは、外部でのコンポーネントビルドと、アプリケーション所有のファイルシステム、プロセスホスト、環境、ポリシーの各エントリを前提としています。プレースホルダーハッシュは、対象バイナリの正確なダイジェストに置き換える必要があります。

エントリ設定

entries:
  - name: wasm_binaries
    kind: fs.directory
    directory: ./wasm

  - name: compute_worker
    kind: process.wasm
    fs: myns:wasm_binaries
    path: /worker.wasm
    hash: sha256:292b796376f8b4cc360acf2ea6b82d1084871c3607a079f30b446da8e5c984a4
    method: run
    imports:
      - wippy:actor
      - wasi:io
      - wasi:poll
    options:
      limits:
        memory_bytes: 67108864
      mailbox:
        capacity: 128
        bytes: 8388608
        message_bytes: 1048576

設定フィールド

ステートフルな Actor とメッセージング

component guest で wippy:actor を import すると、現在の PID と制限付き mailbox にアクセスできます。wippy:actor/process@0.1.0 インターフェースは次の機能を提供します。

メッセージには送信元 PID、topic、最大 16 個の payload が含まれます。payload の形式は bytes、UTF-8 の text、UTF-8 の json です。送信は宛先 PID に対する process.send として認可されます。形式不正、サイズ超過、容量超過のメッセージは、guest が受け取る前に mailbox への受け入れが拒否されます。

guest は通常、長時間実行する run 関数をエクスポートします。例:

package example:worker;

world worker {
  import wippy:actor/process@0.1.0;
  import wasi:io/poll@0.2.8;
  export run: func() -> result<_, string>;
}

run の中でループして receive() を呼び出し、guest の状態を更新します。応答するには message.from に対して send() を使用します。run から戻るとプロセスが終了します。

Actor の制御

永続的なリソースと mailbox の予算は options で設定します。

options:
  worker_class: wasm
  limits:
    memory_bytes: 67108864
    host_buffer_bytes: 8388608
    asyncify_stack_bytes: 65536
    max_execution_ms: 0
    max_open_sockets: 16
    socket_timeout_ms: 30000
  mailbox:
    capacity: 128
    bytes: 8388608
    message_bytes: 1048576

mailbox.message_bytes は mailbox.bytes を超えられません。capacity は キュー内の各メッセージに最低 256 バイトを計上するバイト予算にも収まる 必要があります。不明なフィールドや無効な値はエントリの受け入れを失敗させます。

CLI コマンド

meta.command を使用して、WASM プロセスを名前付きコマンドとして登録します。

  - name: greet
    kind: process.wasm
    meta:
      command:
        name: greet
        short: Greet someone via WASM
    fs: myns:wasm_binaries
    path: /component.wasm
    hash: sha256:...
    method: greet

次のコマンドで実行します。

wippy run greet

利用可能なコマンドを一覧表示します。

wippy run list

CLIコマンドが動作するにはterminal.hostが必要です。これがコマンドを実行するプロセスホストです。

プロセスライフサイクル

WASM プロセスは Init/Step/Close ライフサイクルモデルに従います。

1. Init - 呼び出しコンテキスト、メソッド、入力引数を取得します
2. Step - 最初のステップでモジュールをインスタンス化して開始します。後続ステップではディスパッチャーブリッジ操作を進めます。同期実行は最初のステップで完了する場合があります
3. Close - インスタンスのリソースを解放します

Lua からの生成

WASM プロセスを生成し、完了まで監視します。

local errors = require("errors")

-- Spawn with monitoring
local pid, err = process.spawn_monitored(
    "myns:compute_worker",   -- entry ID
    "myns:processes",        -- process host
    6, 7                     -- arguments passed to the WASM function
)

if err then
    return nil, err
end

-- Wait for the process to complete
local events = process.events()
while true do
    local event, open = events:receive()
    if not open then return nil, errors.new("process event channel closed") end
    if event.kind == process.event.EXIT and event.from == pid then
        local result = event.result.value  -- return value from the WASM function
        return result, event.result.error
    end
end

非同期実行

WASM プロセスは、mailbox の送受信、ポーリング、クロック、ソケット、DNS、ファイルシステムストリーム、送信 HTTP など、ランタイムがディスパッチャーを通じてブリッジするホスト操作で yield できます。スケジューラは保留中の操作が完了するまでプロセスを一時停止し、その後同じ guest インスタンスを再開します。

  - name: http_worker
    kind: process.wasm
    fs: myns:wasm_binaries
    path: /http_worker.wasm
    hash: sha256:...
    method: run
    imports:
      - wasi:io
      - wasi:cli
      - wasi:http
    wasi:
      env:
        - id: myns:api_url
          name: API_URL
          required: true

yield/resume の仕組みは、asyncify された core モジュールや、サポートされている pollable インターフェースを使用する component からは透過的です。

WASI 設定

プロセスは関数と同じ WASI 設定に対応しています。

  - name: file_processor
    kind: process.wasm
    fs: myns:wasm_binaries
    path: /processor.wasm
    hash: sha256:...
    method: process
    imports:
      - wasi:cli
      - wasi:io
      - wasi:clocks
      - wasi:filesystem
    wasi:
      args: ["--input", "/data/input.csv"]
      cwd: "/app"
      env:
        - id: myns:output_format
          name: OUTPUT_FORMAT
      mounts:
        - fs: myns:input_data
          guest: /data
          read_only: true
        - fs: myns:output_dir
          guest: /output

関連項目

• 概要 - WebAssembly ランタイムの概要
• 関数 - WASM 関数の設定
• ホスト関数 - 利用可能なホストインターフェース
• プロセスモデル - プロセスライフサイクル
• 監督 - プロセス監督ツリー