可观察性

Agent

源码编译

从 Github 下载 Apache ShardingSphere 源码，对源码进行编译，操作命令如下。

  1. git clone --depth 1 https://github.com/apache/shardingsphere.git
  2. cd shardingsphere
  3. mvn clean install -DskipITs -DskipTests -Prelease

Agent 制品 distribution/agent/target/apache-shardingsphere-${latest.release.version}-shardingsphere-agent-bin.tar.gz

Proxy 制品 distribution/proxy/target/apache-shardingsphere-${latest.release.version}-shardingsphere-proxy-bin.tar.gz

目录说明

创建 agent 目录，解压 agent 二进制包到 agent 目录。

  1. mkdir agent
  2. tar -zxvf apache-shardingsphere-${latest.release.version}-shardingsphere-agent-bin.tar.gz -C agent
  3. cd agent
  4. tree 
  5. ├── LICENSE
  6. ├── NOTICE
  7. ├── conf
  8. │   └── agent.yaml
  9. ├── plugins
  10. │   ├── lib
  11. │   │   ├── shardingsphere-agent-metrics-core-${latest.release.version}.jar
  12. │   │   └── shardingsphere-agent-plugin-core-${latest.release.version}.jar
  13. │   ├── logging
  14. │   │   └── shardingsphere-agent-logging-file-${latest.release.version}.jar
  15. │   ├── metrics
  16. │   │   └── shardingsphere-agent-metrics-prometheus-${latest.release.version}.jar
  17. │   └── tracing
  18. │       ├── shardingsphere-agent-tracing-opentelemetry-${latest.release.version}.jar
  19. └── shardingsphere-agent-${latest.release.version}.jar

配置说明

conf/agent.yaml 用于管理 agent 配置。内置插件包括 File、Prometheus、OpenTelemetry。

  1. plugins:
  2. #  logging:
  3. #    File:
  4. #      props:
  5. #        level: "INFO"
  6. #  metrics:
  7. #    Prometheus:
  8. #      host:  "localhost"
  9. #      port: 9090
  10. #      props:
  11. #        jvm-information-collector-enabled: "true"
  12. #  tracing:
  13. #    OpenTelemetry:
  14. #      props:
  15. #        otel.service.name: "shardingsphere"
  16. #        otel.traces.exporter: "jaeger"
  17. #        otel.exporter.otlp.traces.endpoint: "http://localhost:14250"
  18. #        otel.traces.sampler: "always_on"

插件说明

File

目前 File 插件只有构建元数据耗时日志输出，暂无其他日志输出。

Prometheus

用于暴露监控指标

  • 参数说明
名称说明
host主机
port端口
jvm-information-collector-enabled是否采集 JVM 指标信息

OpenTelemetry

OpenTelemetry 可以导出 tracing 数据到 Jaeger，Zipkin。

  • 参数说明
名称说明
otel.service.name服务名称
otel.traces.exportertraces exporter
otel.exporter.otlp.traces.endpointtraces endpoint
otel.traces.samplertraces sampler

参数参考 OpenTelemetry SDK Autoconfigure

使用方式

启动 ShardingSphere-Proxy

  1. tar -zxvf apache-shardingsphere-${latest.release.version}-shardingsphere-proxy-bin.tar.gz
  2. cd apache-shardingsphere-${latest.release.version}-shardingsphere-proxy-bin
  3. ./bin/start.sh -g

正常启动后，可以在 ShardingSphere-Proxy 日志中找到 plugin 的加载信息，访问 Proxy 后，可以通过配置的监控地址查看到 Metric 和 Tracing 的数据。

Metrics

指标名称指标类型指标描述
build_infoGAUGE构建信息
parsed_sql_totalCOUNTER按类型（INSERT、UPDATE、DELETE、SELECT、DDL、DCL、DAL、TCL、RQL、RDL、RAL、RUL）分类的解析总数
routed_sql_totalCOUNTER按类型（INSERT、UPDATE、DELETE、SELECT）分类的路由总数
routed_result_totalCOUNTER路由结果总数(数据源路由结果、表路由结果)
proxy_stateGAUGEShardingSphere-Proxy 状态信息。0 表示正常状态；1 表示熔断状态；2 锁定状态
proxy_meta_data_infoGAUGEShardingSphere-Proxy 元数据信息，database_count：逻辑库数量，storage_unit_count：存储节点数量
proxy_current_connectionsGAUGEShardingSphere-Proxy 的当前连接数
proxy_requests_totalCOUNTERShardingSphere-Proxy 的接受请求总数
proxy_transactions_totalCOUNTERShardingSphere-Proxy 的事务总数，按 commit，rollback 分类
proxy_execute_latency_millisHISTOGRAMShardingSphere-Proxy 的执行耗时毫秒直方图
proxy_execute_errors_totalCOUNTERShardingSphere-Proxy 的执行异常总数