第15章 Cassandra Sink
データを Cassandra クラスターに送信します。
この Kamelet はボディーを JSON アレイとして想定します。JSON アレイの内容は、クエリーパラメーターに設定された CQL Prepared Statement の入力として使用されます。
15.1. 設定オプション
次の表は、cassandra-sink
Kamelet で使用できる設定オプションをまとめたものです。
プロパティー | 名前 | 説明 | 型 | デフォルト | 例 |
---|---|---|---|---|---|
connectionHost * | 接続ホスト | Hostname(s) cassandra server(s).複数のホストはコンマで区切ることができます。 | string |
| |
connectionPort * | 接続ポート | cassandra サーバーのポート番号 | string |
| |
keyspace * | キースペース | 使用するキースペース | string |
| |
Password * | Password | セキュアな Cassandra クラスターへのアクセスに使用するパスワード | string | ||
query * | クエリー | Cassandra クラスターテーブルに対して実行するクエリー | string | ||
username * | Username | セキュアな Cassandra クラスターへのアクセスに使用するユーザー名 | string | ||
consistencyLevel | 一貫性レベル | 使用する一貫性レベル。値には、ANY、ONE、TWO、THREE、QUORUM、ALL、LOCAL_QUORUM、EACH_QUORUM、EACH_QUORUM、LOCAL_SERIAL、LOCAL_ONE のいずれかを指定できます。 | string |
|
アスタリスク (*) のマークが付いたフィールドは必須です。