# パイプラインの作成
アプリのホームページから新しいパイプラインを作成できます。
1
SlackまたはMicrosoft Teamsでアプリのホームページに移動します。
2
パイプラインの作成を選択します。
3
ソースシステムを選択します。このアクセラレータは以下のソースをサポートするように事前設定されています:
- Salesforce
- MS SQL
- MS Windowsファイルシステム
4
利用可能なオプションのリストからロードタイプを選択します。
- フルロード(FULL)
- フルロードは、ジョブが実行されるたびにソーステーブルのフルエクストラクトを指します。これらのタイプのジョブには通常開始日がありません。パイプラインを作成する際に頻度を決定できます。たとえば、通貨やコードなどの小~中規模のルックアップテーブルを**フルロード**に割り当てることができます。
- インクリメンタルロード(INCR)
- すべてのインクリメンタルジョブはフルリフレッシュから始まります。リフレッシュはソースをターゲットに同期させ、その後パイプラインは時間/日付ベースのCDCアプローチを使用してインクリメンタルに切り替わります。パイプラインを作成する際にINCRの頻度を決定できます。ジョブが実行されるたびにエクストラクト全体をリフレッシュするのではなく、アクセラレータは前回パイプラインが実行された後に変更されたデータを取得します。たとえば、Salesforceから**Opportunitiesテーブル**を完全に移行し、ロード頻度を毎日に設定するシナリオを考えてみましょう。この場合、毎日のデータ変更のみが抽出されてマージされます。
- エクストラクトロード(EXTR)
- エクストラクトロードは、通常2つのタイムスタンプ間でデータを抽出します。このロードタイプを使用して、監査を含むカスタムレポートを作成できます。
5
パイプラインの作成インターフェースが表示されます。
パイプラインの作成インターフェースで以下の入力フィールドを設定します:
- ソースオブジェクト
- ソースシステムのオブジェクト、例えば連絡先やアカウントなど。
- サンプル値:
- リード、連絡先、またはアカウント。
- 宛先テーブル/オブジェクト
- データをロードするSnowflakeテーブルの名前。選択する名前はSnowflakeの命名規則に従い、二重引用符(
"
)を避ける必要があります。 - サンプル値:
salesforce_leads_table_20220204170134
- 開始日
- ユーザーの›タイムゾーンに対するパイプラインの開始日。
- サンプル値:
2021-02-04
- 開始時間、分
- パイプラインの開始時間を定義します。この値はWorkatoアカウントの所有者のタイムゾーンに対して相対的です。
- サンプル値:
11,30
- 終了日(オプション)
- エクストラクトパイプラインの場合、**終了日**は抽出期間の終了を指定します。フルロードまたはインクリメンタルロードパイプラインには適用されません。
- サンプル値:
2021-02-04
- 終了時間、分(オプション)
- フルロードまたはインクリメンタルロードには適用されません。
- サンプル値:
15,25
- 頻度
- パイプラインの実行頻度を定義します。
- 次のいずれかの値を指定できます:
- 毎時
- 毎日
- 毎週
- 毎月
- 毎年
6
作成をクリックします。
7
パイプラインを作成した後、ELTパイプラインボットからメッセージが送信されます。
ELTコントロールID:6f51a574-b52-426e-992d-2c06414eebe
ソースシステム:Salesforce
ソースオブジェクト:リード
ターゲットテーブル:Leads_Test
開始日:2022-05-18T00:00:00.000000-07:00
開始時間(時):07
開始時間(分):55
頻度:月次
Last updated: 2024/2/22 23:17:11