Cassandra
可以使用 DDTrace 采集 Cassandra 指标。采集数据流向如下:Cassandra -> DDTrace -> DataKit(StatsD)。
可以看到 DataKit 已经集成了 StatsD 的服务端,DDTrace 采集 Cassandra 的数据后使用 StatsD 的协议报告给了 Datakit。
配置¶
前置条件¶
-
已测试的版本:
- 5.0
- 4.1.3
- 3.11.15
- 3.0.24
- 2.1.22
-
下载
dd-java-agent.jar
包,参见 这里; -
Datakit 侧:参见 StatsD 的配置。
-
Cassandra 侧:
在 /usr/local/cassandra/bin 下创建文件 setenv.sh 并赋予执行权限,再写入以下内容:
export CATALINA_OPTS="-javaagent:dd-java-agent.jar \
-Ddd.jmxfetch.enabled=true \
-Ddd.jmxfetch.statsd.host=${DATAKIT_HOST} \
-Ddd.jmxfetch.statsd.port=${DATAKIT_STATSD_HOST} \
-Ddd.jmxfetch.cassandra.enabled=true"
参数说明如下:
javaagent
: 这个填写dd-java-agent.jar
的完整路径;Ddd.jmxfetch.enabled
: 填true
, 表示开启 DDTrace 的采集功能;Ddd.jmxfetch.statsd.host
: 填写 Datakit 监听的网络地址。不含端口号;Ddd.jmxfetch.statsd.port
: 填写 Datakit 监听的端口号。一般为11002
,由 Datakit 侧的配置决定;Ddd.jmxfetch.Cassandra.enabled
: 填true
, 表示开启 DDTrace 的 Cassandra 采集功能。开启后会多出名为cassandra
的指标集;
重启 Cassandra 使配置生效。
采集器配置¶
进入 DataKit 安装目录下的 conf.d/db
目录,复制 cassandra.conf.sample
并命名为 cassandra.conf
。示例如下:
[[inputs.statsd]]
## Collector alias.
source = "statsd/cassandra"
## Collect interval, default is 10 seconds. (optional)
# interval = '10s'
protocol = "udp"
## Address and port to host UDP listener on: (defaults to ":8125")
service_address = ":11002"
## Tag request metric. Used for distinguish feed metric name.
## eg, DD_TAGS=source_key:tomcat,host_key:cn-shanghai-sq5ei
## eg, -Ddd.tags=source_key:tomcat,host_key:cn-shanghai-sq5ei
# statsd_source_key = "source_key"
# statsd_host_key = "host_key"
## Indicate whether report tag statsd_source_key and statsd_host_key.
# save_above_key = false
delete_gauges = true
delete_counters = true
delete_sets = true
delete_timings = true
## Counter metric is float in new Datakit version, set true if want be int.
# set_counter_int = false
## Percentiles to calculate for timing & histogram stats
percentiles = [50.0, 90.0, 99.0, 99.9, 99.95, 100.0]
## separator to use between elements of a statsd metric
metric_separator = "_"
## Parses tags in the datadog statsd format
## http://docs.datadoghq.com/guides/dogstatsd/
parse_data_dog_tags = true
## Parses datadog extensions to the statsd format
datadog_extensions = true
## Parses distributions metric as specified in the datadog statsd format
## https://docs.datadoghq.com/developers/metrics/types/?tab=distribution#definition
datadog_distributions = true
## We do not need following tags(they may create tremendous of time-series under influxdb's logic)
## Examples:
## "runtime-id", "metric-type"
drop_tags = [ ]
## All metric-name prefixed with 'jvm_' are set to influxdb's measurement 'jvm'
## All metric-name prefixed with 'stats_' are set to influxdb's measurement 'stats'
## Attention: Must add these word in statsd conf file.
metric_mapping = ["cassandra_:cassandra", "jvm_:cassandra_jvm", "jmx_:cassandra_jmx", "datadog_:cassandra_datadog"]
## Number of UDP messages allowed to queue up, once filled,
## the statsd server will start dropping packets, default is 128.
# allowed_pending_messages = 128
## Number of timing/histogram values to track per-measurement in the
## calculation of percentiles. Raising this limit increases the accuracy
## of percentiles but also increases the memory usage and cpu time.
percentile_limit = 1000
## Max duration (TTL) for each metric to stay cached/reported without being updated.
# max_ttl = "1000h"
[inputs.statsd.tags]
# some_tag = "some_value"
# more_tag = "some_other_value"
配置好后,重启 DataKit 即可。
可通过 ConfigMap 方式注入采集器配置 或 配置 ENV_DATAKIT_INPUTS 开启采集器。
指标¶
cassandra
¶
- 标签
Tag | Description |
---|---|
columnfamily |
'columnfamily'=batches 'columnfamily'=built_views 'columnfamily'=columns 'columnfamily'='paxos' 'columnfamily'=peer |
host |
Host name. |
instance |
Instance name. |
jmx_domain |
JMX domain. |
keyspace |
'keyspace'=system 'keyspace'=system_schema |
metric_type |
Metric type. |
name |
Type name. |
path |
path=request |
runtime-id |
Runtime id. |
scope |
scope=ReadStage scope=MutationStage scope=HintsDispatcher scope='MemtableFlushWriter' scope='MemtablePostFlush' |
service |
Service name. |
table |
table=IndexInfo,table=available_ranges,table=batches,table=built_views, |
type |
Object type. |
- 指标列表
Metric | Description | Type | Unit |
---|---|---|---|
active_tasks |
The number of tasks that the thread pool is actively executing. | float | count |
bloom_filter_false_ratio |
The ratio of Bloom filter false positives to total checks. | float | count |
bytes_flushed_count |
The amount of data that was flushed since (re)start. | float | B |
cas_commit_latency_75th_percentile |
The latency of 'paxos' commit round - p75. | float | ms |
cas_commit_latency_95th_percentile |
The latency of 'paxos' commit round - p95. | float | ms |
cas_commit_latency_one_minute_rate |
The number of 'paxos' commit round per second. | float | req/s |
cas_prepare_latency_75th_percentile |
The latency of 'paxos' prepare round - p75. | float | ms |
cas_prepare_latency_95th_percentile |
The latency of 'paxos' prepare round - p95. | float | ms |
cas_prepare_latency_one_minute_rate |
The number of 'paxos' prepare round per second. | float | req/s |
cas_propose_latency_75th_percentile |
The latency of 'paxos' propose round - p75. | float | ms |
cas_propose_latency_95th_percentile |
The latency of 'paxos' propose round - p95. | float | ms |
cas_propose_latency_one_minute_rate |
The number of 'paxos' propose round per second. | float | req/s |
col_update_time_delta_histogram_75th_percentile |
The column update time delta - p75. | float | ms |
col_update_time_delta_histogram_95th_percentile |
The column update time delta - p95. | float | ms |
col_update_time_delta_histogram_min |
The column update time delta - min. | float | ms |
compaction_bytes_written_count |
The amount of data that was compacted since (re)start. | float | B |
compression_ratio |
The compression ratio for all SSTables. A low value means a high compression contrary to what the name suggests. Formula used is: 'size of the compressed SSTable / size of original' | float | percent |
currently_blocked_tasks |
The number of currently blocked tasks for the thread pool. | float | count |
currently_blocked_tasks_count |
The number of currently blocked tasks for the thread pool. | float | count |
db_droppable_tombstone_ratio |
The estimate of the droppable tombstone ratio. | float | percent |
dropped_one_minute_rate |
The tasks dropped during execution for the thread pool. | float | count |
exceptions_count |
The number of exceptions thrown from 'Storage' metrics. | float | count |
key_cache_hit_rate |
The key cache hit rate. | float | count |
latency_75th_percentile |
The client request latency - p75. | float | ms |
latency_95th_percentile |
The client request latency - p95. | float | ms |
latency_one_minute_rate |
The number of client requests. | float | req/s |
live_disk_space_used_count |
The disk space used by live SSTables (only counts in use files). | float | B |
live_ss_table_count |
Number of live (in use) SSTables. | float | count |
load_count |
The disk space used by live data on a node. | float | B |
max_partition_size |
The size of the largest compacted partition. | float | B |
max_row_size |
The size of the largest compacted row. | float | B |
mean_partition_size |
The average size of compacted partition. | float | B |
mean_row_size |
The average size of compacted rows. | float | B |
metrics_75th_percentile |
Metrics - p75. | float | count |
metrics_95th_percentile |
Metrics - p95. | float | count |
metrics_count |
Metrics count. | float | count |
metrics_one_minute_rate |
The number of metrics. | float | count |
metrics_value |
Metrics value. | float | count |
net_down_endpoint_count |
The number of unhealthy nodes in the cluster. They represent each individual node's view of the cluster and thus should not be summed across reporting nodes. | float | count |
net_up_endpoint_count |
The number of healthy nodes in the cluster. They represent each individual node's view of the cluster and thus should not be summed across reporting nodes. | float | count |
nodetool_status_load |
Amount of file system data under the 'cassandra' data directory without snapshot content. | float | B |
nodetool_status_owns |
Percentage of the data owned by the node per data center times the replication factor. | float | percent |
nodetool_status_replication_availability |
Percentage of data available per 'keyspace' times replication factor. | float | percent |
nodetool_status_replication_factor |
Replication factor per 'keyspace'. | float | count |
nodetool_status_status |
Node status: up (1) or down (0). | float | bool |
pending_compactions |
The number of pending compactions. | float | count |
pending_flushes_count |
The number of pending flushes. | float | count |
pending_tasks |
The number of pending tasks for the thread pool. | float | count |
range_latency_75th_percentile |
The local range request latency - p75. | float | ms |
range_latency_95th_percentile |
The local range request latency - p95. | float | ms |
range_latency_one_minute_rate |
The number of local range requests. | float | req/s |
read_latency_75th_percentile |
The local read latency - p75. | float | ms |
read_latency_95th_percentile |
The local read latency - p95. | float | ms |
read_latency_99th_percentile |
The local read latency - p99. | float | ms |
read_latency_one_minute_rate |
The number of local read requests. | float | req/s |
row_cache_hit_count |
The number of row cache hits. | float | count |
row_cache_hit_out_of_range_count |
The number of row cache hits that do not satisfy the query filter and went to disk. | float | count |
row_cache_miss_count |
The number of table row cache misses. | float | count |
snapshots_size |
The disk space truly used by snapshots. | float | B |
ss_tables_per_read_histogram_75th_percentile |
The number of SSTable data files accessed per read - p75. | float | count |
ss_tables_per_read_histogram_95th_percentile |
The number of SSTable data files accessed per read - p95. | float | count |
timeouts_count |
Count of requests not acknowledged within configurable timeout window. | float | count |
timeouts_one_minute_rate |
Recent timeout rate, as an exponentially weighted moving average over a one-minute interval. | float | count |
tombstone_scanned_histogram_75th_percentile |
Number of tombstones scanned per read - p75. | float | count |
tombstone_scanned_histogram_95th_percentile |
Number of tombstones scanned per read - p95. | float | count |
total_blocked_tasks |
Total blocked tasks | float | count |
total_blocked_tasks_count |
Total count of blocked tasks | float | count |
total_commit_log_size |
The size used on disk by commit logs. | float | B |
total_disk_space_used_count |
Total disk space used by SSTables including obsolete ones waiting to be garbage collected | float | B |
view_lock_acquire_time_75th_percentile |
The time taken acquiring a partition lock for materialized view updates - p75. | float | ms |
view_lock_acquire_time_95th_percentile |
The time taken acquiring a partition lock for materialized view updates - p95. | float | ms |
view_lock_acquire_time_one_minute_rate |
The number of requests to acquire a partition lock for materialized view updates. | float | count |
view_read_time_75th_percentile |
The time taken during the local read of a materialized view update - p75. | float | ms |
view_read_time_95th_percentile |
The time taken during the local read of a materialized view update - p95. | float | ms |
view_read_time_one_minute_rate |
The number of local reads for materialized view updates. | float | count |
waiting_on_free_memtable_space_75th_percentile |
The time spent waiting for free mem table space either on- or off-heap - p75. | float | ms |
waiting_on_free_memtable_space_95th_percentile |
The time spent waiting for free mem table space either on- or off-heap - p95. | float | ms |
write_latency_75th_percentile |
The local write latency - p75. | float | ms |
write_latency_95th_percentile |
The local write latency - p95. | float | ms |
write_latency_99th_percentile |
The local write latency - p99. | float | ms |
write_latency_one_minute_rate |
The number of local write requests. | float | req/s |
cassandra_jvm
¶
- 标签
Tag | Description |
---|---|
host |
Host name. |
instance |
Instance name. |
jmx_domain |
JMX domain. |
metric_type |
Metric type. |
name |
Type name. |
runtime-id |
Runtime id. |
service |
Service name. |
type |
Object type. |
- 指标列表
Metric | Description | Type | Unit |
---|---|---|---|
buffer_pool_direct_capacity |
Measure of total memory capacity of direct buffers. | float | B |
buffer_pool_direct_count |
Number of direct buffers in the pool. | float | count |
buffer_pool_direct_used |
Measure of memory used by direct buffers. | float | B |
buffer_pool_mapped_capacity |
Measure of total memory capacity of mapped buffers. | float | B |
buffer_pool_mapped_count |
Number of mapped buffers in the pool. | float | count |
buffer_pool_mapped_used |
Measure of memory used by mapped buffers. | float | B |
cpu_load_process |
Recent CPU utilization for the process. | float | percent |
cpu_load_system |
Recent CPU utilization for the whole system. | float | percent |
daemon_code_cache_used |
The number of daemon threads. | float | count |
daemon_thread_count |
Daemon thread count. | float | count |
gc_cms_count |
The total number of garbage collections that have occurred. | float | count |
gc_code_cache_used |
GC code cache used. | float | count |
gc_eden_size |
The 'eden' size in garbage collection. | float | B |
gc_major_collection_count |
The rate of major garbage collections. Set new_gc_metrics: true to receive this metric. | float | count |
gc_major_collection_time |
The fraction of time spent in major garbage collection. Set new_gc_metrics: true to receive this metric. | float | PPM |
gc_metaspace_size |
The metaspace size in garbage collection. |
float | B |
gc_minor_collection_count |
The rate of minor garbage collections. Set new_gc_metrics: true to receive this metric. | float | count |
gc_minor_collection_time |
The fraction of time spent in minor garbage collection. Set new_gc_metrics: true to receive this metric. | float | PPM |
gc_old_gen_size |
The ond gen size in garbage collection. | float | B |
gc_parnew_time |
The approximate accumulated garbage collection time elapsed. | float | ms |
gc_survivor_size |
The survivor size in garbage collection. | float | B |
heap_memory |
The total Java heap memory used. | float | B |
heap_memory_committed |
The total Java heap memory committed to be used. | float | B |
heap_memory_init |
The initial Java heap memory allocated. | float | B |
heap_memory_max |
The maximum Java heap memory available. | float | B |
loaded_classes |
Number of classes currently loaded. | float | count |
non_heap_memory |
The total Java non-heap memory used. Non-heap memory is: Metaspace + CompressedClassSpace + CodeCache . |
float | B |
non_heap_memory_committed |
The total Java non-heap memory committed to be used. | float | B |
non_heap_memory_init |
The initial Java non-heap memory allocated. | float | B |
non_heap_memory_max |
The maximum Java non-heap memory available. | float | B |
os_open_file_descriptors |
The number of file descriptors used by this process (only available for processes run as the dd-agent user) | float | count |
peak_thread_count |
The peak number of live threads. | float | count |
thread_count |
The number of live threads. | float | count |
total_thread_count |
The number of total threads. | float | count |
cassandra_jmx
¶
- 标签
Tag | Description |
---|---|
host |
Host name. |
instance |
Instance name. |
jmx_domain |
JMX domain. |
metric_type |
Metric type. |
name |
Type name. |
runtime-id |
Runtime id. |
service |
Service name. |
type |
Object type. |
- 指标列表
Metric | Description | Type | Unit |
---|---|---|---|
gc_cms.count |
The total number of garbage collections that have occurred. | float | count |
gc_major_collection_count |
The rate of major garbage collections. Set new_gc_metrics: true to receive this metric. | float | count |
gc_major_collection_time |
The fraction of time spent in major garbage collection. Set new_gc_metrics: true to receive this metric. | float | PPM |
gc_minor_collection_count |
The rate of minor garbage collections. Set new_gc_metrics: true to receive this metric. | float | count |
gc_minor_collection_time |
The fraction of time spent in minor garbage collection. Set new_gc_metrics: true to receive this metric. | float | PPM |
gc_parnew.time |
The approximate accumulated garbage collection time elapsed. | float | ms |
heap_memory |
The total Java heap memory used. | float | B |
heap_memory_committed |
The total Java heap memory committed to be used. | float | B |
heap_memory_init |
The initial Java heap memory allocated. | float | B |
heap_memory_max |
The maximum Java heap memory available. | float | B |
non_heap_memory |
The total Java non-heap memory used. Non-heap memory is calculated as follows: 'Metaspace' + CompressedClassSpace + CodeCache | float | B |
non_heap_memory_committed |
The total Java non-heap memory committed to be used. | float | B |
non_heap_memory_init |
The initial Java non-heap memory allocated. | float | B |
non_heap_memory_max |
The maximum Java non-heap memory available. | float | B |
thread_count |
The number of live threads. | float | count |
cassandra_datadog
¶
- 标签
Tag | Description |
---|---|
endpoint |
Endpoint. |
host |
Host name. |
lang |
Lang type. |
lang_interpreter |
Lang interpreter. |
lang_interpreter_vendor |
Lang interpreter vendor. |
lang_version |
Lang version. |
metric_type |
Metric type. |
priority |
Priority. |
service |
Service name. |
stat |
Stat. |
tracer_version |
Tracer version. |
- 指标列表
Metric | Description | Type | Unit |
---|---|---|---|
tracer_agent_discovery_time |
Tracer agent discovery time. | float | ms |
tracer_api_errors_total |
Tracer api errors total. | float | count |
tracer_api_requests_total |
Tracer api requests total. | float | count |
tracer_flush_bytes_total |
Tracer flush bytes total. | float | count |
tracer_flush_traces_total |
Tracer flush traces total. | float | count |
tracer_queue_enqueued_bytes |
Tracer queue enqueued bytes. | float | count |
tracer_queue_enqueued_spans |
Tracer queue enqueued spans. | float | count |
tracer_queue_enqueued_traces |
Tracer queue enqueued traces. | float | count |
tracer_queue_max_length |
Tracer queue max length. | float | count |
tracer_scope_activate_count |
Tracer scope activate count. | float | count |
tracer_scope_close_count |
Tracer scope close count. | float | count |
tracer_span_pending_created |
Tracer span pending created. | float | count |
tracer_span_pending_finished |
Tracer span pending finished. | float | count |
tracer_trace_agent_discovery_time |
Tracer trace agent discovery time. | float | count |
tracer_trace_agent_send_time |
Tracer trace agent send time. | float | count |
tracer_trace_pending_created |
Tracer trace pending created. | float | count |
tracer_tracer_trace_buffer_fill_time |
Tracer trace buffer fill time. | float | count |