--- url: 'https://docs.workato.com/ja/features/file-streaming.md' description: Workatoのファイルストリーミングが大容量ファイルをアプリ間でチャンク単位で転送し、転送元と転送先のメモリ制限内に収める方法について説明します。 --- # ファイルストリーミング {: #file-streaming :} ファイルストリーミングは、大きなファイルを小さな部分に分割し、1つずつ転送してから、それらの部分を順番どおりに戻すことで処理する手法です。 たとえば、Workatoがファイルストリーミングを使用してシステム間でファイルを転送する場合、各部分はソースからダウンロードされ、順番に宛先へアップロードされます。 ファイルストリーミングは、ソースまたは宛先アプリのサイズやメモリの制限により、大きなファイルの処理が実用的でない場合や不可能な場合に役立ちます。 ファイルストリーミングでは、Workatoが小さなチャンクを1つずつ処理するため、各アプリの制約内に収めることができます。 これにより、Workatoはストリーミングをサポートするアプリ間で、任意のサイズのファイルを転送できます。 Workatoは、大容量ストレージとデータ変換のためのファイルストリーミングもサポートしています。 次の図は、ファイルストリーミングの仕組みを示しています。 ![ファイルストリーミングの仕組み](/images/features/file-streaming/streaming-illustration.jpg) *ファイルストリーミングの仕組み* ## ユースケース {: #use-cases :} Workatoのファイルストリーミングは、次のようなユースケースで使用できます。 * アプリケーションにデータを一括送信 * 一括トリガーまたは一括アクションを使用してアプリケーションからデータを受信 * 大きなファイルを[Workato FileStorage](/ja/features/workato-filestorage.md)、または[SFTP](/ja/connectors/sftp.md)や[S3](/ja/connectors/s3.md)などの他のファイルシステムに保存する * [SQL Transformations](/ja/features/sql-transformations.md)との間でデータを送受信する たとえば、ファイルストリーミングでは次のことができます。 * オンブレミスファイルサーバーから100万行のリードデータを含むファイルを抽出し、Google BigQueryテーブルにロードする * バッチアクションを使用して、HubSpotなどの非ストリーミングソースからWorkato FileStorageに100,000行を蓄積し、その後FileStorageから[Salesforce bulk APIs](/ja/connectors/salesforce/salesforce-bulk.md)へ行を一度にストリーミングする * 一括トリガーを使用して[Marketo](/ja/connectors/marketo.md)から新規または更新された取引先責任者レコードを抽出し、[SQL Transformations](/ja/features/sql-transformations.md)で他のデータソースと集計する ### バッチ処理との比較 {: #comparison-with-batch-processing :} バッチ処理とは、複数のジョブがそれぞれ複数のレコードを処理することです。 1つのジョブで処理できるレコード数は、バッチサイズによって決まります。 Workatoは、関連するすべてのレコードを処理するために必要な数のジョブを作成するため、非常に大きなファイルを処理できます。 ただし、バッチサイズとメモリの制限により、この方法では大量のAPIコールが発生する可能性があり、データ量が増えるにつれて十分にスケールしません。 これに対し、ファイルストリーミングでは、1つのジョブを使用して、関連するすべてのレコードをストリーミングAPIへの1回の呼び出しでチャンクごとに処理します。 これにより、ファイルが非常に大きい場合でも、APIコールが少なくなり、処理が速くなります。 バッチトリガーおよびアクションは通常、他のバッチアクションと組み合わせる必要があります。 同様に、ストリーミング対応のデータプロデューサー（ファイルダウンロード、一括トリガー、一括エクスポートアクションなど）は、ストリーミング対応のデータコンシューマー（ファイルアップロード、一括作成、一括アップサート、一括インポートアクションなど）と組み合わせる必要があります。 :::info HTTPコネクターの例外 [Send request via HTTP](/ja/developing-connectors/http/building-http-action.md)アクションは、このルールの例外です。 [**Wait for response**](/ja/developing-connectors/http/building-http-action.md#configure-http-action-as-a-long-action)と[**Enable streaming**](/ja/developing-connectors/http/building-http-action.md#stream-http-responses)を**Yes**に設定すると、ファイルストリーミングをサポートしないアクションを含む、後続の任意のアクションにレスポンスをストリーミングできます。 ::: 可能な場合は、ファイルストリーミングをサポートするトリガーとアクションを使用して、次のことに役立てることをおすすめします。 * レシピ設計を簡素化 * タスク数を削減 * ソースと宛先の間で行われるAPIコール数を削減 ## ファイルストリーミングの使用方法 {: #how-to-use-file-streaming :} ソース（ファイルダウンロード、一括トリガー、一括アクションなど）または宛先（ファイルアップロードや一括アクションなど）のいずれかがファイルストリーミングをサポートしている場合、ファイルコンテンツまたはCSVコンテンツデータピルを**ファイルコンテンツ**入力フィールドに渡すと、Workatoはファイルストリーミングを自動的に開始します。 レシピで追加の設定は必要ありません。 ![ファイルコンテンツデータピルをファイルコンテンツ入力フィールドに渡す](/images/features/file-streaming/file-contents-datapill.png) *ファイルコンテンツデータピルを**ファイルコンテンツ**入力フィールドに渡す* ストリーミング転送は、レシピがレシピ内のコンシューマーアクションステップに到達したときに開始されることに注意してください。 ファイルストリーミングアクションは通常、[長時間または遅延アクション](/ja/recipes/long-actions.md)です。 そのため、転送にどれだけ時間がかかっても、ストリーミングアクションはタイムアウトしません。 ## ファイルストリーミングをサポートするトリガーとアクション {: #triggers-and-actions-that-support-file-streaming :} 次の表に、ファイルストリーミングをサポートするトリガーとアクションを示します。 | コネクター名 | ファイルストリーミングをサポートするトリガーとアクション | | ---------------------------------------------------------------------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ | | [Adobe Experience Manager](/ja/connectors/adobe_experience_manager.md) | ストリーミングによるアセットのアップロードアクション | | [Amazon S3](/ja/connectors/s3.md) | ファイルコンテンツのダウンロードアクションファイルのアップロード（ストリーミング）アクション新規ファイルトリガー新規または更新されたファイルまたはフォルダトリガー | | Anaplan | ファイルのダウンロードアクションダンプファイルのダウンロードアクションファイルのアップロードアクション | | [Azure Blob Storage](/ja/connectors/azure_blob_storage.md) | BLOBコンテンツのダウンロードアクションBLOBのアップロードアクション | | [BIM360](/ja/connectors/bim360.md) | プロジェクト内のドキュメントのダウンロードアクションプロジェクトへのドキュメントのアップロードアクション | | [Box](/ja/connectors/box.md) | ファイルのダウンロードアクションファイルコンテンツを使用したファイルのアップロードアクション | | [Bynder](/ja/connectors/bynder.md) | アセットのアップロードアクションアセットのダウンロードアクション | | [Dropbox](/ja/connectors/dropbox.md) | ファイルコンテンツを使用したファイルのアップロードアクション | | [Egnyte](/ja/connectors/egnyte.md) | 選択したフォルダからのファイルのダウンロードアクションファイルのアップロードアクション | | [ファイルツール by Workato](/ja/features/file-tools-by-workato.md) | URLからのファイル取得アクションファイルの圧縮アクション | | [Freshdesk](/ja/connectors/freshdesk.md) | チケット添付ファイルの取得アクション | | [FTP/FTPS](/ja/connectors/ftp.md) | 大きなファイルのダウンロードアクションファイルのアップロードアクション | | [HTTPコネクター](/ja/developing-connectors/http/building-http-action.md) | HTTP経由でリクエストを送信アクション（**Wait for response**と**Enable streaming**の両方を**Yes**に設定する必要があります）。 ストリーミングされたレスポンスは、ファイルストリーミングをサポートしないアクションを含む、後続の任意のアクションに渡すことができます。 | | [Google Cloud Storage](/ja/connectors/google_cloud_storage.md) | オブジェクトのダウンロードアクションオブジェクトのアップロードアクション | | [Google Drive](/ja/connectors/google-drive.md) | ファイルのダウンロードアクションファイルのアップロードアクションフォルダ階層内の新規ファイルまたはフォルダトリガー新規ファイルまたはフォルダトリガー | | [Jira](/ja/connectors/jira.md) | Jiraの新規課題のエクスポートトリガーJiraの新規または更新された課題のエクスポートトリガー | | [Marketo](/ja/connectors/marketo.md) | Marketoの新規リードのエクスポートトリガーMarketoの新規または更新されたリードのエクスポートトリガー | | [Microsoft Dynamics 365](/ja/connectors/dynamics-crm.md) | 新規レコードのエクスポートトリガー新規または更新されたレコードのエクスポートトリガー | | [Microsoft Sharepoint](/ja/connectors/sharepoint.md) | ライブラリ内のファイルのアップロードアクション | | [NetSuite](/ja/connectors/netsuite.md) | 新規レコードのエクスポートトリガー新規または更新されたレコードのエクスポートトリガー | | [OneDrive](/ja/connectors/onedrive.md) | ファイルのダウンロードアクションセッション経由での大きなファイルのアップロードアクション | | [On-prem](/ja/connectors/on-prem-files.md) | ファイルのダウンロードアクションファイルのアップロードアクションファイルのアップロード（レガシー）アクションフォルダ内の新規ファイルトリガー | | [Outlook](/ja/connectors/outlook/outlook.md) | メールの送信アクション | | [Percolate](/ja/connectors/percolate.md) | アセットのダウンロードアクション | | [PlanGrid](/ja/connectors/plangrid.md) | オブジェクトのダウンロードアクション | | [Quickbase](/ja/connectors/quickbase.md) | CSVファイルからのレコードの一括作成および更新アクション | | [Salesforce](/ja/connectors/salesforce.md) | ファイルのアップロードアクション | | [ServiceNow](/ja/connectors/servicenow.md) | 添付ファイルのアップロードアクション添付ファイルコンテンツの取得アクション 新規レコードのエクスポートトリガー新規または更新されたレコードのエクスポートトリガー | | [SFTP](/ja/connectors/sftp.md) | ファイルのダウンロードアクションファイルのアップロードアクション | | [SMB](/ja/connectors/smb.md) | ファイルのダウンロードアクションファイルのアップロードアクション | | [Workato FileStorage](/ja/features/workato-filestorage.md) | ファイルコンテンツの取得アクション新規ファイルトリガー | | [Workfront](/ja/connectors/workfront.md) | ドキュメントのダウンロードアクション | | [Zoom](/ja/connectors/zoom.md) | クラウド録画のダウンロードアクション | :::info カスタムコネクターの構築 ファイルストリーミングを使用するカスタムコネクターの構築方法については、[Connector SDKファイルストリーミングガイド](/ja/developing-connectors/sdk/guides/building-actions/streaming.md)を参照してください。 ::: :::tip ファイルストリーミングの動作を確認 ファイルストリーミングを使用してオンブレミスファイルシステムからAmazon S3へファイルを転送する[サンプルレシピ](https://www.workato.com/recipes/867852#recipe)を表示します。 :::