# tCosmosDBOutput ジョブで、前のコンポーネントからの入力フローに基づいてCosmosデータベースコレクションでドキュメントを挿入、更新、アップサート、削除します。 デフォルトで、このコンポーネントはTalend Studioと共には出荷されていません。機能マネージャーを使ってインストールする必要があります。 詳細は、[機能マネージャーを使って機能をインストール](https://help.qlik.com/talend/r/ja-JP/8.0/studio-user-guide/install-features-to-talend-studio)をご覧ください。 ## tCosmosDBOutputの標準プロパティ これらのプロパティは、標準ジョブのフレームワークで実行されているtCosmosDBOutputを設定するために使われます。 標準のtCosmosDBOutputコンポーネントは、Cloudファミリーとデータベースファミリーに属しています。 このフレームワークのコンポーネントは、すべてのビッグデータ対応のTalend製品およびTalend Data Fabricで利用できます。 ## 基本設定 | [Properties] (プロパティ) | 説明 | | --- | --- | | [Use existing connection] (既存の接続を使用) | 定義済みの接続の詳細を再利用する場合は、このチェックボックスをオンにして、[Component List] (コンポーネントリスト)ドロップダウンリストから、目的の接続コンポーネントを選択します。 | | API | 使うデータベースAPIを選択します。定義が必要な対応するパラメーターが、[Component] (コンポーネント)ビューに表示されます。

このコンポーネントの現在のバージョンでは、MongoDB APIのみがサポートされています。このため、MongoDBデータベースはCosmosDBコンポーネントのドキュメンテーションで頻繁に言及されています。 | | [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] (レプリカセットのアドレスまたは複数クエリールーターを使用します)チェックボックスがオフの時に利用できます。 | | [Database] (データベース) | 接続先とするMongoDBデータベースの名前を入力します。 | | [Set write concern] (書き込み確認の設定) | このチェックボックスをオンにすると、書き込み操作で要求される確認レスポンスのレベルを設定できます。この操作のレベルを選択する必要があります。

詳細は、http://docs.mongodb.org/manual/core/write-concern/で、関連するMongoDBのドキュメンテーションをご覧ください。 | | [Bulk write] (バルク書き込み) | データを一括で挿入、アップデート、または削除するには、このチェックボックスをオンにします。この機能は、使っているMongoDBのバージョンが 2.6+の場合のみ利用できます。

[Ordered] (順序指定)または[Unordered] (順序指定なし)を選択して、MongoDBデータベースがTalend Studioによって送信されたデータを処理する方法を定義する必要があります。



[Bulk write size] (バルク書き込みサイズ)フィールドに、MongoDBによって処理する各クエリーグループのサイズを入力します。MongoDBのドキュメンテーションでは、このサイズに関する一部の制限と予想される動作が説明されています。詳細は、http://docs.mongodb.org/manual/core/bulk-write-operations/をご覧ください。 | | [Authentication mechanism] (認証メカニズム) | Kerberosを使用していない場合は、[Authentication mechanism] (認証メカニズム)ドロップダウンリストにリスト表示されているメカニズムのうち、[NEGOTIATE]が推奨されます。使用しているMongoデータベースバージョンに最もよく対応している認証メカニズムが自動的に選択されるためです。

このリスト内の他のメカニズムについては、MongoDBのドキュメンテーションで[MongoDB Authentication](https://docs.mongodb.org/manual/reference/parameters/#param.authenticationMechanisms)をご覧ください。 | | [Set Authentication database] (認証データベースの設定) | MongoDBへの接続に使用するユーザー名がMongoDBの特定の認証データベース内で作成済みの場合は、このチェックボックスをオンにして、表示される[Authentication database] (認証データベース)フィールドに、この認証データベースの名前を入力します。

MongoDB認証データベースについては、[User Authentication database](https://docs.mongodb.org/manual/core/security-users/#user-authentication-database)をご覧ください。 | | [Username] (ユーザー名)と[Password] (パスワード) | DBユーザー認証データ。

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

[Use Authentication] (認証を使用)チェックボックスがオンの場合に使えます。

[Authentication mechanism] (認証方式)ドロップダウンリストから、Kerberosをセキュリティシステムに選択した場合は、[Username] (ユーザー名)と[Password] (パスワード)のフィールドではなく、[User principal] (プリンシパルを使用)、[Realm] (レルム)、[KDC server] (KDCサーバー)のフィールドに入力します。 | | [Collection] (コレクション) | データベースのコレクションの名前。 | | [Drop collection if exist] (存在する場合はコレクションをドロップ) | このチェックボックスをオンにすると、既に存在する場合はコレクションが削除されます。 | | [Action on data] (データでのアクション) | 以下の操作を実行できます:

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

[Built-in] (組み込み): そのコンポーネントに対してのみスキーマを作成し、ローカルに保管します。

[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されています。さまざまなプロジェクトやジョブデザインで再利用できます。

再使用するスキーマに整数またはファンクションのデフォルト値が指定されている場合は、これらのデフォルト値を引用符で囲まないようにご注意ください。引用符で囲まれている場合は手動で削除します。

詳細は、[テーブルスキーマを取得](https://help.qlik.com/talend/r/ja-JP/8.0/studio-user-guide/retrieving-table-schemas?tocId=_C1~eFOlN~GM_JR2qkBYZg)をご覧ください。

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



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

このコンポーネントによって、コレクションにドキュメントを挿入する際にダイナミックスキーマがサポートされます。ダイナミックスキーマ機能を使用するためには、スキーマに含まれているカラムが1つだけであることを確認し、[DB column] (DBカラム)を\*に、そして[Type] (タイプ)を文字列に(入力タイプが文字列の場合)、またはオブジェクトに(入力タイプがオブジェクトの場合)に設定する必要があります。

情報メモ注:

| | Mapping | このコンポーネント用に定義されたスキーマの各カラムは、読み取るドキュメントのフィールドを表します。このテーブルで、これらのフィールドの親ノードがあればそれを指定する必要があります。

たとえば、次のようなドキュメントがあるとします。

```
{
_id: ObjectId("5099803df3f4948bd2f98391"),
person: { first: "Joe", last: "Walker" }
}
```


フィールド*first*および*last*には親ノード*person*がありますが、*\_id*フィールドには親ノードがありません。したがって、完了すると、この[Mapping]テーブルは次のようになります。

```
Column Parent node path
_id
first "person"
last "person"
```

[Advanced settings] (詳細設定)で[Generate JSON Document] (JSONドキュメントを生成)チェックボックスがオンになっている場合は利用できません。 | | [Die on error] (エラー発生時に強制終了) | このチェックボックスはデフォルトでオフになっています。すなわち、エラーが発生した行をスキップし、エラーが発生していない行のプロセスを完了させます。 | ## 詳細設定 | [Properties] (プロパティ) | 説明 | | --- | --- | | [Generate JSON Document] (JSONドキュメントを生成) | JSON設定のためにこのチェックボックスをオンにします。

[Configure JSON Tree] (JSONツリーを設定): [...]ボタンをクリックして、JSONツリー設定のインターフェイスを開きます。詳細は、[JSONツリーを設定](https://help.qlik.com/talend/r/ja-JP/8.0/components/processing/configuring-a-json-tree)をご覧ください。

[Create empty element if needed] (必要に応じて空のエレメント作成): XMLツリーエディターの[Related Column] (関連カラム)にNULL値がある場合、またはXMLノードに関連付けられているカラムがない場合、このオプションを実行すると予想される場所に開閉タグが作成されます。このチェックボックスはデフォルトで選択されています。

[Ignore service attributes for empty elements] (空のエレメントのサービス属性を無視する): このオプションを選択すると、入力ノードがnullであるにもかかわらずサービス属性(@type、@class、@arrayなど)を持つ場合に、コンポーネントがノードを生成することを防止できます。このオプションは、[Create empty element if needed] (必要に応じて空のエレメントを作成)オプションが選択されていない場合に利用可能です。

[Group by] (グループ基準): [+]ボタンをクリックして行を追加し、レコードを分類するための入力カラムを選択します。

[Remove root node] (ルートノードを削除): ルートノードを削除するには、このチェックボックスをオンにします。

[Data node] (データノード)と[Query node] (クエリーノード) (アップデートアクションとアップサートアクションで利用可能): JSONツリー上に設定されたデータノードとクエリーノードの名前を入力します。

これらのノードは、更新とアップサートのアクションに必須です。これらはデータベースには保管されませんが、更新とアップサートのアクションを有効にすることを目的としています。

[Node] (ノード) ([Set] (セット)アクションと[Upsert with set] (セットでアップサート)アクションで使用可能): 特定のJSONノードに対するアップデート操作を指定します。アップデート操作を追加するためには、このフィールドの下部にあるプラスボタンをクリックしてアップデート演算子を入力するか、[Node type] (ノードタイプ)カラムにあるドロップダウンリストからアップデート演算子を選択し、[Node reference] (ノード参照)カラムにノード名を二重引用符で囲んで入力します。アップデート演算子に関する情報は、[アップデート演算子](https://docs.mongodb.com/v4.4/reference/operator/update/)をご覧ください。

情報メモ注: このフィールドは、Talendが提供するR2022-01以降のTalend Studioマンスリーアップデートをインストール済みである場合のみ利用できます。詳細は管理者にお問い合わせください。 | | [No query timeout] (クエリータイムアウトなし) | アイドルカーソルの非アクティブ状態が10分間続いた時にMongoDBサーバーがカーソルを停止することを防ぐには、このチェックボックスをオンにします。この状況では、このカーソルの結果が枯渇するか、またはcursor.close()方式を使用して手動で閉じるまで、アイドルカーソルが開いたままとなります。

MongoDBのカーソルはクエリーの結果セットを指すポインターです。デフォルトでは、すなわち、このチェックボックスがオフの場合、Mongoデータベースサーバーは、メモリの過剰使用を避けるために、非アクティブ状態が特定の期間続くと、アイドルカーソルを自動的に停止します。MongoDBカーソルの詳細は、https://docs.mongodb.org/manual/core/cursors/をご覧ください。 | | [tStatCatcher Statistics] (tStatCatcher統計) | このチェックボックスをオンにすると、コンポーネントレベルでログデータを収集できます。 | ## 使用方法 | 使用方法のガイダンス | 説明 | | --- | --- | | **使用ルール** | tCosmosDBOutputは、ジョブ内の先行するコンポーネントからのフローをベースに、データベースのコレクションで定義されているアクションを実行します。 | | 制限事項 | |