0

Cassandra にデータを保存する場合、保存の 70% のパフォーマンスには約 4 ~ 8 ミリ秒かかります。しかし、リクエストの 30% は約 80 ~ 90 ミリ秒かかります。そのため、一部のリクエストに時間がかかる理由を突き止めようとしています。私の疑いでは、これらのリクエストのためにデータセンターを通過している可能性がありますが、確認できません.

また、astyanax を使用する場合は、localhost にピン留めします。これは、ローカルの cassandra コーディネーターに接続するのに役立ちます。ここで使用される主キーは、生成された UUID です。

この問題を解決できる人がいれば、本当に感謝しています。

Write Consistency: CL_ONE
Read Consistency: CL_LOCAL_QUORUM

using Astyanax for java client: 1.56.37
Cassandra version: 1.2.5

キースペース情報は次のとおりです。

CREATE KEYSPACE grd WITH replication = {
  'class': 'NetworkTopologyStrategy',
  'HYWRCA02': '2',
  'CHRLNCUN': '2'
};

CREATE TABLE route (
  routeid uuid PRIMARY KEY,
  allowdynamicstickyness boolean,
  businesskey uuid,
  createdby text,
  createdtimestamp timestamp,
  datapartitionkeyselectorref text,
  deletedby text,
  deletedtimestamp timestamp,
  envcontext text,
  lockedbyuser text,
  partner text,
  routelocationlatitudeselector double,
  routelocationlongitudeselector double,
  routelocationmaxdistanceselector double,
  routename text,
  sequence int,
  serviceidentifier text,
  stalenessinmins int,
  status text,
  stickykeyselector text,
  tags set<text>,
  type text,
  updatedby text,
  updatedtimestamp timestamp,
  versionmapnameref text,
  versionselector text
) WITH
  bloom_filter_fp_chance=0.010000 AND
  caching='ALL' AND
  comment='' AND
  dclocal_read_repair_chance=0.000000 AND
  gc_grace_seconds=864000 AND
  read_repair_chance=0.100000 AND
  replicate_on_write='true' AND
  populate_io_cache_on_flush='false' AND
  compaction={'class': 'LeveledCompactionStrategy'} AND
  compression={'sstable_compression': 'SnappyCompressor'};

ありがとう。

4

1 に答える 1

0

クラスタのノードの 1 つにログインして cqlsh を実行し、USE を使用してキースペースを選択してみてください。

[root@yournode ~]# cqlsh
Connected to YourCluster at localhost:9160.
[cqlsh 3.1.2 | Cassandra 1.2.6 | CQL spec 3.0.0 | Thrift protocol 19.36.0]
Use HELP for help.
cqlsh> use yourkeyspacehere ;

この後、cqlsh でコマンドのトレースを実行します。

cqlsh:yourkeyspacehere> tracing on
Now tracing requests.

次に、異なるキーを使用してテーブルに対して異なるクエリを実行し、クエリに関係するノードの時間と IP をチェックして、データセンター間接続があるかどうかを確認します。サンプル出力は次のようになります。

select * from your_table_name_is_here limit 1;

Tracing session: 1ab19ff0-2fa3-11e3-a9aa-2face31554b7

 activity                                                                                        | timestamp    | source         | source_elapsed
-------------------------------------------------------------------------------------------------+--------------+----------------+----------------
                                                                              execute_cql3_query | 22:52:12,528 | XXX.XX.XXX.XXX |              0
                                          Parsing select * from your_table_name_is_here limit 1; | 22:52:12,529 | XXX.XX.XXX.XXX |           1108
                                                                              Peparing statement | 22:52:12,530 | XXX.XX.XXX.XXX |           1555
                                                                   Determining replicas to query | 22:52:12,530 | XXX.XX.XXX.XXX |           1643
                                                           Message received from /XXX.XX.XXX.XXX | 22:52:12,534 | YYY.YY.YYY.YYY |             34
                                                            Enqueuing request to /YYY.YY.YYY.YYY | 22:52:12,536 | XXX.XX.XXX.XXX |           7549
                                                              Sending message to /YYY.YY.YYY.YYY | 22:52:12,536 | XXX.XX.XXX.XXX |           7812
 Executing seq scan across 9 sstables for [min(-9223372036854775808), max(-8721075978151533877)] | 22:52:12,538 | YYY.YY.YYY.YYY |           3609
                                                                    Scanned 1 rows and matched 1 | 22:52:12,550 | YYY.YY.YYY.YYY |          15977
                                                           Enqueuing response to /XXX.XX.XXX.XXX | 22:52:12,550 | YYY.YY.YYY.YYY |          16035
                                                              Sending message to /XXX.XX.XXX.XXX | 22:52:12,550 | YYY.YY.YYY.YYY |          16202
                                                           Message received from /YYY.YY.YYY.YYY | 22:52:12,557 | XXX.XX.XXX.XXX |          28494
                                                        Processing response from /YYY.YY.YYY.YYY | 22:52:12,557 | XXX.XX.XXX.XXX |          28647
                                                                                Request complete | 22:52:12,556 | XXX.XX.XXX.XXX |          28884

それが役に立てば幸い!

于 2013-10-07T23:01:40.703 に答える