使用 DataFlux 採集 NTPQ 監控指標並展示頭條網

使用 DataFlux 採集 NTPQ 監控指標並展示

2020-12-10 14:56:11 佚名

DataFlux是上海駐雲自研發的一套大數據統一分析平臺，可以通過對任何來源、類型、規模的實時數據進行監控、分析和處理，釋放數據價值。

DataFlux包含五大功能模塊：

- Datakit 採集器

- Dataway 數據網關

- DataFlux Studio 實時數據洞察平臺

- DataFlux Admin Console 管理後臺

- DataFlux.f(x) 實時數據處理開發平臺

面向企業提供全場景的數據洞察分析能力，具有實時性、靈活性、易擴展、易部署等特點。

ntpq命令可以用來處理各種時間之間的同步和換算，非常強大。今天跟大家分享一個監控SAAS平臺，只需要簡單配置，就可以實現站點以及業務監控——使用DataFlux採集NTPQ性能指標並分析展示。

安裝DataKit

PS：以Linux系統為例

第一步：執行安裝命令

DataKit 安裝命令：

<code>DK_FTDATAWAY=[你的 DataWay 網關地址] bash -c "$(curl https://static.dataflux.cn/datakit/install.sh)"/<code>

補充安裝命令中的 DataWay 網關地址，然後複製安裝命令到主機上執行即可。

例如：如果的 DataWay 網關地址 IP 為 1.2.3.4，端口為 9528(9528為默認端口)，則網關地址為

<code>DK_FTDATAWAY=http://1.2.3.4:9528/v1/write/metrics bash -c "$(curl https://static.dataflux.cn/datakit/install.sh)"/<code>

安裝完成後，DataKit 默認會自動運行，並且會在終端中提示 DataKit 的狀態管理命令

NTPQ 監控指標採集

採集 ntpq 指數上報到 DataFlux 中

前置條件

已安裝 DataKit（DataKit 安裝文檔）

配置

打開 DataKit 採集源配置文件夾（默認路徑為 DataKit 安裝目錄的 conf.d 文件夾），找到 ntpq文件夾，打開裡面的 ntpq.conf。

設置：

<code>[[inputs.jolokia2_agent]]
  name_prefix = "kafka_"

  urls = ["http://localhost:8080/jolokia"]

  [[inputs.jolokia2_agent.metric]]
    name         = "controller"
    mbean        = "kafka.controller:name=*,type=*"
    field_prefix = "$1."

  [[inputs.jolokia2_agent.metric]]
    name         = "replica_manager"
    mbean        = "kafka.server:name=*,type=ReplicaManager"
    field_prefix = "$1."

  [[inputs.jolokia2_agent.metric]]
    name         = "purgatory"
    mbean        = "kafka.server:delayedOperation=*,name=*,type=DelayedOperationPurgatory"
    field_prefix = "$1."
    field_name   = "$2"

  [[inputs.jolokia2_agent.metric]]
    name     = "client"
    mbean    = "kafka.server:client-id=*,type=*"
    tag_keys = ["client-id", "type"]

  [[inputs.jolokia2_agent.metric]]
    name         = "request"
    mbean        = "kafka.network:name=*,request=*,type=RequestMetrics"
    field_prefix = "$1."
    tag_keys     = ["request"]

  [[inputs.jolokia2_agent.metric]]
    name         = "topics"
    mbean        = "kafka.server:name=*,type=BrokerTopicMetrics"
    field_prefix = "$1."

  [[inputs.jolokia2_agent.metric]]
    name         = "topic"
    mbean        = "kafka.server:name=*,topic=*,type=BrokerTopicMetrics"
    field_prefix = "$1."
    tag_keys     = ["topic"]

  [[inputs.jolokia2_agent.metric]]
    name       = "partition"
    mbean      = "kafka.log:name=*,partition=*,topic=*,type=Log"
    field_name = "$1"
    tag_keys   = ["topic", "partition"]

  [[inputs.jolokia2_agent.metric]]
    name       = "partition"
    mbean      = "kafka.cluster:name=UnderReplicated,partition=*,topic=*,type=Partition"
    field_name = "UnderReplicatedPartitions"
    tag_keys   = ["topic", "partition"]/<code>

配置好後，重啟 DataKit 即可生效

採集指標