cassandra QueryHandlerで各クライアントのセッションを区別する方法はありますか？

Question

私の目的は、カスタムQueryHandler実装を記述することでセッションごとにユニークなクエリを記録することです。

ケースを検討する：ユーザがJavaクライアントでcassandraクラスタに接続し、「select * from users where id =？」を実行すると、 100回。 他のユーザーがcqlshから接続し、同じクエリを50回実行しました。だから私はこの場合2つのクエリだけを記録したい。そのためには、ログインごとに固有のセッションIDが必要です。

Cassandraは、すべてのリクエストが上がるが、そのapiのいずれも上記の2つの異なるセッションを区別するためのsessionIdを提供しないインターフェースを提供する。

org.apache.cassandra.cql3.QueryHandler 

注：私は[リモート/ポートを取得することができるが、私は、ユーザーがログインしたときに作成され、彼は切断時に破壊され得るいくつかのidをしたいです。

Answer 1

queryState.getClientState().getRemoteAddress()では、address + portは、セッションプール内のTCP接続ごとに一意になります。各接続で複数の同時リクエストが存在する可能性があり、セッションはホストごとに複数の接続を持つことができます。同じtcp接続がクライアント側のある要求から別の要求に使用されるという保証もありません。

ただし、1つのセッションを2人の異なるユーザー（接続の初期化の一部）として接続することはできません。そのため、説明したシナリオは同じセッションオブジェクトの観点からは不可能です。一意性の鍵としてアドレスを使用することは、プロトコル/ドライバがどのように動作するかを考えれば可能です。それは少なくとも物事を少しだけ控除します。

あなたは実際にログインをインラインで処理していますか、非同期でオフにしていますか？ logbackを使用している場合は、非同期アペンダを使用する必要がありますが、投稿したイベントが別のサーバと同期している場合は、すべてのイベントをキューに投げて、別のスレッドで重複排除を実行して待ち時間を傷つけないようにしてください。