# サンプルユースケース - データの拡張
ソースから抽出したデータを送信先に送る前に、しばしば1つまたは複数のソースから追加情報でデータを拡張する必要があります。データのボリュームが増えると、データを一時的に保存して拡張し、それから送信先にロードすることが困難になります。
SQL変換を使用すると、ユーザーは任意の数のデータソースをパイプライン化し、大量のデータを簡単に処理できます。ユーザーはSQLの結合操作を使用してファイル間でデータをマージ/集計し、受信データに追加情報を付加し、リアルタイムで操作を行い、任意の送信先に送信するか、Workato FileStorage内に保存することができます。
# サンプルレシピ：Salesforceから機会を取得し、取得したデータを拡張してSFTPサーバーに送信する
次のシナリオを考えてみましょう：
会社はSalesforceからすべての機会情報を一括で抽出し、コスト、価格、特定の地域の詳細などの追加製品情報で拡張し、拡張されたデータを外部SFTPサーバーのパートナーファイルシステムに送信する必要があります。
SQL変換を使用すると、これらの複雑なプロセスをたった5つのステップで簡単に実行できます！
指定した頻度で実行されるスケジューラトリガーを設定します。
Salesforceで必要なすべての機会レコードを一括でCSVコンテンツとして取得するための一括アクションを設定します。
拡張に使用するデータがGoogleドライブなどの異なるソースで利用可能な場合は、ダウンロードアクションを使用してそれらのコンテンツを取得します。
SQL変換コネクタのQuery CSVアクションを設定します。このステップでは、さまざまなソースからのデータをパイプライン化し、追加データで機会を拡張するクエリを作成できます。
最後のステップでは、Workatoがデータを送信先であるSFTPサーバーに送信します。
# データの拡張にSQL変換を活用する方法
このセクションでは、データの拡張にSQL変換を活用するために、Query CSVアクションのさまざまなセクションの設定方法について説明します。
一緒に進める
このレシピリンクを参照して、サンプルレシピを変更して独自のワークフローに合わせる方法を確認してください。
# データソースの設定
SQL変換がクエリを実行する異なるデータソースを接続します。この例では、3つの異なるデータソースがあります。
ソース #1に接続するには、次のフィールドに入力します。この例では、ソース #1はオンプレミスシステムからの入力抽出です。
データソース名
データソース名に意味のある名前を指定します。例えば、contacts_extractとします。
データソースタイプ
データソースタイプを選択します。この例ではCSVコンテンツストリームです。
CSVストリーム入力
データソースをCSVコンテンツストリームとして設定した後、CSVストリーム入力を設定します。これは、オンプレミスファイルトリガーからのファイルコンテンツを渡す場所です。
データスキーマ
データスキーマを設定します。これは、いくつかのサンプル連絡先データを含むCSVファイルをインポートすることで簡単に行えます。
CSVヘッダ行を無視
入力データに見出し列がある場合、それを無視してデータの一部として考慮しないように指定できます。
列区切り記号
CSVファイルで列を区切るために使用される区切り記号を選択します。利用可能なオプションには ,（カンマ）、;（セミコロン）などがあります。
ソース #2に接続するには、次のフィールドに入力します。これは、ソースから抽出したデータを拡張するために使用される製品価格リストデータを指すソースです。
データソース名
データソース名に意味のある名前を指定します。例えば、product_price_lookupとします。
データソースタイプ
データソースタイプを選択します。この例ではCSVコンテンツストリームです。
CSVストリーム入力
データを取得するためのCSV参照データピルを指定します。この例では、Googleドライブのダウンロードアクションからのコンテンツを使用しています。
データスキーマ
データスキーマを設定します。これは、いくつかのサンプル連絡先データを含むCSVファイルをインポートすることで簡単に行えます。
ソース #3を設定します。
このステップでは、機会データを拡張するために使用する特定の地域の詳細を取得します。このデータは頻繁に再利用する予定であり、それ自体ではデータを変更しないため、キャッシュすることができます。
以下のフィールドを設定してください：
データソース名
データソース名に意味のある名前を付けてください。例えば、region_lookupとします。
データソースの種類
データソースの種類を選択してください。この例では、FileStorageファイルです。
FileStorageファイルのパス
ヒストリカルデータファイルがFileStorage内のどのパスにあるかを指定してください。
データスキーマ
データスキーマを設定してください。これは、いくつかのサンプル連絡先データを含むCSVファイルをインポートすることで簡単に行うことができます。スキーマは、ソースから左から右に来る列の順序に一致します。
# クエリの設定
次に、データソース上で動作し、変換された出力を生成するクエリを設定します。この例では、クエリはすべての3つのデータソースを結合し、製品価格データの助けを借りて総売上、総コスト、総利益を計算します。さらに、国と地域の詳細もregion_lookupデータソースとの結合によって追加されます。WITH ... AS ...関数は、サブクエリを書き、そのデータをメインクエリで簡単に使用するのに役立ちます。
# 出力の設定
出力の形式を定義します。
この例では、エンリッチされたレコードファイルをSFTPサーバーに送信します。エンリッチされたレコードファイルをSFTPサーバーに送信するため、出力タイプをCSVコンテンツストリームとしました。これにより、Query CSVデータアクションの「CSVコンテンツ」出力データピルをSFTPアップロードファイルアクションのコンテンツ入力セクションに渡すことができ、Query CSVアクションからSFTPサーバーへのコンテンツストリームが自動的に行われます。また、データソースの設定と同様に、出力CSVコンテンツで使用する区切り文字と、列ヘッダーを含めるかどうかを選択するオプションもあります。
以下のフィールドに入力してください：
出力タイプ
出力のタイプを選択してください。ストリーム可能なデータピルとしてコンテンツを共有するには、CSVコンテンツストリームを使用します。
ヘッダー行を含める
データの列名をファイルのヘッダー行として追加する場合は、はいに設定します。これは、レポートの生成にファイルを使用する場合に便利です。デフォルト値はいいえです。
列区切り文字
CSVファイルで列を区切るために使用する区切り文字を選択してください。利用可能なオプションには、,（カンマ）、;（セミコロン）などがあります。
SFTPへのファイルのアップロードアクションを選択します。
以下のフィールドに入力してください：
ファイル名
フォルダを含む完全なパスを指定してください。フォルダはファイルを追加する前に存在している必要があります。
追記
はいの場合、既存のファイルに内容を追記します。いいえの場合、既にファイルが存在する場合は上書きします。デフォルトはいいえです。
ファイルの内容
アップロードするファイルの内容。ステップ4 クエリCSVデータアクションからCVSコンテンツデータピルを渡してください。
# 次に読む
Last updated: 2024/2/13 16:59:53