メイン コンテンツをスキップする 補完的コンテンツへスキップ

tSalesforceBulkExecの標準プロパティ

これらのプロパティは、標準ジョブのフレームワークで実行されているtSalesforceBulkExecを設定するために使われます。

標準tSalesforceBulkExecコンポーネントは、ビジネスファミリーとCloudファミリーに属しています。

このフレームワーク内のコンポーネントは、すべてのTalend製品で使用できます。

基本設定

[Property Type] (プロパティタイプ)

接続の詳細を設定する方法を選択します。

  • [Built-In] (組み込み): このコンポーネントの接続の詳細がローカルに設定されます。関連するすべての接続のプロパティ値を手動で指定する必要があります。

  • [Repository] (リポジトリー): [Repository] (リポジトリー) > [Metadata] (メタデータ)で一元的に保存された接続の詳細が、このコンポーネントによって再使用されます。

    このチェックボックスの横にある [...] ボタンをクリックし、表示された [Repository Content] (リポジトリーのコンテンツ)ダイアログボックスで、再使用する接続の詳細を選択すると、関連するすべての接続のプロパティに値が自動的に入力されます。

[Connection Component] (接続コンポーネント)ドロップダウンリストから、他の接続コンポーネントを選択した場合、このプロパティは、利用できません。

[Connection Component] (接続コンポーネント)

このコンポーネントで再利用するデータベース接続を開くコンポーネントを選択します。

[Connection type] (接続タイプ)

ドロップダウンリストから、接続のタイプを選択します。接続のプロパティは、選択した接続タイプによって異なります。

  • [Basic] (基本): Salesforceのユーザー名とパスワードを入力してSalesforceにアクセスするには、このオプションを選択します。

  • OAuth: OAuth (Open Authorization) 2.0プロトコルを使ってSalesforceにアクセスし、OAuth 2.0認証フロータイプとして[Json Web Token Flow] (Json Webトークンフロー)を使ってユーザーを認証するには、このオプションを選択します。このオプションを使用するためには、Salesforceで接続アプリケーションを作成し、Salesforce認証プロバイダーを設定する必要があります。

    OAuth認証フローの詳細は、Authenticate Apps with OAuthをご覧ください。

    Salesforceで接続アプリケーションを作成する方法は、接続アプリケーションを作成をご覧ください。

[User Id] (ユーザーID)

Salesforceのユーザー名。

このプロパティは、[Basic] (基本)接続タイプが選択されている場合のみ利用できます。

[Password] (パスワード)

ユーザー名に関連付けられたSalesforceのパスワード。

このプロパティは、[Basic] (基本)接続タイプが選択されている場合のみ利用できます。

[Security Token] (セキュリティトークン)

Salesforceのセキュリティトークン。詳細は、セキュリティトークンのリセットをご覧ください。

このプロパティは、[Basic] (基本)接続タイプが選択されている場合のみ利用できます。

[Issuer] (発行者)

接続アプリケーションが作成され、Salesforceの接続アプリケーションの詳細ページに表示される時に生成されるOAuthコンシューマーキー。詳細は、接続アプリケーションを作成をご覧ください。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Subject] (件名)

Salesforceのユーザー名。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Audience] (オーディエンス)

Json Webトークンのオーディエンス。

独自のJson Webトークンオーディエンスを設定できます。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Expiration time (in seconds)] (有効期限(秒))

5分以内のアサーションの有効期限(秒)。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Key store] (キーストア)

Java KeyStore (JKS)形式のキーストアファイルへのパス。

Keystoreファイルは、Salesforceによって署名された証明書を作成し、それをKeystoreにエクスポートすることで生成できます。詳細は、自己署名証明書の生成をご覧ください。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[KeyStore password] (KeyStoreパスワード)

Keystoreのパスワード。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Certificate alias] (証明書の別名)

Salesforceによって署名された証明書の一意の名前。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Mutual authentication] (相互認証)

このオプションを選択すると、Salesforceへの接続を確立するための相互認証を有効にできます。Salesforceでの相互認証の詳細は、Set Up a Mutual Authentication Certificateをご覧ください。

このオプションを使用する場合:

  • コンポーネント側でtSetKeystoreコンポーネントを使い、相互認証キーストアとキーストアパスワードを提供します。

  • メタデータ側で[Window] (ウィンドウ) > [Preferences] (基本設定) > Talend > [Security] (セキュリティ) > SSLと進み、対応するキーストア構成を設定します。

デフォルトでは、このオプションは選択されていません。

[Mutual auth keystore] (相互認証キーストア) (非推奨)

相互認証Keystoreファイル(キーと証明書を含むパスワードで保護されたファイル)へのパスを入力します。

このオプションは非推奨です。tSetKeystoreコンポーネントを使って相互認証キーストアとキーストアパスワードを提供することをお勧めします。

このオプションは、接続タイプが[Basic] (基本)で、[Mutual authentication] (相互認証)チェックボックスがオンになっている時に利用できます。

[Mutual auth keystore password] (相互認証Keystoreパスワード)

相互認証Keystoreファイルのパスワードを入力します。

このオプションは、接続タイプが[Basic] (基本)で、[Mutual authentication] (相互認証)チェックボックスがオンになっている時に利用できます。

[Module Name] (モジュール名)

フィールドの横にある[...]ボタンをクリックし、表示されたダイアログボックスで、使われるモジュールを選択します。または、[Use custom object] (カスタムオブジェクトの使用)チェックボックスをオンにして、[Object Name] (オブジェクト名)フィールドにモジュール名を指定します。

[Schema] (スキーマ)[Edit schema] (スキーマを編集)

スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。

スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。

  • [View schema] (スキーマを表示): スキーマのみを表示する場合は、このオプションを選択します。

  • [Change to built-in property] (組み込みのプロパティに変更): ローカルで変更を行うためにスキーマを組み込みに変更する場合は、このオプションを選択します。

  • [Update repository connection] (リポジトリー接続をアップデート): リポジトリーに保存されているスキーマに変更を加え、変更後にそのコンテンツをすべてのジョブにプロパゲートするかどうかを決める場合は、このオプションを選択します。

    変更を現在のジョブにのみ反映する場合は、変更後、[No] (いいえ)を選択し、[Repository Content] (リポジトリーコンテンツ)ウィンドウで再びこのスキーマのメタデータを選択します。

ジョブで接続している先行コンポーネントからスキーマを取得するためには、[Sync columns] (カラムを同期)をクリックします。

このコンポーネントは、ダイナミックスキーマ機能の利点を備えているので、ソースファイルから不明なカラムを取得したり、各カラムを個別にマッピングしなくてもソースからカラムを一括してコピーしたりできます。ダイナミックスキーマの詳細は、ダイナミックスキーマをご覧ください。

ダイナミックスキーマ機能は、テーブルの不明なカラムを取得するしくみになっており、その他の目的には使用しないことをお勧めします。テーブルの作成には推奨しません。

[Output Action] (出力アクション)

ドロップダウンリストから、実行する次のいずれかの操作を選択します。

  • Insert] (挿入): 1つ以上の新しいレコードをSalesforceに挿入します。

  • [UPDATE] (アップデート): Salesforceの1つ以上の既存のレコードをアップデートします。

  • [UPSERT] (アップサート): 新しいレコードを作成するか、既存のレコードをアップデートします。表示された[Upsert Key Column] (アップサートキーカラム)フィールドにアップサート操作のキーカラムを指定します。[Output upsert column] (アップサートカラムの出力)を選択すると、UpsertColumnValueという名前のカラムが出力スキーマに追加されます。このカラムにはアップサートキーの値が保持されるため、アップサートキーの監視に使えます。アップサートキーが変数の場合は、[Output upsert column] (アップサートカラムの出力)を選択できます。

  • [DELETE] (削除): Salesforceで1つ以上のレコードを削除します。

[Bulk File Path] (バルクファイルパス)

処理するデータを保管するファイルへのパスを指定します。

[Content Type] (コンテンツタイプ)

データをロードするファイルの形式を選択します。現在は、JSONCSVという2つのファイル形式がサポートされています。Bulk API 2.0ではJSON形式がサポートされていないため、JSONファイルからデータをロードしたい場合は、[Advanced settings] (詳細設定)ビューにある[Bulk API V2]オプションを選択しません。

詳細設定

Salesforce URL

Salesforceへの接続に必要なWebService URL。

情報メモ警告: Salesforceの最近のバージョンで行われた大幅な変更のため、相互認証で[Basic] (基本)接続タイプを使用する場合は、ジョブの実行中にエラーが発生しないようエンドポイントを調整する必要があります。例: https://MyDomainName.my.salesforce.com:8443/services/Soap/u/57.0

[API version] (APIバージョン)

Salesforce APIバージョン。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

圧縮が必要

SOAPメッセージ圧縮を有効にする場合は、このチェックボックスを選択します。これにより、パフォーマンスが向上する場合があります。

[Trace HTTP message] (HTTPメッセージをトレース)

コンソールでのHTTPインタラクションを出力する場合は、このチェックボックスを選択します。

[Client Id] (クライアントID)

Salesforce Webサイトへのアクセスに同じアカウントとパスワードを使うユーザーを区別するには、実際のユーザーのIDを入力します。

[Timeout] (タイムアウト)

Salesforceでクエリータイムアウトの予定数をミリ秒で入力します。

[Use Proxy] (プロキシを使用)

SOCKSプロキシサーバーを使う場合は、このチェックボックスをオンにして、表示された[Host] (ホスト)[Port] (ポート)[User Id] (ユーザーID)[Password] (パスワード)フィールドで、SOCKSプロキシサーバーの接続パラメーターを指定します。

情報メモ注: 許可されているタイプのプロキシ(HTTPプロキシ、HTTPSプロキシ、SOCKSプロキシを含む)を使用するには、tSetProxyコンポーネントを使用します。

[Bulk API V2] (バルクAPI V2)

このチェックボックスを選択し、バルクAPI V2ジョブを作成してから、CSVデータ用に、[Column Delimiter] (カラム区切り)ドロップダウンリストから、フィールド区切りのタイプを、[Line Ending] (行末)ドロップダウンリストから、行末処理の方法をそれぞれ選択します。

Bulk API V1と比べると、Bulk API v2ではデータの処理方法が簡素化されています。

このプロパティは、OAuth接続タイプが選択されている場合のみ利用できます。

[Concurrency Mode] (同時モード)

ジョブの同時モードを選択します。

  • [Parallel] (並列): バッチを並列モードで処理します。

  • [Serial] (シリアル): バッチをシリアルモードで処理します。

[Rows to Commit] (コミットする行数)

処理するデータバッチごとの行数を指定します。

[Bytes to Commit] (コミットするバイト数)

処理するデータバッチごとのバイト数を指定します。

[Wait Time Check Batch State] (バッチ状態確認の待機時間)

すべてのバッチが最終的に処理されるまで、ジョブ内のバッチが処理されたかどうかを確認するための待機時間(ミリ秒)を指定します。

[Safety Switch] (安全スイッチ)

クエリーするモジュールのカラムの長さが100,000文字を超える場合は、このチェックボックスをオフにします。デフォルトでは、このチェックボックスは過剰なメモリ使用を防ぐためにオンになっています。

このプロパティは、[Query Mode] (クエリーモード)ドロップダウンリストから、[Bulk] (バルク)またはBulkV2が選択されている場合に利用できます。

[tStatCatcher Statistics] (tStatCatcher統計)

このチェックボックスを選択すると、ジョブレベルおよび各コンポーネントレベルでジョブ処理メタデータが収集されます。

グローバル変数

NB_LINE

処理された行数。これはAfter変数で、整数を返します。

NB_SUCCESS

正しく処理された行数。これはAfter変数で、整数を返します。

NB_REJECT

リジェクトされた行数。これはAfter変数で、整数を返します。

ERROR_MESSAGE

エラー発生時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。

使用方法

使用ルール

このコンポーネントは、一般にtSalesforceOutputBulkコンポーネントと共に使います。一緒に使うと、Salesforceで情報をフィードまたは変更する時にパフォーマンスが向上します。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。