tCosmosDBBulkLoad標準プロパティ - 7.2

CosmosDB

Version
7.2
Language
日本語 (日本)
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
ジョブデザインと開発 > サードパーティーシステム > DBコンポーネント > CosmosDBコンポーネント
データガバナンス > サードパーティーシステム > DBコンポーネント > CosmosDBコンポーネント
データクオリティとプレパレーション > サードパーティーシステム > DBコンポーネント > CosmosDBコンポーネント

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

Standard tCosmosDBBulkLoadコンポーネントはCloudファミリーとデータベースファミリーのコンポーネントです。

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

基本設定

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

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

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

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

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

  • [Update repository connection] (リポジトリー接続を更新): リポジトリーに保存されているスキーマに変更を加え、変更後にそのコンテンツをすべてのジョブにプロパゲートするかどうかを決める場合は、このオプションを選択します。変更を現在のジョブにのみ反映する場合は、変更後、[No] (いいえ)を選択し、[Repository Content] (リポジトリーのコンテンツ)ウィンドウで再びこのスキーマのメタデータを選択します。

[MongoDB directory] (MongoDBディレクトリー)

このフィールドにMongoDBホームディレクトリーを入力します。

[Use replica set address or multiple query routers] (レプリカセットのアドレスまたは複数クエリールーターを使用します)

このチェックボックスをオンにして[Server addresses] (サーバーアドレス)テーブルを表示します。

[Server addresses] (サーバーアドレス)テーブルで、接続先とするシャードMongoDBデータベースまたはMongoDBレプリカセットを定義します。

[Server] (サーバー)[Port] (ポート)

データベースサーバーのIPアドレスとリスニングポート番号を入力します。

[Use replica set address or multiple query routers] (レプリカセットのアドレスまたは複数クエリールーターを使用します)チェックボックスがオフの時に使用できます。

データベース

接続先とするMongoDBデータベースの名前を入力します。

[Collection] (コレクション)

データのインポート先となるコレクションの名前を入力します。

[Drop collection if exist] (存在する場合はコレクションをドロップ)

このチェックボックスをオンにすると、既に存在する場合はコレクションが削除されます。

[Authentication mechanism] (認証メカニズム)

Kerberosを使用していない場合は、[Authentication mechanism] (認証メカニズム)ドロップダウンリストにリスト表示されているメカニズムのうち、[NEGOTIATE]が推奨されます。使用しているMongoDBバージョンに最もよく対応している認証メカニズムが自動的に選択されるためです。

このリスト内の他のメカニズムについては、MongoDBのドキュメンテーションでMongoDB Authenticationを参照してください。

[Set Authentication database] (認証データベースの設定)

MongoDBへの接続に使用するユーザー名がMongoDBの特定の認証データベース内で作成済みの場合は、このチェックボックスをオンにして、表示される[Authentication database] (認証データベース)フィールドに、この認証データベースの名前を入力します。

MongoDB認証データベースについては、User Authentication databaseを参照してください。

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

DBユーザー認証データ。

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

[Required authentication] (認証の要求)チェックボックスが選択されている場合に使用できます。

[Authentication mechanism] (認証方式)ドロップダウンリストでKerberosをセキュリティシステムに選択した場合は、[Username] (ユーザー名)[Password] (パスワード)のフィールドではなく、[User principal] (プリンシパルを使用)[Realm] (レルム)[KDC server] (KDCサーバー)のフィールドに入力します。

[Data file] (データファイル)

データのインポート元ファイルの完全パスを入力するか、[...]ボタンをクリックして目的のデータファイルを参照します。

データファイルが標準形式になっていることを確認します。たとえば、CSVファイルのフィールドはコンマで区切る必要があります。

[File type] (ファイルタイプ)

リストから適切なファイルの種類を選択します。CSV、TSV、およびJSONがサポートされています。

[The JSON file starts with an array] (JSONファイルは配列で始まる)

このチェックボックスをオンにすると、tCosmosDBBulkloadでは配列で始まるJSONファイルを読み取れます。

このチェックボックスは、選択した[File type] (ファイルタイプ)がJSONの場合に表示されます。

[Action on data] (データへのアクション)

データに対して実行する操作を選択します。

  • [Insert] (挿入): データをデータベースに挿入します。

    CSVまたはTSVファイルからMongoDBデータベースにデータを挿入する場合は[First line is header] (最初の行をヘッダーにする)チェックボックスをオンにするか、スキーマでフィールドを定義する必要があります。

  • [Upsert] (アップサート): データが存在しない場合は挿入し、存在する場合は既存のデータを更新します。

    MongoDBデータベースでデータのアップサートを行う場合、アップサート操作のクエリー部分のフィールドリストを指定する必要があることにご注意ください。

[Upsert fields] (アップサートフィールド)

必要に応じてアップサートするフィールドをカスタマイズします。

このテーブルは[Action on data] (データの操作)リストから[Upsert] (アップサート)を選択した場合に使用できます。

[First line is header] (最初の行をヘッダーにする)

このチェックボックスをオンにすると、CSVまたはTSVファイルの最初の行をヘッダーとして使用できます。

このチェックボックスは、[File type] (ファイルタイプ)リストからCSVまたはTSVを選択した場合にのみ使用できます。

[Ignore blanks] (空白を無視)

このチェックボックスをオンにすると、CSVまたはTSVファイルの空のフィールドを無視できます。

このチェックボックスは、[File type] (ファイルタイプ)リストからCSVまたはTSVを選択した場合にのみ使用できます。

[Print log] (ログの印刷)

このチェックボックスをオンにすると、ログを印刷できます。

詳細設定

[Additional arguments] (追加の引数)

必要に応じて、追加の引数を使用するには、このテーブルの入力を完了します。

たとえば、引数--jsonArrayを使用して、単一のJSON配列内の複数のMongoDBドキュメントで表されるデータのインポートを受け入れることができます。その他の引数の詳細は、http://docs.mongodb.org/manual/reference/program/mongoimport/に移動し、オプションの説明を参照してください。

[tStatCatcher Statistics] (tStatCatcher統計)

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

使用方法

使用ルール

このコンポーネントは、tCosmosDBInputコンポーネントと共に使い、データが正しくインポートされたかどうかを確認できます。

制限事項

MongoDBクライアントツールは、このコンポーネントを使用するジョブが実行されるマシンにインストールしておく必要があります。