データソースの設定

Data Sources 設定では、SQL クエリを実行するための 1 つ以上のソースを指定できます。レシピのセットアップ中に複数のデータソースを追加できます。レシピがアクティブになった後で既存のデータソースを変更したり新しいものを追加するには、最初にレシピを停止してから変更を行ってください。

データソースの設定方法

データソースを設定するには、次の手順を完了します。

1

1つ以上のデータソースを含めるには、Add data source を選択します。

2

各データソースについて、次のフィールドを設定します：

• データソース名

• クエリで参照するために、accounts や employees などのデータソースの名前を指定します。

• データソースの種類

• SQL Transformations がデータを取得するデータソースの種類を選択します：

CSV コンテンツストリームをデータソースとして使用するには、Content stream を選択します。上流のアクションやトリガーから、バルクアクションやファイルコネクタからのファイル内容などのCSVコンテンツのデータピルを Content input stream フィールドに渡します。

Workato FileStorage 内のファイルをデータソースとして使用するには、FileStorage file を選択します。ファイルのパスを直接使用するか、Search files や Get file contents など、上流の FileStorage アクションからデータピルを使用できます。

Workato のデータテーブル内のデータテーブルをデータソースとして使用するには、Data table を選択します。このオプションにより、追加のセットアップなしで Workato 内で設定されたテーブルからデータを取得できます。

3

データソースの種類に Data table を選択した場合、利用可能なリストから特定のデータテーブルを選択します。テーブルを選択した後、追加の設定は必要ありません。

RESERVED CHARACTER USAGE

データテーブルのテーブル名やカラム名の先頭に @ 文字を使用しないでください。これは SQL で予約されており、クエリ実行中にエラーを引き起こす可能性があります。

4

データソースの種類に Content stream または FileStorage file を選択した場合、データの File format（ファイル形式）を選択します。CSV または Excel を選択します。選択に基づいて、追加のフィールドが表示されます：

• Worksheet（Excelファイルのみ）

• 取得するデータを含むExcelワークシートの名前を入力します。

• Range（Excelファイルのみ）

• データを取得するExcelワークシート内のセル範囲を指定します（例：B5:C20）。範囲を指定する際はヘッダ行を無視してください。データ範囲が動的な場合は、任意の範囲を含め、クエリを設定して空またはヌル行を無視します。

5

ファイル形式を選択した後、Schema setup type（スキーマ設定タイプ）を設定します。この設定は、受信データのスキーマをどのように定義するかを決定します：

受信データの構造が設計時に確立されている場合は、Defined スキーマを使用します。このオプションでは、カラムとその期待されるデータ型を明示的に定義できます。

Defined スキーマを設定するには、次のフィールドを完了します：

• カラムスキーマ

• CSV または Excel ファイルからのカラム名を提供します。手動で名前を入力するか、Use a sample CSV file 機能を選択してスキーマを自動生成します。Excel ファイルの場合、特定の要件に合わせてスキーマを調整するために、カラム名を手動で入力します。

• カラムの緩和

• ソースデータにスキーマで定義された以上のカラムが含まれている可能性がある場合は Yes を選択し、エラーを引き起こすことなく変化を許可します。No を選択すると、スキーマとデータが正確に一致することを強制します。No が選択されている場合に追加のカラムが存在すると、エラーが返されます。

• ヘッダの有無

• データにカラム名を含むヘッダ行が含まれているかどうかを選択します。データにヘッダ行が含まれている場合は Yes を選択します。カラムを順番でマッチさせるには No を選択します。デフォルトの設定は Yes です。

• ヘッダマッチングモード

• 提供されたスキーマを受信データのヘッダと名前または順番でマッチさせるかを選択します。ヘッダが存在する場合、Name を選択してカラムを名前でマッチさせます。スキーマにデータヘッダと異なるカラム名が含まれる場合は Order を選択し、左から右への順番でスキーマカラムをデータにマッピングします。

• カラム区切り文字（CSVファイルのみ）

• CSV データ内でカラムを区切る文字を選択します。例えば、,（カンマ）や ;（セミコロン）などです。デフォルトはカンマです。

HOW ARE THE COLUMNS MATCHED IN THE DEFINED SCHEMA?

スキーマ内のカラムは、実際のデータと左から右へ順番に上下でマッチします。これにより、実際のデータにカラム名が含まれていない場合でも正しいカラム識別が保証されます。カラムの緩和が No に設定されている場合、スキーマと実際のデータのカラム数が一致しないと Workato はエラーを返します。

カラムの緩和が Yes に設定されている場合、Workato はスキーマで定義されていない追加のカラムに任意のカラム名（例えば、column_1、column_2）を割り当てます。Add header in output が Yes に設定されている場合、これらの任意の名前も出力に表示されます。

受信データの構造が実行時に変化する場合は、Dynamic スキーマオプションを使用します。データピルを使用してスキーマを渡し、カラム名と型を指定します。カラムの緩和がサポートされているため、カラム数が正確に一致する必要はありません。Workato はヘッダが存在する場合は名前で、存在しない場合は順番でデータをマッチさせます。

Dynamic スキーマを設定するには、次のフィールドを完了します：

• カラムスキーマ

• データピルを使用して実行時に必要なカラム名と型を提供し、スキーマを入力します。CSV ファイルの場合、データピルを通じて直接スキーマを提供します。Excel ファイルの場合、データがあるシート名を指定します。このアプローチは、受信データの構造が固定されておらず、データソース間で変化する場合に使用します。

• カラムの緩和

• ソースデータにスキーマで定義された以上のカラムが含まれている可能性がある場合は Yes を選択し、エラーを引き起こすことなく変化を許可します。No を選択すると、スキーマとデータが正確に一致することを強制します。No が選択されている場合に追加のカラムが存在すると、エラーが返されます。

• ヘッダの有無

• データにカラム名を含むヘッダ行が含まれているかどうかを選択します。データにヘッダ行が含まれている場合は Yes を選択します。カラムを順番でマッチさせるには No を選択します。デフォルトの設定は Yes です。

• ヘッダマッチングモード

• 提供されたスキーマを受信データのヘッダと名前または順番でマッチさせるかを選択します。ヘッダが存在する場合、Name を選択してカラムを名前でマッチさせます。スキーマにデータヘッダと異なるカラム名が含まれる場合は Order を選択し、左から右への順番でスキーマカラムをデータにマッピングします。

• カラム区切り文字（CSVファイルのみ）

• CSV データ内でカラムを区切る文字を選択します。例えば、,（カンマ）や ;（セミコロン）などです。デフォルトはカンマです。

DYNAMIC SCHEMA USE CASES

動的スキーマの具体的な使用例については、以下の例を参照してください：

• Dynamic schema with Salesforce trigger output の例では、Salesforce トリガからのデータ構造の変化を動的に処理する方法を示しています。スキーマは Salesforce が提供するフィールドに自動的に適応し、手動の介入を必要としません。

• Dynamic schema with schema from previous query の例では、Source schemas と Output schemas のデータピルを使用して、あるクエリから別のクエリにスキーマを渡す方法を示しています。これにより、前のクエリの出力に基づいて動的な更新が可能になります。

スキーマを提供する予定がない場合は、Infer スキーマオプションを使用します。スキーマはヘッダ情報に基づいてデータから直接推論されます。このオプションは、スキーマの変更がユーザー入力なしで自動的に処理される動的なクエリに便利です。

Infer スキーマを設定するには、次のフィールドを完了します：

• カラム区切り文字（CSVファイルのみ）
• CSV データ内でカラムを区切る文字を選択します。例えば、,（カンマ）や ;（セミコロン）などです。デフォルトはカンマです。

HOW DOES WORKATO HANDLE INFER SCHEMA?

Workato は提供されたヘッダに基づいてデータ内のカラムを自動的にマッチさせます。スキーマの調整やカラム順の変更は、ユーザー入力なしで自動的に推論されます。

6

Add data source を選択して追加のデータソースを提供します。これにより、変換に必要なデータをまとめることができます。

例：AWS S3 コネクタからの CSV ファイルコンテンツを使用したデータソース

この例では、データソースは employee と名付けられ、S3 のダウンロードファイルアクションから取得したファイルコンテンツからデータが取得されます。スキーマには従業員に関する情報が含まれており、CSV データは ,（カンマ）を区切り文字として使用しています。

さらに、ユーザーは CSV のヘッダ行を無視することを選択しています。

データソースの例の設定 1

例：Workato FileStorage に保存された CSV ファイルを使用したデータソース

この例では、データソースは zipcode と名付けられ、パスが SQL/zipcode_data.csv の Workato FileStorage に保存されたファイルから取得されます。

前の例と同様に、カラム区切り文字は ,（カンマ）であり、ユーザーはクエリの実行中にファイルからのデータの CSV ヘッダ行を無視することを選択しています。

データソースの例の設定 2

例：Google Drive コネクタからの Excel ファイルコンテンツを使用したデータソース

この例では、データソースは sales_data と名付けられています。Google Drive のダウンロードファイルアクションから取得した Excel ファイルからデータを取得します。スキーマは売上関連のカラムで構成され、Excel のデータは Q1_Sales という名前のワークシートと範囲 A3:E100 から取得されます。

データソースの例の設定 3

例：Salesforce トリガー出力を使用した動的スキーマのデータソース

この例では、Salesforce トリガーを使用し、Salesforce 出力の Object schema データピルを通じてスキーマを動的に更新します。Field name、Field label、Mapped type などの Salesforce データは、トリガーによって返されるレコードに応じて変化する可能性があるため、このレシピでは Schema setup type を Dynamic に設定します。

Salesforce 動的スキーマのデータソース設定例

スキーマは Salesforce 出力のフィールドに自動的に適応し、手動の介入を必要とせずにオブジェクトフィールドの変更や更新を処理します。

例：前のクエリからのスキーマを使用した動的スキーマのデータソース

次の例では、あるクエリステップから次のクエリステップに動的なスキーマを渡します。最初のクエリからの Output schema データピルが、2つ目のクエリの動的スキーマセクションでデータソースとしてマッピングされます：

前のクエリデータからのスキーマを渡すデータソース設定例

データ構造（Field name や Field type など）が前に処理されたレコードによって変化する可能性があるため、動的スキーマオプションが選択されています。スキーマは手動の設定を必要とせず、前のクエリの出力の構造に合わせて自動的に調整されます。

---

次を読む

1. クエリの設定
2. 出力の構成
3. 出力フィールド

Sample use cases

次のユースケースで SQL Transformations を活用するためのステップバイステップの手順については、ガイドをご覧ください：

• 変更データキャプチャ
• データの検証とクレンジング
• データのエンリッチメント