管理 Kapacitor 订阅

Kapacitor 通过使用 InfluxDB 订阅与 InfluxDB 紧密集成，InfluxDB 订阅是本地或远程端点，所有写入 InfluxDB 的数据都会复制到这些端点。Kapacitor 订阅 InfluxDB，使其能够捕获、操作和处理您的数据。

Kapacitor 订阅的工作原理

Kapacitor 允许您在数据写入 InfluxDB 时对其进行操作和处理。所有数据都通过 InfluxDB 订阅复制到您的 Kapacitor 服务器或集群，而不是查询 InfluxDB 获取数据（使用 BatchNode 时除外）。这减少了 InfluxDB 上的查询负载，并将与数据操作相关的开销隔离到您的 Kapacitor 服务器或集群。

启动时，Kapacitor 会检查 InfluxDB 中是否存在与 Kapacitor 服务器或集群 ID 匹配的名称的订阅。此 ID 存储在 /var/lib/kapacitor/ 中。如果 ID 文件在启动时不存在，Kapacitor 将创建它。如果 InfluxDB 中不存在与 Kapacitor ID 匹配的订阅，Kapacitor 将在 InfluxDB 中创建新订阅。此过程确保当 Kapacitor 停止时，只要 /var/lib/kapacitor/ 的内容保持不变，它就会在重启时重新连接到相同的订阅。

Kapacitor 存储其 ID 的目录可以使用 kapacitor.conf 中的 data-dir 根配置选项进行配置。

配置 Kapacitor 订阅

Kapacitor 订阅配置选项在 kapacitor.conf 中的 [[influxdb]] 部分下可用。以下是特定于订阅的配置选项示例，后跟每个选项的描述。

Kapacitor 订阅配置示例

[[influxdb]]

  # ...

  disable-subscriptions = false
  subscription-mode = "server"
  subscription-protocol = "http"
  subscriptions-sync-interval = "1m0s"

  # ...

  [influxdb.subscriptions]
    my_database1 = [ "default", "longterm" ]
  [influxdb.excluded-subscriptions]
    my_database2 = [ "default", "shortterm" ]

disable-subscriptions

设置为 true 以禁用所有订阅。

subscription-mode

定义 Kapacitor 的订阅模式。可用选项

• "server"
• "cluster"

默认设置为 cluster。

subscription-protocol

定义订阅使用的协议。可用选项

• "udp"
• "http"
• "https"

默认设置为 http。

[influxdb.subscriptions]

定义要订阅的数据库和保留策略集。如果为空，Kapacitor 将订阅除 [influxdb.excluded-subscriptions] 中列出的数据库和保留策略之外的所有数据库和保留策略。

[influxdb.subscriptions]
  # Pattern:
  db_name = <list of retention policies>

  # Example:
  my_database = [ "default", "longterm" ]

[influxdb.excluded-subscriptions]

定义要从订阅中排除的数据库和保留策略集。

[influxdb.excluded-subscriptions]
  # Pattern:
  db_name = <list of retention policies>

  # Example:
  my_database = [ "default", "longterm" ]

故障排除

查看 Kapacitor 服务器或集群 ID

有两种方法可以查看您的 Kapacitor 服务器或集群 ID

1. 查看 /var/lib/kapacitor/server.id 或 /var/lib/kapacitor/cluster.id 的内容。

   ID 文件的位置取决于您的操作系统和 kapacitor.conf 中的 data-dir 设置。

2. 运行以下命令

   kapacitor stats general
   

   服务器和集群 ID 包含在输出中。

重复的 Kapacitor 订阅

重复的 Kapacitor 订阅通常是由 /var/lib/kapacitor 的内容在重启之间未持久化引起的，如上文所述。解决方案是确保此目录的内容持久化。任何已创建的重复 Kapacitor 订阅都需要手动删除。