第18章 Cassandra Sink
Apache Cassandra クラスターにデータを送信します。
この Kamelet は JSON 配列形式のデータを想定しています。JSON 配列の内容は、クエリーパラメーターに設定された CQL 準備済みステートメントの入力として使用されます。
18.1. 設定オプション リンクのコピーリンクがクリップボードにコピーされました!
次の表は、cassandra-sink Kamelet で使用できる設定オプションをまとめたものです。
| プロパティー | 名前 | 説明 | 型 | デフォルト | 例 |
|---|---|---|---|---|---|
| connectionHost * | Connection Host | Cassandra サーバーのホスト名。複数のホスト名を区切るにはコンマを使用します。 | string | localhost | |
| connectionPort * | Connection Port | Cassandra サーバーのポート番号。複数のポート番号を区切るには、コンマを使用します。 | string | 9042 | |
| keyspace* | Keyspace | 使用するキースペース。 | string | customers | |
| query* | Query | Cassandra クラスターテーブルに対して実行するクエリー | string | ||
| consistencyLevel | Consistency Level | 使用する一貫性レベル。 | string | ANY | |
| extraTypeCodecs | Extra Type Codecs | 特定のコンマ区切りの Extra Type コーデックのリストを使用します。 | string | ||
| jsonPayload | JSON Payload | ペイロードを JSON に変換するかどうか | boolean | True | |
| password | Password | 保護された Cassandra クラスターにアクセスするためのパスワード。 | string | ||
| prepareStatements | Prepare Statements | true の場合、クエリーとして PreparedStatements を使用するように指定します。false の場合、クエリーとして通常のステートメントを使用するように指定します。 | boolean | True | |
| username | Username | 保護された Cassandra クラスターにアクセスするためのユーザー名。 | string |
* = アスタリスクの付いたフィールドは 必須 です。