パイプラインの作成 ​

SlackまたはMicrosoft Teamsを開き、App homepageに移動します。

Create Pipelineを選択します。

Source Systemを選択します。 このアクセラレーターは、次のソースをサポートするように事前設定されています:

• Salesforce
• MS SQL
• MS Windowsファイルシステム

使用可能なオプションのリストからLoad Typeを選択します。

フルロード（FULL）

Fullとは、ジョブが実行されるたびにソーステーブルを完全に抽出することを指します。 通常、この種類のジョブには開始日がありません。 パイプラインを作成するときに頻度を決定できます。 たとえば、通貨やコードなどの小規模から中規模のルックアップ テーブルをフルロードに割り当てることができます。

増分ロード（INCR）

すべての増分ジョブは、完全なリフレッシュから開始されます。 リフレッシュによってソースがターゲットと同期され、その後パイプラインは時刻/日付ベースのCDCアプローチを使用して増分に切り替わります。 パイプラインを作成するときにINCRの頻度を決定できます。 ジョブが実行されるたびに抽出全体をリフレッシュするのではなく、アクセラレーターは前回パイプラインが実行された後に変更されたデータを取得します。 たとえば、Salesforceの商談テーブルを完全に移行し、ロード頻度を毎日に設定するシナリオを考えます。 この状況では、日次のデータ変更のみが抽出されてマージされます。

抽出ロード（EXTR）

抽出ロードは、通常2つのタイムスタンプ間の、指定された時間枠内のデータを取得します。 このロードタイプを使用して、監査を含むカスタムレポートを作成できます。

Create Pipelineインターフェースが表示されます。

Create Pipelineインターフェースで次の入力フィールドを設定します:

ソースオブジェクト

連絡先やアカウントなど、ソースシステムのオブジェクト。

サンプル値:

リード、連絡先、またはアカウント。

宛先テーブル/オブジェクト

データのロード先として予定しているSnowflakeテーブルの名前。 選択する名前はSnowflakeの命名規則に従い、二重引用符（"）を避ける必要があります。

サンプル値:

salesforce_leads_table_20220204170134

開始日

ユーザーのタイムゾーンに相対するパイプライン開始日。

サンプル値:

2021-02-04

開始時刻（時、分）

パイプラインの開始時刻を定義します。 この値は、Workatoアカウント所有者のタイムゾーンを基準にしています。

サンプル値:

11,30

終了日（任意）

抽出パイプラインでは、終了日によって抽出時間枠の終了を指定します。 フルロードまたは増分ロードのパイプラインには適用されません。

サンプル値:

2021-02-04

終了時刻（時、分）（任意）

フルロードまたは増分ロードには適用されません。

サンプル値:

15,25

頻度

パイプラインが実行される頻度を定義します。

次のいずれかにできます:

• 毎時
• 毎日
• 毎週
• 毎月
• 毎年

Createをクリックします。

パイプラインを作成すると、ELT Pipeline botから次の形式のメッセージが送信されます。

ELT Control ID: 6f51a574-b52-426e-992d-2c06414eebe
Source System: Salesforce
Source Object: Lead
Target Table: Leads_Test
Start Date: 2022-05-18T00:00:00.000000-07:00
Start Date Hours: 07
Start Date Minutes: 55
Frequency: MONTHLY