--- schema_version: "1" id: 63b046f5939e2ddd6869d55242e704df6e37c5a067464aa07a7b730ccb07cb87 title: Rust での Flex Gateway カスタムポリシーの実装 collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/gateway/1.9/policies-custom-flex-implement-rust.md canonical_url: https://docs.mulesoft.com/jp/gateway/1.9/policies-custom-flex-implement-rust source_site: docs.mulesoft.com content_type: documentation content_hash: 9a7d07967630cd8749a9dc93e1e5d3dceb310963f5b64b30080eaa0994e2e7fb description: MuleSoft Documentation Site release: "1.9" latest: false --- # Rust での Flex Gateway カスタムポリシーの実装 **新機能があります**​: この製品機能は最新ではなく、既存のカスタムポリシーのためにのみ提供されています。新しいカスタムポリシーを作成するには、​[Flex Gateway Policy Development Kit (PDK)](https://docs.mulesoft.com/pdk/latest/policies-pdk-overview)​ を使用してください。 ## [](#概要)概要 WebAssembly (WASM) 拡張機能を使用して、Envoy 上でカスタム検索条件として機能するカスタムポリシーを実装できます。これらのポリシーは、 [WebAssembly for Proxies (Rust SDK)](https://github.com/proxy-wasm/proxy-wasm-rust-sdk)​ を使用して実装します。以下の例では、Rust と関連ツールに関する知識があることを前提としています。 ## [](#ライフサイクルイベント)ライフサイクルイベント カスタムポリシーは、Envoy に依存しないイベント駆動型の L4/L7 プロキシ用ローレベルインターフェースである [proxy-wasm ABI](https://github.com/proxy-wasm/spec)​ に基づいています。このインターフェースは、WASM 拡張機能とホストがやり取りする方法を指定し、リスン可能なライフサイクルイベントである HTTP 要求ライフサイクルイベントに加えて WASM 検索条件ライフサイクルイベントも使用します。 SDK は、各ライフサイクルイベントに関連した情報を取得するためのメソッドを提供します。たとえば、​`on_http_request_headers`​ イベントから取得されるデータを使用して、関連するカスタムポリシーロジックを実行でき、その結果によって、要求を処理する必要があるかどうかをランタイムに通知できます。 ### [](#http-要求ライフサイクルイベント)HTTP 要求ライフサイクルイベント - `on_http_request_headers` エンドポイントが完全な HTTP リクエストヘッダーのセットを受け取るとトリガーされます。 - `on_http_request_body` エンドポイントが HTTP 要求の最初の数バイトを受け取るとトリガーされます。 - `on_http_response_headers` エンドポイントが完全な HTTP レスポンスヘッダーのセットを受け取るとトリガーされます。 - `on_http_response_body` エンドポイントが HTTP 応答本文の最初の数バイトを受け取るとトリガーされます。 ### [](#ライフサイクルイベントの絞り込み)ライフサイクルイベントの絞り込み - `on_configure` WASM 検索条件が使用可能な設定で開始されるとトリガーされます。 Flex Gateway は、ポリシー設定を JSON にシリアル化し、シリアル化された設定は Envoy WASM 検索条件の設定に使用されます。この JSON をカスタムポリシーで使用されるデータに非シリアル化して解析できます。 ### [](#ライフサイクルイベントの実装例)ライフサイクルイベントの実装例 次の Envoy 検索条件テンプレートは、ライフサイクルイベントの実装方法を示しています。 use proxy\_wasm::traits::\*; use proxy\_wasm::types::\*; proxy\_wasm::main! {{ proxy\_wasm::set\_log\_level(LogLevel::Trace); proxy\_wasm::set\_root\_context(|\_| -> Box { Box::new(HttpConfigHeaderRoot { header\_content: String::new(), }) }); }} struct HttpConfigHeader { header\_content: String, } impl Context for HttpConfigHeader {} impl HttpContext for HttpConfigHeader { fn on\_http\_request\_headers(&mut self, \_num\_headers: usize, \_end\_of\_stream: bool) -> Action { Action::Continue } fn on\_http\_request\_body(&mut self, \_body\_size: usize, \_end\_of\_stream: bool) -> Action { Action::Continue } fn on\_http\_response\_headers(&mut self, \_num\_headers: usize, \_end\_of\_stream: bool) -> Action { Action::Continue } fn on\_http\_response\_body(&mut self, \_body\_size: usize, \_end\_of\_stream: bool) -> Action { Action::Continue } } struct HttpConfigHeaderRoot { header\_content: String, } impl Context for HttpConfigHeaderRoot {} impl RootContext for HttpConfigHeaderRoot { fn on\_configure(&mut self, \_: usize) -> bool { if let Some(config\_bytes) = self.get\_plugin\_configuration() { self.header\_content = String::from\_utf8(config\_bytes).unwrap() } true } fn create\_http\_context(&self, \_: u32) -> Option> { Some(Box::new(HttpConfigHeader { header\_content: self.header\_content.clone(), })) } fn get\_type(&self) -> Option { Some(ContextType::HttpContext) } } ## [](#カスタム認証ヘッダーポリシーの例)カスタム認証ヘッダーポリシーの例 次のチュートリアルでは、すでに Exchange にパブリッシュされている​[ポリシー定義](https://docs.mulesoft.com/jp/gateway/1.9/policies-custom-flex-getting-started#create-policy-definition-files)​のポリシー実装の例を作成する方法を示しています。 このポリシー例では、​`x-custom-auth`​ ヘッダーがユーザー設定の値と一致しない要求をブロックしています。 ポリシー開発プロセスは、以下のステップで行います。 1. ポリシー定義 JSON ファイルを作成する。 2. プロジェクトをセットアップする。 3. カスタムポリシーを開発する。 ### [](#ポリシー定義-json-ファイルの作成)ポリシー定義 JSON ファイルの作成 ポリシー実装例では、ポリシー定義 JSON ファイルが必要です。Flex Gateway は、ポリシー設定をポリシー定義構造と一緒に JSON として Envoy WASM 検索条件に渡します。 認証ヘッダーポリシーの例には、ヘッダーで渡す必要のある値のパラメーターのみを使用しています。ポリシー定義 JSON ファイルは次の内容と一致している必要があります。 { "title": "Custom Auth Header", "type": "object", "description": "Enforces HTTP authentication matching x-custom-auth value to what is configured in the policy.", "properties": { "secret-value": { "title": "Custom Auth Header Password", "type": "string", "@context": { "@characteristics": \[ "security:sensitive" \] } } }, "required": \[ "secret-value" \], "unevaluatedProperties": false, "@context": { "@vocab": "anypoint://vocabulary/policy.yaml#", "security": "anypoint://vocabulary/policy.yaml#" }, "$id": "custom-auth-header-simple", "$schema": "https://json-schema.org/draft/2019-09/schema" } ### [](#プロジェクトのセットアップ)プロジェクトのセットアップ 1. 次のコマンドで Rust プロジェクトを作成します。 cargo new flex\_custom\_policy\_example --lib これにより ​`flex_custom_policy_example`​ ディレクトリが作成されます。 2. 次のコンテンツを ​`flex_custom_policy_example`​ ディレクトリの ​`Cargo.toml`​ にコピーします。 \[package\] name = "flex\_custom\_policy\_example" version = "0.1.0" edition = "2021" # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html \[lib\] crate-type = \["cdylib"\] name="flex\_custom\_policy\_example" path="src/lib.rs" \[dependencies\] proxy-wasm = { git = "https://github.com/proxy-wasm/proxy-wasm-rust-sdk.git", tag = "v0.2.0" } serde = { version = "1.0", features = \["derive"\] } serde\_json = "1.0" \[profile.release\] opt-level = "z" lto = "fat" ### [](#カスタムポリシーの開発)カスタムポリシーの開発 1. 次のポリシーブートストラップコードを新しい Rust ソースファイルに追加します。 use proxy\_wasm::traits::\*; use proxy\_wasm::types::\*; use serde::Deserialize; proxy\_wasm::main! {{ proxy\_wasm::set\_log\_level(LogLevel::Trace); proxy\_wasm::set\_root\_context(|\_| -> Box { Box::new(CustomAuthRootContext { config: CustomAuthConfig::default(), }) }); }} このコードは、WASM 検索条件を Envoy にデプロイするために必要です。​`main`​ ブロックは、ルートコンテキストを設定します。このルートコンテキストは、受け取った各 HTTP 要求に対して子コンテキストを生成するために使用する Envoy エンティティです。 2. 次のルートコンテキスト実装コードを追加します。 struct CustomAuthRootContext { config: CustomAuthConfig, } impl Context for CustomAuthRootContext {} impl RootContext for CustomAuthRootContext { fn create\_http\_context(&self, \_: u32) -> Option> { Some(Box::new(CustomAuthHttpContext { config: self.config.clone(), })) } fn get\_type(&self) -> Option { Some(ContextType::HttpContext) } } 各 Envoy 検索条件は、ルートコンテキスト実装を提供するために必要です。​`RootContext`​ trait には、実装可能な便利なメソッドが含まれています。この例では、Envoy が子コンテキストを生成できるように、HTTP 検索条件は ​`create_http_context`​ と ​`get_type`​ を実装しています。 3. 次の ​`Struct`​ を追加して、この JSON の解析を有効にします。 #\[derive(Default, Clone, Deserialize)\] struct CustomAuthConfig { #\[serde(alias = "secret-value")\] secret\_value: String, } Flex Gateway は、ポリシー定義で指定されている JSON を使用してポリシーを設定します。解析が必要な JSON には ​`secret-value`​ という項目が 1 つあります。 4. 設定を非シリアル化します。 基本的なポリシー設定構造を作成したら、逆シリアル化するために ​`RootContext` ​`on_configure`​ メソッドを実装する必要があります。 `CustomAuthRootContext`​ の ​`RootContext`​ の実装内で、次のスニペットのように ​`on_configure`​ メソッドを追加します。 impl RootContext for CustomAuthRootContext { fn on\_configure(&mut self, \_: usize) -> bool { if let Some(config\_bytes) = self.get\_plugin\_configuration() { self.config = serde\_json::from\_slice(config\_bytes.as\_slice()).unwrap(); } true } // Other implemented methods // ... } 5. 次の HTTP コンテキストコードを追加します。 struct CustomAuthHttpContext { pub config: CustomAuthConfig, } impl Context for CustomAuthHttpContext {} impl HttpContext for CustomAuthHttpContext {} 受け取った各要求によって新しい ​`CustomAuthHttpContext`​ が作成されます。この ​`CustomAuthHttpContext`​ は、HTTP 要求が有効である間は有効です。これにより (要求間の状態データではなく) 要求に関連した状態データを格納できます。 6. 次のコアポリシー機能ロジックを追加します。 impl HttpContext for CustomAuthHttpContext { fn on\_http\_request\_headers(&mut self, \_num\_headers: usize, \_end\_of\_stream: bool) -> Action { if let Some(value) = self.get\_http\_request\_header("x-custom-auth") { if self.config.secret\_value == value { return Action::Continue; } } self.send\_http\_response(401, Vec::new(), None); Action::Pause } } `proxy-wasm`​ ABI は、受け取ったリクエストヘッダー値を取得して、値を ​`secret-value`​ と比較します。​`secret-value`​ がヘッダーと一致すると、実装は ​`Action::Continue`​ を返します。そうでない場合は ​`Action::Pause`​ を返し、検索条件自身が ​`send_http_response`​ を使用して呼び出し側のクライアントに応答を返します。 注意: Rust SDK には、​`get_http_request_header`​ を使用した非 UTF-8 値の読み込みの問題があります。この問題を回避するには、​`get_http_request_headers_bytes`​ メソッドを使用し、​`from_utf8` [メソッド](https://doc.rust-lang.org/std/string/struct.String.html#method.from_utf8)​を使用してバイトを読み取ります。次に例を示します。 let header = self.get\_http\_request\_header\_bytes("x-custom-auth").map(String::from\_utf8).and\_then(Result::ok); 7. `wasm32`​ をターゲットとして追加して、コンパイルを有効にします。 rustup target add wasm32-wasi ポリシーに含まれるすべてのサードパーティライブラリは、​`wasm32-wasi`​ Rust コンパイルターゲットと互換性がある必要があります。

一部のライブラリは wasm32-wasi ターゲットと適切に互換性があっても、Flex Gateway にデプロイすると適切に動作しないことがあります。この状況が発生した場合のデプロイメントエラーの例は次のとおりです。

  • Failed to load Wasm module due to a missing import (インポートが欠落しているため Wasm モジュールの読み込みに失敗しました)

  • Wasm VM failed to initialize Wasm code (Wasm VM が Wasm コードの初期化に失敗しました)

  • Plugin configured to fail closed failed to load (フェールクローズに設定されたプラグインの読み込みに失敗しました)

これらの問題を解決するには、サードパーティライブラリのオーナーに問い合わせるか、別のライブラリを使用してください。
8. 次のコマンドでカスタムポリシーをコンパイルします。 cargo build --target wasm32-wasi --release コンパイルにより、バイナリ ​`.wasm`​ ファイルが ​`./target/wasm32-wasi/release`​ ディレクトリに出力されます。 Exchange へのカスタムポリシーのパブリッシュついての詳細は、​[「Flex Gateway または Mule 4 カスタムポリシーのパブリッシュ」](https://docs.mulesoft.com/jp/gateway/1.9/policies-custom-flex-getting-started)​を参照してください。