Openflow Connector for Salesforce Bulk API:コネクタを構成する¶

注釈

このコネクタは、 Snowflakeコネクタ規約に従うものとします。

このトピックでは、 Openflow Connector for Salesforce Bulk API を構成する手順について説明します。

コネクタをインストールする¶

次のステップに従って、Openflowランタイムで Openflow Connector for Salesforce Bulk API をインストールします。

Openflow Overview ページに移動します。Featured connectors セクションで、 View more connectors を選択します。
Openflowコネクタページで、 Openflow connector for Salesforce Bulk API を見つけ、 Add to runtime を選択します。
Select runtime ダイアログで、 Available runtimes ドロップダウンリストからランタイムを選択します。

コネクタプロセスグループが追加されたOpenflowキャンバスが表示されます。

コネクタを構成する¶

コネクタを構成するには、次のステップを実行します。

インポートしたプロセスグループを右クリックし、 Parameters を選択します。
以下のテーブルの説明に従って、必要なパラメーター値を入力します。

パラメーター	説明
列の削除ストラテジー	受信した最新のスキーマに基づいて、宛先テーブルの列を削除する必要がある場合に、採用する戦略を定義します。次の3つの可能な値。`Drop Column`、 `Rename Column`、 `Ignore Column` `Drop Column`:Snowflakeテーブルから列を削除します。 `Rename Column`:Snowflakeテーブルの列の名前を変更します。 `Ignore Column`:列は無視し、Snowflakeテーブル内のままにします。
接続済みアプリキー	Salesforceの設定中に生成された `private.key` ファイルのコンテンツをコピーして貼り付けます。代わりにOpenflowランタイムにプライベートキーをアップロードする場合は、次のパラメーターを使用することもできます。
接続済みアプリキーファイル	参照アセットチェックボックスをクリックして `private.key` ファイルを直接アップロードし、アセットとしてアップロードし、パラメーターの値としてアセットを選択します。
接続済みアプリキーパスワード	Salesforce設定ステップ中にプライベートキーファイルに設定されたパスワード。
宛先データベース	Salesforceデータが複製されるSnowflakeのデータベースの名前。コネクタを開始する前に、データベースが存在している必要があります。
宛先スキーマ	コネクタが追加するSalesforceデータのテーブルを作成する、上記のデータベース内のスキーマの名前。コネクタの開始前に、スキーマが存在している必要があります。
フィルター	Salesforceから複製するオブジェクトのコンマ区切りリスト、または既存のオブジェクトすべてに適用する正規表現。例: `Account, Opportunity, Contact` 注釈空にしておくと、すべてのオブジェクトが複製されます。Salesforceインスタンスには通常、何千ものオブジェクトがあるため、これは推奨されません。
インクリメンタル・オフロード	プロセッサーがインクリメンタルオフロードを実行するかどうか。`true` の場合、プロセッサーは適切なタイムスタンプフィールドの `WHERE` 句を使用して、最後のクエリジョブ送信以降に変更された記録のみをフェッチします。`false` の場合、コネクタの実行ごとにすべての記録が取得されます。
初期ロードのチャンク	`NONE` 以外の値に設定されている場合、初期データのロードはこの間隔に基づいて複数のジョブに分割されます。オブジェクトに対して最初に実行すると、コネクタはSalesforceにクエリして最も古い記録を見つけ、それを開始点として使用します。後続の各ジョブは、現在の時刻に追いつくまで次の時刻チャンクをクエリします。次のいずれかで設定する必要があります。`NONE`、 `MONTHLY`、 `QUARTERLY`、 `YEARLY` これは、1つのクエリですべての履歴データをロードするとタイムアウトしたり、 API 制限を超えたり、ランタイムのコンテンツリポジトリのストレージサイズを超えたりする可能性がある大規模なデータセットに役立ちます。キャッチすると、プロセッサーは通常の増分オフロードの動作を続行します。
OAuth2 オーディエンス	JWT トークンで設定するオーディエンス。通常は `https://login.salesforce.com` に設定されます。
OAuth2 クライアント ID	Salesforceセットアップステップで取得した Consumer Key 値に設定する必要があります。
OAuth2 サブジェクト	このユーザーの代わりにアプリケーションがSalesforce APIs とやり取りするために、管理者が承認したユーザーのユーザー名に設定する必要があります。
OAuth2 トークンエンドポイント URL	JWT ベアラーフローを介してトークンを交渉するエンドポイント。例: `https://myCompany.my.salesforce.com/services/oauth2/token`
オブジェクトフィールドフィルター JSON	Salesforceオブジェクトごとに、含めるまたは除外するフィールドとフィールドパターンを指定する JSON。オブジェクトごとに1つのアイテムを持つ配列の形式をとります。例1：これには、 'Account' Salesforceオブジェクトの 'name' で終わるすべてのフィールドが含まれます。 `[ {"objectType":"Account", "includedPattern":".*name"} ]` 例2：これにより、 'Account' SalesforceオブジェクトのフィールドID、名前、および収益が含まれます。 `[ {"objectType":"Account", "included": ["Id", "Name", "Revenue"]} ]` `excluded` および `excludedPattern` は、フィルターを構成するためにも利用できます。
オブジェクト識別子の解決	スキーマ/テーブル/列名を大文字と小文字を区別するかどうかを決定します。次のいずれかです。`CASE_INSENSITIVE` / `CASE_SENSITIVE` 注釈このパラメーター値を変更するには、状態をクリアし、すべてのオブジェクトの完全な再ロードを行う必要があります。
列名サフィックスの削除	パラメーター Column Removal Strategy が `Rename Column` に設定されている場合、列名にサフィックスが追加されます。デフォルト： `__deleted`。
スケジュールを実行する	コネクタが Filter パラメーターを介して構成されたオブジェクトのSalesforceの更新をチェックする頻度。デフォルト： `15 minutes`。
Salesforce インスタンス	ドメイン名を含むSalesforceインスタンスのホスト名。プロトコルプレフィックス（`https://`）を含めないでください。使用例：`myCompany.my.salesforce.com`
Snowflakeアカウント識別子	データが永続化される `[organization-name]-[account-name]` 形式のSnowflakeアカウント名。例: `PM-CONNECTORS`
Snowflakeのユーザー名	コネクタがSnowflakeに接続するために使用するサービスユーザーの名前。サービスユーザーは、 `KEY_PAIR` 認証戦略（Openflow BYOC のみ）を使用する場合にのみ必要です。
Snowflake秘密キー	コネクタがSnowflakeへの認証に使用する RSA プライベートキー。PKCS8 標準に従ってフォーマットされ、標準の PEM ヘッダーとフッターが含まれています。ヘッダー行は `-----BEGIN PRIVATE` で始まります。これは、 `KEY_PAIR` 認証戦略（Openflow BYOC のみ）を使用する場合にのみ必要です。代わりに、次のパラメーターを使用してプライベートキーをOpenflowランタイムにアップロードすることもできます。
Snowflake秘密キーファイル	コネクタがSnowflakeへの認証に使用する RSA プライベートキーを含むファイル。PKCS8 標準に従ってフォーマットされ、標準の PEM ヘッダーとフッターが含まれています。ヘッダー行は `-----BEGIN PRIVATE` で始まります。`KEY_PAIR` 認証戦略（Openflow BYOC のみ）を使用する場合にのみ必要です。 Reference asset チェックボックスを選択して、プライベートキーファイルをアップロードし、Openflowランタイムに安全に保存します。
Snowflake秘密キーパスワード	Snowflakeプライベートキーファイル（暗号化されている場合）に関連付けられたパスワードを提供します。これは、 `KEY_PAIR` 認証戦略（Openflow BYOC のみ）を使用する場合にのみ必要です。
Snowflakeロール	クエリ実行中に使用されるSnowflakeロールの名前。`SNOWFLAKE_MANAGED` を使用する場合、これはOpenflowランタイムのSnowflakeロールです。`KEY_PAIR` （Openflow BYOC のみ）を使用する場合、これは指定されたSnowflakeユーザー名に割り当てられたロールです。
Snowflake認証ストラテジー	Snowflakeに接続するためのコネクタの認証戦略。 SNOWFLAKE_MANAGED``（デフォルト）を使用すると、指定されたSnowflakeランタイムロールに関連付けられたSnowflake管理トークンを使用します。Openflow BYOC をを使用する場合、カスタムキーペアを介して特定のユーザーとロールを指定するために ``KEY_PAIR を使用することもできます。
Snowflakeウェアハウス	クエリの実行に使用されるSnowflakeウェアハウス。
特別なオブジェクトフィルター	Salesforceからオフロードするオブジェクトのコンマ区切りリスト（ダイレクト API アクセスを使用）、またはすべての既存のオブジェクトに適用する正規表現。このフィルターは、たとえば、ナレッジデータなどSalesforce一括 API でサポートされていないオブジェクトにのみ使用します。このパラメーターは Filter パラメーターと重複しないでください。例: `Knowledge.*`

コネクタを実行¶

以下のステップに従ってコネクタを起動し、SalesforceからSnowflakeへのデータの複製を開始します。

キャンバスの空の領域を右クリックして、 Enable all Controller Services を選択します。
コネクタのプロセスグループを右クリックし、 Start を選択します。

オブジェクト複製を管理¶

コネクタが開始され、オブジェクトが複製された後、複製に新しいオブジェクトを追加したり、複製から既存のオブジェクトを削除したりできます。

複製に新しいオブジェクトを追加¶

複製に新しいオブジェクトを追加するには、:ui:`Filter`パラメーター（または該当する場合は:ui:`Special Objects Filter`パラメーター）を新しいオブジェクト名で更新します。コネクタを停止する必要はありません。新しいオブジェクトは、次回のスケジュールされた実行時に複製されます。

たとえば、現在の:ui:`Filter`値が``Account, Opportunity``で、``Contact``オブジェクトを追加する場合は、値を``Account, Opportunity, Contact``に変更します。

複製からオブジェクトを削除¶

複製からオブジェクトを削除するには、コネクタを停止し、コネクタの状態とSnowflakeの宛先テーブルの両方をクリーンアップする必要があります。

コネクタプロセスグループを右クリックして:ui:`Stop`を選択し、フロー内のすべてのプロセッサを停止します。
実行中の FlowFiles が処理されていないことを確認してください。
キャンバスを右クリックして:ui:`Parameters`を選択し、:ui:`Filter`パラメーター（または該当する場合は:ui:`Special Objects Filter`パラメーター）からオブジェクト名を削除します。
キャンバスを右クリックして、 Disable all controller services を選択します。
Controller services に移動し、 Salesforce Bulk Jobs State という名前のコントローラーサービスの状態を開きます。
削除したオブジェクトタイプの横にあるゴミ箱アイコンを選択して、その状態エントリを削除します。
キャンバスを右クリックして:ui:`Enable all controller services`を選択し、すべてのプロセッサーを起動してコネクタを再開します。
該当する場合は、Snowflake宛先データベースから対応するテーブルをドロップして、先ほど複製したデータをクリーンアップします。例:
```
DROP TABLE <database_name>.<schema_name>.<object_name>;
```
Copy

次のステップ¶

コネクタのモニターとトラブルシューティングについては、 Openflow Connector for Salesforce Bulk API:トラブルシューティングをご参照ください。