1. Homepage
  2. DataWeave (2.2)
  3. 言語ガイド

  4. DataWeave で使用可能な外部関数

DataWeave で使用可能な外部関数

DataWeave 2.2 は Mule 4.2 と互換性があり、Mule 4.2 にバンドルされています。 このバージョンの Mule は、拡張サポートが終了する 2023 年 5 月 2 日にその すべてのサポート​が終了しました。

このバージョンの Mule を使用する CloudHub には新しいアプリケーションをデプロイできなくなります。許可されるのはアプリケーションへのインプレース更新のみになります。

標準サポートが適用されている最新バージョンの Mule 4 にアップグレード​することをお勧めします。これにより、最新の修正とセキュリティ機能強化を備えたアプリケーションが実行されます。

組み込み DataWeave 関数に加えて Mule Runtime と一部のモジュール、コネクタ、およびコアコンポーネントには、DataWeave スクリプトで使用できる関数が用意されています。この関数は、その関数を提供するモジュール、コネクタ、およびコンポーネントに固有のものです。 開始する前に、DataWeave バージョン 2 は Mule 4 アプリケーションを対象とすることに注意してください。Mule 3 アプリケーションの場合、Mule 3.9 ドキュメントの ​DataWeave 1.0 ドキュメントセット​を参照してください。他の Mule バージョンの場合は、Mule Runtime の目次のバージョンセレクターを使用できます。

Mule Runtime 関数

以下の関数は Mule Runtime により挿入されています。

  • p​

  • lookup​

  • causedBy

Mule 4.1.4 以降、DataWeave は Mule Runtime 関数を Mule 関数モジュールに組み込みました。

Mule Runtime 4.1.4 以降で実行する Mule アプリケーションでこれらの関数を使用する場合、まず ​Mule​ 名前空間を使用することをお勧めします。これを使用するには、関数名の先頭に名前空間を追加するだけです。たとえば、​p('http:port')​ ではなく ​Mule::p('http:port')​ のようにします。

DataWeave スクリプトとマッピングでの Mule Runtime 関数の使用が継続的にサポートされることに加えて、Mule モジュールを使用すると、​カスタム DataWeave モジュール​で Mule Runtime 関数を使用することもできます。

バージョン 4.1.4 ​よりも前​の Mule Runtime バージョンで実行する Mule アプリケーションでは、DataWeave スクリプトおよびマッピング内に限って、​Mule​ 名前空間を使用したり、カスタムモジュールで Mule Runtime 関数を使用したりできません。

プロパティの割り当て (p 関数)

p​ 関数は、以下のプロパティへのアクセスを提供します。

  • Mule プロパティのプレースホルダー

  • システムプロパティ

  • 環境プロパティ

プロパティの設定および処理方法についての詳細は、​「プロパティの設定」​を参照してください。

次の例では、プロパティ ​http.port​ の値を記録します。

例: Mule 4.1.4 以降のプロパティ関数の使用方法
<flow name="simple">
  <logger level="INFO" doc:name="Logger"
    message="#[Mule::p('http.port')]"/>
</flow>

DataWeave 変数または関数を定義する場合も関数を使用できます。この例では、​p​ 関数を ​myVar​ 定義内で使用します。 4.1.4 よりも前のランタイムでは、​Mule::​ 名前空間を省略するだけでこれと同様の処理を実行できます。

<flow name="simple">
  <logger level="INFO" doc:name="Logger"
    message="#[var myVar = Mule::p('http.port') --- myVar]"/>
</flow>
例: Mule 4.1.3 以前のプロパティ関数の使用方法
<flow name="simple">
  <logger message="#[p('http.port')]"/>
</flow>

Mule 4.2 の Mule 関数モジュールで導入された ​p​ 関数も参照してください。

フローの実行 (lookup 関数)

Flow Reference コンポーネントと同様に、​lookup​ 関数を使用すると、アプリケーション内で別のフローを実行し、結果のペイロードを取得できます。これは、フローの名前と入力ペイロードをパラメーターとして使用します。たとえば、​lookup("anotherFlow", payload)​ は、​anotherFlow​ という名前のフローを実行します。

この関数は、現在の属性、変数、エラーを使用して、指定されたフローを実行しますが、属性または変数を含まないペイロードを渡すのみです。同様に、コールされたフローはそのペイロードを返すのみです。

lookup​ 関数では、サブフローのコールはサポートされません。

パラメーター

名前 説明

​flowName

対象フローを識別する文字列。

​payload

対象フローに送信するペイロード。任意 (​Any​) 型を使用できます。

​timeoutMillis

省略可能。対象フローの実行のタイムアウト (ミリ秒)。実行しているスレッドが ​CPU_LIGHT​ または ​CPU_INTENSIVE​ の場合、デフォルトの ​2000​ ミリ秒 (2 秒) に設定され、他のスレッドから実行している場合は 1 分に設定されます。lookup の実行に、指定された ​timeoutMillis​ 値よりも長い時間がかかっている場合、エラーが発生します。

次の例は、2 つのフローの XML を示しています。​flow1​ の ​lookup​ 関数は ​flow2​ を実行し、オブジェクト ​{test:'hello '}​ をそのペイロードとして ​flow2​ に渡します。次に、​flow2​ の Set Payload コンポーネント (​<set-payload/>​) は ​{test:'hello '}​ の値を文字列 ​world​ と連結し、​hello world​ を出力して記録します。

例: Mule 4.1.4 以降の ​lookup​ 関数の使用方法
<flow name="flow1">
  <http:listener doc:name="Listener" config-ref="HTTP_Listener_config"
    path="/source"/>
  <ee:transform doc:name="Transform Message" >
    <ee:message >
      <ee:set-payload ><![CDATA[%dw 2.0
output application/json
---
Mule::lookup('flow2', {test:'hello '})]]></ee:set-payload>
    </ee:message>
  </ee:transform>
</flow>
<flow name="flow2" >
  <set-payload value='#[payload.test ++ "world"]' doc:name="Set Payload" />
  <logger level="INFO" doc:name="Logger" message='#[payload]'/>
</flow>
例: Mule 4.1.3 以前の ​lookup​ 関数の使用方法
<flow name="flow1">
  <http:listener doc:name="Listener" config-ref="HTTP_Listener_config"
    path="/source"/>
  <ee:transform doc:name="Transform Message" >
    <ee:message >
      <ee:set-payload ><![CDATA[%dw 2.0
output application/json
---
lookup('flow2', {test:'hello '})]]></ee:set-payload>
    </ee:message>
  </ee:transform>
</flow>
<flow name="flow2" >
  <set-payload value='#[payload.test ++ "world"]' doc:name="Set Payload" />
  <logger level="INFO" doc:name="Logger" message='#[payload]'/>
</flow>
出力
hello world

DataWeave のような関数型言語では、​lookup​ 関数の呼び出しに副作用が​ない​ことが期待されることを常に覚えておくことが重要です。 このため、DataWeave エンジン内部の動作により、​lookup​ 関数が他の ​lookup​ と並行して呼び出されたり、何も呼び出されなかったりすることがあります。

Flow Ref (​flow-ref​) コンポーネントを使用してフローを呼び出して、​target​ 属性を使用してフローの結果を ​var​ に配置し、その ​var​ を DataWeave スクリプト内から参照することをお勧めします。

種別によるエラーの一致 (causedBy 関数)

causedBy​ 関数は、エラーハンドラーのように、エラーをその種別によって一致させます。これは、上位の種別による一致だけでなく特定のサブ種別のロジックも必要な場合や、異なる種別の子エラーを含む ​COMPOSITE_ROUTING​ エラーを処理する場合に役立ちます。

一致させるエラーは暗黙的に示すことはできますが、種別は常に必須パラメーターです。

次の例では、​SECURITY​ エラーを一般的な方法で処理するようにグローバルエラーハンドラーがセットアップされていますが、​HTTP:UNAUTHORIZED​ と ​HTTP:FORBIDDEN​ のエラーについては特定のアクションがセットアップされています。

例: Mule Runtime バージョン 4.1.4 以降のエラーマッチャー関数の使用方法
<error-handler name="securityHandler">
  <on-error-continue type="SECURITY">
    <!-- general error handling for all SECURITY errors -->
    <choice>
      <when expression="#[error Mule::causedBy 'HTTP:UNAUTHORIZED']">
        <!-- specific error handling only for HTTP:UNAUTHORIZED errors -->
      </when>
      <when expression="#[Mule::causedBy('HTTP:FORBIDDEN')]">
        <!-- specific error handling only for HTTP:FORBIDDEN errors -->
      </when>
    </choice>
  </on-error-continue>
</error-handler>
例: Mule Runtime バージョン 4.1.3 以前のエラーマッチャー関数の使用方法
<error-handler name="securityHandler">
  <on-error-continue type="SECURITY">
    <!-- general error handling for all SECURITY errors -->
    <choice>
      <when expression="#[error causedBy 'HTTP:UNAUTHORIZED']">
        <!-- specific error handling only for HTTP:UNAUTHORIZED errors -->
      </when>
      <when expression="#[causedBy('HTTP:FORBIDDEN')]">
        <!-- specific error handling only for HTTP:FORBIDDEN errors -->
      </when>
    </choice>
  </on-error-continue>
</error-handler>

エラーパラメーターは明示的にも暗黙的にも使用されます。

コネクタおよびコンポーネント関数

Mule アプリケーションでコネクタとコンポーネントを使用する場合、関数を挿入できます。 Runtime 関数とは異なり、この関数には名前空間が必要であり、通常、この名前空間はコンポーネント名に一致します。

たとえば、Batch を使用するアプリケーションでは、​#[Batch::isSuccessfulRecord()]​ 式を使用できます。

関連情報

DataWeave Core 関数​

DataWeave 型​

DataWeave セレクター