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

tESBConsumerの標準プロパティ

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

標準のtESBConsumerコンポーネントは、ESBファミリーに属しています。

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

基本設定

サービス設定

Webサービスのバインドと設定の説明。[Endpoint] (エンドポイント)フィールドは、サービス設定が完了すると自動的に入力されます。

[Input Schema] (入力スキーマ)および[Edit schema] (スキーマを編集)

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

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

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

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

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

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

 

[Built-in] (組み込み): スキーマが作成され、このコンポーネント専用にローカルに保存されます。関連項目: 詳細は、ジョブに組み込みスキーマを設定をご覧ください。

 

[Repository] (リポジトリー): スキーマは既に存在し、リポジトリーに保存されています。したがって、再利用できます。関連項目:ジョブにリポジトリースキーマを設定をご覧ください。

[Response Schema] (応答スキーマ)および[Edit schema] (スキーマを編集)

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

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

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

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

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

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

 

[Built-in] (組み込み): スキーマが作成され、このコンポーネント専用にローカルに保存されます。関連項目: 詳細は、ジョブに組み込みスキーマを設定をご覧ください。

 

[Repository] (リポジトリー): スキーマは既に存在し、リポジトリーに保存されています。したがって、再利用できます。関連項目:ジョブにリポジトリースキーマを設定をご覧ください。

[Fault Schema] (フォールトスキーマ)および[Edit schema] (スキーマを編集)

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

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

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

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

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

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

 

[Built-in] (組み込み): スキーマが作成され、このコンポーネント専用にローカルに保存されます。関連項目: 詳細は、ジョブに組み込みスキーマを設定をご覧ください。

 

[Repository] (リポジトリー): スキーマは既に存在し、リポジトリーに保存されています。したがって、再利用できます。関連項目:ジョブにリポジトリースキーマを設定をご覧ください。

Service Registryを使用

このオプションは、Talend Enterprise ESBソリューションをサブスクライブしている場合のみ利用可能です。

このチェックボックスをオンにすると、Service Registryが有効になります。それによりダイナミックエンドポイントのルックアップが可能になり、レジストリーから取得された情報に基づいて、サービスのリダイレクトができるようになります。これはランタイムでのみ使用できます。

[Username] (ユーザー名)および[Password] (パスワード)フィールドに、認証情報を入力します。

SAMLトークンがService Registryに登録されている場合、[Role] (役割)フィールドでクライアントの役割を指定する必要があります。[Propagate Credentials] (認証情報のプロパゲート)チェックボックスをオンにし、既存の認証情報をプロパゲートすることで、認証済みユーザーの代わりに決断を下すこともできます。ユーザー名とパスワードを入力してSTSで認証し、ユーザー名とパスワードを使用してプロパゲートするか、またはエイリアス、ユーザー名、およびパスワードを入力し、証明書を使ってプロパゲートします。詳細は、[Use Authentication] (認証を使用)オプションをご覧ください。[Encryption/Signature body] (暗号化/署名本文)チェックボックスをオンにして、XML暗号化/XML署名を有効にします。詳細は、XKMSサービスをご覧ください。

[Correlation Value] (相関値)フィールドで、相関IDを指定するか、またはこのフィールドを空白のままにしておきます。詳細は、[Use Business Correlation] (ビジネス相関の使用)オプションをご覧ください。

Service Registryの設定方法と使い方は、Setting up ESB Service RegistryとService Registryをご覧ください。

Service Locatorを使用

要求およびサービスレベル合意(SLA)を満たすよう、サービスの可用性を維持します。

このオプションは、[Use Service Registry] (Service Registryを使用)チェックボックスがオンになっている場合は表示されません。

 [Use Service Activity Monitor] (サービスアクティビティモニタリングの使用)

このオプションにより、イベントがキャプチャーされ、それに関する情報が保存されて、サービスアクティビィティの詳細な分析とビジネストランザクションにおけるメッセージの追跡とトレースが行えます。これはサービス応答時間の分析、トラフィックパターンの特定、根本原因分析の実行などに使用できます。

Talend Enterprise ESBソリューションをサブスクライブしている場合、[Use Service Registry] (サービスレジストリーを使用)チェックボックスをオンにすることでもこのオプションは無効になります。

 [Use Authentication] (認証を使用)

認証オプションを有効にするには、このチェックボックスをオンにします。Basic HTTP (基本HTTP)、[HTTP Digest] (HTTPダイジェスト)、[Username Token] (ユーザー名トークン)、[SAML Token (ESB runtime only)] (SAMLトークン(ESB Runtimeのみ))から選択します。必要に応じて、該当するフィールドにユーザー名およびパスワードを入力します。Basic HTTP (基本HTTP)、[HTTP Digest] (HTTPダイジェスト)、[Username Token] (ユーザー名トークン)による認証は、Talend Studioと Talend Runtimeの両方で機能します。[SAML Token] (SAMLトークン)による認証は実行時にのみ使用できます。

[SAML Token (ESB runtime only)] (SAMLトークン-ESB実行時のみ)を選択した場合、リクエストを送信するためにユーザーの認証情報を提供するか、または既存の認証情報をプロパゲートすることで、認証済みユーザーの代わりに決定を下すことができます。次の中から選択します:

-: 該当するフィールドにユーザー名とパスワードを入力して、サービスにアクセスします。

[Propagate using U/P] (U/Pを使ってプロパゲート): STSの認証に使用するユーザー名とパスワードを入力します。

[Propagate using Certificate] (証明書を使ってプロパゲート): STSの認証に使用するエイリアスとパスワードを入力します。

パスワードを入力するためには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符で囲んで入力して[OK]をクリックし、設定を保存します。

このオプションは、[Use Service Registry] (Service Registryを使用)チェックボックスがオンになっている場合は表示されません。

[Use Authorization] (認証サービスを使用)

このオプションは、Talend Enterprise ESBソリューションをサブスクライブしている場合のみ利用可能です。

このチェックボックスをオンにして、許可されたコールを有効にします。クライアントのロールを[Role] (ロール)フィールドに指定します。このオプションは、[Use Authentication] (認証を使用)リストで[SAML Token (ESB runtime only)] (SAMLトークン(ESB実行時のみ))を選択すると表示されます。

ユーザーのロールと権限の管理については、Managing ESB Resources and authorizationとTalend Identity and Access Managementをご覧ください。

[Encryption/Signature body] (暗号化/署名本文)

このチェックボックスをオンにして、XML暗号化/XML署名を有効にします。詳細は、XKMSサービスをご覧ください。

このオプションは、[Use Authentication] (認証を使用)リストで[SAML Token (ESB runtime only)] (SAMLトークン(ESB実行時のみ))を選択すると表示されます。

[Use Business Correlation] (ビジネスコリレーションを使用)

このチェックボックスをオンにしてこのコンポーネントにコリレーションIDを作成します。

コリレーションIDは[Correlation Value] (コリレーション値)フィールドで指定できます。この場合、コリレーションIDはIDが呼び出すサービスに渡されます。その結果、連鎖型のサービスコールがこのコリレーションIDの下にまとめられます。このフィールドを空白にすると、実行時にこの値が自動的に生成されます。

このオプションを有効になっている場合、tESBConsumerは応答ヘッダーから相関IDを抽出し、それをフロー内での今後の使用のためにコンポーネント変数に保存します。

このオプションは、[Use Service Registry] (サービスレジストリーを使用)チェックボックスがオンになっている場合、自動的に有効になります。

[Use GZip Compress] (GZip圧縮の使用)

このチェックボックスをオンにすると、送信する前に受信メッセージをGZip形式に圧縮できます。

Die on error (エラー発生時に強制終了)

エラー発生時にジョブを強制終了するには、このチェックボックスをオンにします。

詳細設定

[Log messages] (ログメッセージ) サービスプロバイダーとコンシューマーの間のメッセージ交換を記録するには、このチェックボックスをオンにします。

[Service Locator Custom Properties] (カスタムプロパティ)

このテーブルは、[Use Service Locator] (サービスロケーターを使用)チェックボックスがオンになっている場合に表示されます。テーブルに必要な数だけ行を追加して、関連するプロパティをカスタマイズできます。[Property Name] (プロパティ名)フィールドと[Property Value] (プロパティ値)フィールドに、それぞれのプロパティの名前と値を二重引用符で囲んで入力します。

[Service Activity Custom Properties] (サービスアクティビティのカスタムプロパティ)

このテーブルは、[Use Service Activity Monitor] (サービスアクティビティモニタリングの使用)チェックボックスがオンになっている場合に表示されます。テーブルに必要な数だけ行を追加して、関連するプロパティをカスタマイズできます。[Property Name] (プロパティ名)フィールドと[Property Value] (プロパティ値)フィールドに、それぞれのプロパティの名前と値を二重引用符で囲んで入力します。

[Connection time out(second)] (接続タイムアウト(秒))

Webサービス接続タイムアウトの値を秒単位で設定します。

このオプションは、Talend Studioでのみ機能します。実行時にコンポーネントがデプロイされた後にそれを使用するには:

  1. <TalendRuntimePath>/container/etc /フォルダーに名前org.apache.cxf.http.conduits-<endpoint_name>.cfgを持つ設定ファイルを作成します。

  2. Webサービスのurlとclient.ConnectionTimeoutパラメーターを設定ファイルにミリ秒単位で指定します。[Receive time out] (受信タイムアウト)オプションを使用する必要がある場合は、client.ReceiveTimeoutもミリ秒で指定してください。urlには、完全なエンドポイントアドレス、またはワイルドカードを含む正規表現を指定できます。たとえば、次のようになります。

    url = http://localhost:8040/*
client.ConnectionTimeout=10000000
client.ReceiveTimeout=20000000

    この場合、http://localhost:8040/*は、http://localhost:8040/で始まるすべてのURLとマッチします。

[Receive time out(second)] (受信タイムアウト(秒))

サーバー応答の値を秒単位で設定します。

このオプションは、Talend Studioでのみ機能します。コンポーネントが実行時にデプロイされた後にそれを使用する方法については、[Connection time out] (接続タイムアウト)オプションをご覧ください。

[Disable Chunking] (チャンクの無効化)

payloadのチャンクエンコードを無効にする場合は、このチェックボックスをオンにします。通常、ストリーミングは直接実行されるため、チャンクはより有効に機能します。しかし、チャンクが有効な状態でペイロードが切り詰められる場合があります。サービスとの連携時に奇妙なエラーが発生する場合は、チャンクをオフにして、それが機能するかどうかご確認ください。

[Trust server with SSL] (SSLを使用したTrustサーバー)/[TrustStore file] (TrustStoreファイル)と[TrustStore password] (TrustStoreパスワード)

このチェックボックスをオンにすると、SSLプロトコルを使用してサーバー証明書についてクライアントに対して検証を行い、対応するフィールドに入力できます。

[TrustStore file] (トラストストアファイル): クライアントが信頼する証明書のリストを含む証明書トラストストアファイルへのパス(ファイル名を含む)を入力します。

[TrustStore password] (トラストストアパスワード): トラストストアデータの整合性チェックに使用するパスワードを入力します。

[Use http proxy/Proxy host] (httpプロキシ/プロキシホストを使用)、[Proxy port] (プロキシポート)、[Proxy user] (プロキシユーザー)、および[Proxy password] (プロキシパスワード)

プロキシサーバーを使用している場合は、このチェックボックスをオンにして、必要な情報を入力します。

パスワードを入力するためには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符で囲んで入力して[OK]をクリックし、設定を保存します。

[HTTP Headers] (HTTPヘッダー)

リクエストされたHTTP操作のパラメーターを定義するために、HTTPヘッダーの名前/値ペアを追加するのに必要な数だけ[+]をクリックします。

[tStatCatcher Statistics] (tStatCatcher統計)

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

グローバル変数

グローバル変数

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

CORRELATION_ID: チェーンされたサービス呼び出しがグルーピングされるコリレーションID。これはFlow変数で、文字列を返します。

ERROR_MESSAGE: エラーが発生した時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。この変数はコンポーネントにこのチェックボックスが存在し、[Die on error] (エラー発生時に強制終了)がオフになっている場合のみ機能します。

HTTP_RESPONSE_CODE: HTTPレスポンスステータスコード。これはAfter変数で、整数を返します。

HTTP_HEADERS: レスポンスからのHTTPヘッダーのセット。これはFlow変数で、マップオブジェクトjava.util.Map<String, java.util.List<?>>を返します。ヘッダー名はマップキーで表されます。ヘッダー値はjava.util.List<?>で表されます。

Flow変数はのコンポーネントの実行中に機能し、After変数はコンポーネントの実行後に機能します。

フィールドまたは式に変数を入力する場合は、Ctrl + スペースを押して変数リストにアクセスし、使用する変数を選択します。

変数の詳細は、コンテキストと変数を使用をご覧ください。

使用方法

使用ルール

このコンポーネントは、中間コンポーネントとして使用できます。出力コンポーネントにリンクしている必要があります。

[Dynamic settings] (ダイナミック設定)

[+]ボタンをクリックしてテーブルに行を追加し、[Code] (コード)フィールドにコンテキスト変数を入力して、[Use Authentication] (認証を使用)または[Use HTTP proxy] (HTTPプロキシの使用)オプションがランタイムにダイナミックにオンまたはオフになるようにします。テーブルに行を2つ追加すれば、両方のオプションを設定できます。

ダイナミックパラメーターを定義すると、[Basic settings] (基本設定)ビューまたは[Advanced settings] (詳細設定)ビューで対応するオプションがハイライトされ、利用できなくなります。

ダイナミックパラメーターの定義法を示すユースケースについては、コンテキストベースのダイナミック接続によってデータベースからデータを読み取りと、ダイナミックにロードされた接続パラメーターを使って異なるMySQLデータベースからデータを読み取りをご覧ください。ダイナミック設定とコンテキスト変数の詳細は、ダイナミックスキーマとコンテキストグループを作成し、その中でコンテキスト変数を定義をご覧ください。

[Limitation] (制限事項)

このコンポーネントを動作させるには、JDKが必要です。

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

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

こちらにフィードバックをお寄せください