--- schema_version: "1" id: 3766c2a23247330fa08c798dfc4b120094a4c147f0516de057488761bccb24a2 title: 時間ベースのアグリゲーターの例 collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/aggregators-module/latest/aggregators-time-example.md canonical_url: https://docs.mulesoft.com/jp/aggregators-module/latest/aggregators-time-example source_site: docs.mulesoft.com content_type: documentation content_hash: 6fb02c5b37266534d3840589e23c34be2e165ee6ede32a6fcf44e815638f86a1 description: MuleSoft Documentation Site release: "1.1" latest: true --- # 時間ベースのアグリゲーターの例 Aggregators Module の ​**\[Time based aggregator (時間ベースのアグリゲーター)\]**​ スコープを使用すると、定義済みの時間制限内で要素を集約することができます。次の例は、​`5`​ 秒間の HTTP 要求コールを集約するようにこのスコープを設定する方法を示しています。アプリケーションは DataWeave を使用して、ランダム ID 番号で各コールのペイロードを設定します。集約が ​`5`​ 秒に達すると、​**\[Aggregator listener (アグリゲーターリスナー)\]**​ ソースは要素のリストを取得し、アプリケーションはすべての集約されたランダム ID 番号を記録します。 ![Anypoint Studio キャンバスでの時間ベースのアグリゲーターのフローの例](/mulesoft/current/ja-jp/aggregators-module/latest/_images/aggregator-time-example.png) Figure 1. 時間ベースのアグリゲーターのフローの例 独自の環境でこの例をテストするには、Mule アプリケーションを作成し、curl コマンドを使用してアプリケーションを実行する必要があります。 ## [](#mule-アプリケーションの作成)Mule アプリケーションの作成 Anypoint Studio で Mule フローを作成する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[HTTP Listener (HTTP リスナー)\]**​ を選択してキャンバスにドラッグします。 このソースは受信 HTTP メッセージ属性をリスンすることでフローを開始します。 2. **\[Connector configuration (コネクタ設定)\]**​ で ​**\[HTTP\_Listener\_config\]**​ を選択します。 3. **\[Path (パス)\]**​ を ​`/test`​ に設定します。 4. **\[Transform message\]**​ コンポーネントを ​**\[Listener\]**​ の右にドラッグします。 5. **\[Transform message\]**​ コンポーネントの DataSense プレビューウィンドウで、次の DataWeave 式を追加します。これにより、各 HTTP 要求のペイロードに ​`Source Name`​ が ​`"time-based"`​ として設定され、​`Source ID`​ が ​`random() as String`​ として設定されます。 ```DataWeave %dw 2.0 output application/json --- { "Source Name": "time-based", "Source ID": (random() as String) } ``` 6. **\[Time based aggregator (時間ベースのアグリゲーター)\]**​ スコープを ​**\[Transform message\]**​ の右にドラッグします。 7. **\[名前\]**​ を ​`timeBasedAggregator`​ に設定します。 8. **\[Period (期間)\]**​ を ​`5`​ に設定します。 9. **\[Period unit (期間単位)\]**​ を ​`SECONDS(Default)`​ に設定します。 10. **\[Content (コンテンツ)\]**​ を ​`payload`​ に設定します。これは、何を集約するか (この場合は変換された HTTP 要求) を定義する式です。 11. **\[Logger\]**​ コンポーネントを ​**\[Incremental aggregation (増分集約)\]**​ ルートにドラッグします。 12. **\[Logger\]**​ 設定画面で、​**\[Message (メッセージ)\]**​ を ​`Doing incremental step.`​ に設定します。 13. **\[Aggregator listener (アグリゲーターリスナー)\]**​ ソースを最初のフローの下にドラッグします。 このソースは、前に定義された時間ベースのアグリゲーターをリスンします。このアグリゲーターがその要素を解放すると、リスナーが実行されます。 14. **\[Aggregator name (アグリゲーター名)\]**​ を ​`timeBasedAggregator`​ に設定します。 15. **\[Logger\]**​ コンポーネントを ​**\[Aggregator listener (アグリゲーターリスナー)\]**​ の右にドラッグします 16. **\[Message (メッセージ)\]**​ を ​`Aggregation complete`​ に設定します。 17. 別の ​**\[Logger\]**​ コンポーネントを、前に追加した ​**\[Logger\]**​ コンポーネントの右にドラッグします。 18. **\[Message (メッセージ)\]**​ を次の式に設定します。この式では、すべての集約された要素が返されます。 ```xml output application/json --- payload ``` 19. プロジェクトを保存します。 20. **Package Explorer**​ で、​**\[Run (実行)\] > \[Run As (別のユーザーとして実行)\] > \[Mule Application (Mule アプリケーション)\]**​ をクリックします。 21. `5`​ 秒以内に次の curl コマンドを 2 回送信して、アプリケーションをテストします。 `curl -X POST [http://localhost:8086/test](http://localhost:8086/test)`​ これにより、​**\[Time based aggregator (時間ベースのアグリゲーター)\]**​ で処理する 2 個の HTTP 要求が生成されます。 22. **\[Console (コンソール)\]**​ ビューに移動して、ロガーメッセージを参照します。 ```none INFO 2021-06-09 12:02:04,203 [[MuleRuntime].uber.04: [aggregator-time-demo].aggregator-time-demoFlow.CPU_INTENSIVE @59b15997] [processor: aggregator-time-demoFlow/processors/1/route/0/processors/0; event: a6b00280-c933-11eb-a825-f01898ad2638] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: Doing incremental step. INFO 2021-06-09 12:02:06,071 [[MuleRuntime].uber.04: [aggregator-time-demo].aggregator-time-demoFlow.CPU_INTENSIVE @59b15997] [processor: aggregator-time-demoFlow/processors/1/route/0/processors/0; event: a7cd0b40-c933-11eb-a825-f01898ad2638] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: Doing incremental step. INFO 2021-06-09 12:02:09,206 [[MuleRuntime].uber.04: [aggregator-time-demo].aggregator-time-demoOnCompleteFlow.CPU_LITE @2ab3c271] [processor: aggregator-time-demoOnCompleteFlow/processors/0; event: 827c9591-c933-11eb-a825-f01898ad2638] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: Aggregation complete INFO 2021-06-09 12:02:09,208 [[MuleRuntime].uber.04: [aggregator-time-demo].aggregator-time-demoOnCompleteFlow.CPU_LITE @2ab3c271] [processor: aggregator-time-demoOnCompleteFlow/processors/1; event: 827c9591-c933-11eb-a825-f01898ad2638] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: [ { "Source Name": "time-based", "Source ID": "0.7095971146328517" }, { "Source Name": "time-based", "Source ID": "0.6900116288202388" } ] ``` このロガーメッセージの例は、各 HTTP 要求で、​**\[Incremental aggregator (増分アグリゲーター)\]**​ ルートの ​**\[Logger\]**​ コンポーネントによってメッセージ ​`Doing incremental step`​ が記録されることを示しています。​**\[Aggregator listener (アグリゲーターリスナー)\]**​ ソースによって参照される ​`timeBasedAggregator`​ 値が ​`5`​ 秒以内に増分集計を完了すると、すべての要素のリストを使用してリスナーがトリガーされます。後続の ​**\[Logger\]**​ コンポーネントによってメッセージ ​`Aggregation complete`​ が記録され、2 番目の ​**\[Logger\]**​ コンポーネントによって、集約されたペイロード要素 (ランダム ID 番号) が返されます。 ```none { "Source Name": "time-based", "Source ID": "0.7095971146328517" }, { "Source Name": "time-based", "Source ID": "0.6900116288202388" } ``` ## [](#時間ベースのアグリゲーターの例の-xml)時間ベースのアグリゲーターの例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ## [](#関連情報)関連情報 - [Aggregators Module の例](https://docs.mulesoft.com/jp/aggregators-module/latest/aggregators-examples) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)