tCouchbaseOutputの標準プロパティ - Cloud - 8.0

Couchbase

Version
Cloud
8.0
Language
日本語
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
ジョブデザインと開発 > サードパーティーシステム > NoSQLコンポーネント > Couchbase
データガバナンス > サードパーティーシステム > NoSQLコンポーネント > Couchbase
データクオリティとプレパレーション > サードパーティーシステム > NoSQLコンポーネント > Couchbase
Last publication date
2024-02-28

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

標準tCouchbaseOutputコンポーネントは、データベースNoSQLファミリーに属しています。

このフレームワークのコンポーネントは、すべてのビッグデータ対応のTalend製品およびTalend Data Fabricで使用できます。

基本設定

[Bootstrap nodes] (ブートストラップノード)

Couchbase SDKでブートストラップするノードの名前かIPを入力します。Couchbaseはブートストラップに複数のノードを指定するよう推奨しているので、ノードの名前かIPをコンマ( , )で区切ってこのフィールドに入力してください。

Couchbaseブートストラップの詳しい情報は、How Couchbase SDKs connect to the clusterをご覧ください。

ノード名はCouchbase Web Consoleの[Servers] (サーバー)ページで見つかります。詳しい情報は、Couchbaseクラスターの管理者に連絡するか、Couchbaseのドキュメンテーションをご覧ください。

Clouchbaseサーバーはプロキシをサポートしないことにご注意ください。この理由により、TalendからのCouchbaseのコンポーネントもプロキシをサポートしません。

[Username] (ユーザー名)[Password] (パスワード)

認証情報を自分のCouchbaseクラスターに入力します。

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

Couchbase V5.0以降ではパスワードがバケットに関連付けられなくなったため、該当するバージョンを使用している場合は、[Bucket] (バケット)フィールドに同じ値をパスワードとして入力してください。ただしCouchbaseでは、バケットにアクセスできるロールを持つユーザーを作成する必要があります。

Couchbaseサイドでのアクセスコントロールやその他の重要要件に関する詳細は、お使いのバージョンのCouchbaseリリースノートをご覧ください。

パスワードを入力するには、[Password] (パスワード)フィールドの横にある[...]ボタンをクリックし、[Enter a new password] (新しいパスワードを入力)ダイアログボックスを表示させ、テキストフィールドにパスワードを入力して[OK]をクリックします。パスワードは、[pure password] (純粋なパスワード)モードではJSON文字列で、[Java mode] (Javaモード)ではJava式として入力できます。テキストフィールドの上部にある[switch to Java mode] (Javaモードに切り替え)または[switch to pure password mode] (純粋なパスワードに切り替え)をクリックすることで、2つのモードの間で切り替えられます。
注:
  • この2つのパスワードモードは、Talendが提供する8.0.1 R2022-05以降のTalend Studioマンスリーアップデートをインストール済みである場合のみ利用できます。詳細は管理者にお問い合わせください。
  • Talendが提供する8.0.1 R2022-05以降のTalend Studioマンスリーアップデートがインストールされていない場合は、[Java mode] (Javaモード)でのみパスワードを入力できます。

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

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

JSON以外のドキュメントを使用する場合は、[String] (文字列)型のidカラムを定義してから、contentカラムを定義します。このcontentカラムのタイプは、文字列ドキュメントの場合は[String] (文字列)バイナリドキュメントの場合はbyte[] である必要があります。

JSONドキュメントについては、使用するJSONドキュメントに存在するフィールドを定義します。

[Bucket] (バケット)

Couchbaseデータベースにあるデータバケットの名前を二重引用符で囲んで入力します。

使用している認証情報に、このバケットにアクセスできる適切な権限があることを確認します。

Couchbase V5.0以降を使用している場合、使用するCouchbase UIの[Security] (セキュリティ)タブで作成したユーザー名がこのバケットの名前になります。

[Document type] (ドキュメントタイプ)

Couchbaseデータベースに保存されるデータは、JSON、文字列、バイナリのいずれかを入力します。このドロップダウンリストから、Couchbaseで使用する必要があるデータのタイプを選択します。

JSON、バイナリ、文字列のドキュメントを同じバケットに混在させることはお勧めしません。この混合により、ドキュメント処理でエラーが発生しやすくなる可能性があります。

[Field to use as ID] (IDとして使用するフィールド)

Couchbaseに書き込むドキュメントのIDを取得できるよう、スキーマからのカラム名を二重引用符で囲まずに入力します。

[Partial update] (部分アップデート)

受信データによって提供されない他のプロパティを変更せずに、ドキュメントのサブセットのみをアップデートするには、このチェックボックスをオンにします。

このチェックボックスをオフにすると、ドキュメントがデータベースに既に存在する場合、つまり、このドキュメントと受信データのドキュメントが同じIDを持つ場合、既存のドキュメント全体が受信ドキュメントに置き換えられます。

[Use N1QL Query with parameters] (N1QLクエリーをパラメーターと共に使う)

N1QLクエリーに変数を適用するには、このチェックボックスをオンにします。選択すると、[Query] (クエリー)フィールドと[Query Parameters wraps flat data into documents for storage in the Couchbase database.] (クエリーパラメーターはフラットデータをドキュメントにラップし、Couchbaseデータベースに保管します。)テーブルが表示され、クエリーを入力し、クエリーで使う変数を定義できます。

tCouchbaseOutputごとに許可されるクエリーは1つだけです。

たとえば、[Query] (クエリー)フィールドに次のクエリーを入力します。
INSERT INTO 'travel-sample' (KEY, VALUE)
VALUES 
($nm, 
   {
    "name":$nm, 
    "type":$tp, 
    "country":$cnty, 
    "callsign":$call,  
    "id":$zid
   }
)

次に、このクエリーの[Query Parameters] (クエリーパラメーター)テーブルで使われるすべての変数を定義する必要があります($で始まる文字列)。

Query Parameter Name     Column
nm                       name
tp                       type
cnty                     countries
call                     company
zid                      docid

このテーブルは、クエリーの変数と、データのコンポーネントで定義したスキーマのカラムの間のマップを作成します。[Column] (カラム)カラムの値は、このスキーマのカラム名です。[Query Parameter Name] (クエリーパラメーター名)カラムの値は、クエリーの変数です。

詳細設定

[tStatCatcher Statistics] (tStatCatcher統計)

このチェックボックスをオンにすると、コンポーネントレベルでログデータを収集できます。

[Use custom connection parameters] (カスタム接続パラメーターを使用)

このオプションを選択すれば、[Connection timeout] (接続タイムアウト)[Query timeout] (クエリータイムアウト)[Analytics timeout] (アナリティクスタイムアウト)[Query threshold] (クエリーしきい値)といった接続パラメーターを設定できます。

接続パラメーターを設定する場合は、テーブルの下部にあるプラスボタンをクリックして[Connection parameters] (接続パラメーター)テーブルに行を追加し、[Parameter name] (パラメーター名)カラムをクリックしてドロップダウンリストから目的のパラメーターを選択し、[Parameter value] (パラメーター値)カラムにパラメーター値を入力します。

[Use TLS] (TLSを使用)

転送されるデータを保護するようTLSを有効にする場合は、このオプションを選択します。関連情報はCouchbase TLSをご覧ください。

注: このオプションは、Talendが提供する8.0.1-R2022-06以降のTalend Studioマンスリーアップデートをインストール済みである場合のみ利用できます。詳細は管理者にお問い合わせください。

Java Truststore

TrustStoreのファイル名を入力します。関連情報はKeyStores and TrustStoresをご覧ください。

注: このオプションは、[Use TLS] (TLSを使用)オプションを選択した場合のみ利用できます。

Java TrustStore password (Java TrustStoreのパスワード)

TrustStoreファイルのパスワードを入力します。関連情報はGenerating a KeyStore and TrustStoreをご覧ください。

注: このオプションは、[Use TLS] (TLSを使用)オプションを選択した場合のみ利用できます。

[Java TrustStore type] (Java TrustStoreタイプ)

Java TrustStoreタイプを入力します。デフォルトでは、Java TrustStoreタイプがJKSとなっています。

注: このオプションは、[Use TLS] (TLSを使用)オプションを選択した場合のみ利用できます。

グローバル変数

グローバル変数

NB_LINE: 入力コンポーネントによって読み取られた行の数、または出力コンポーネントに転送された行の数。これはAfter変数で、整数を返します。

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

NB_REJECT: 拒否された行の数。これはAfter変数で、整数を返します。

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

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

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

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

使用方法

使用ルール

入力コンポーネント、tCouchbaseOutputが先行します