文档文档

InfluxDB 中的 UDP 协议支持

本页介绍的是早期版本的 InfluxDB OSS。 InfluxDB OSS v2 是最新的稳定版本。请参阅 InfluxDB v2 文档

UDP 输入

关于 UDP/IP 操作系统缓冲区大小的说明

某些操作系统(最值得注意的是 Linux)对 UDP 协议的性能施加了非常严格的限制。 强烈建议您在尝试将 UDP 流量路由到您的实例之前,将这些操作系统限制提高到至少 25MB。 25MB 只是一个建议,应该根据您的 read-buffer 插件设置进行调整。

Linux

通过键入以下命令检查当前 UDP/IP 接收缓冲区默认值和限制

sysctl net.core.rmem_max
sysctl net.core.rmem_default

如果这些值小于 26214400 字节 (25MB),您应该将以下行添加到 /etc/sysctl.conf 文件中

net.core.rmem_max=26214400
net.core.rmem_default=26214400

/etc/sysctl.conf 的更改在重新启动之前不会生效。 要立即更新值,请以 root 身份键入以下命令

sysctl -w net.core.rmem_max=26214400
sysctl -w net.core.rmem_default=26214400

BSD/Darwin

在 BSD/Darwin 系统上,您需要在内核限制套接字缓冲区中添加大约 15% 的填充。 例如,如果您想要 25MB 的缓冲区(26214400 字节),您需要将内核限制设置为 26214400*1.15 = 30146560。 这在任何地方都没有记录,但在这里的内核中发生。

检查当前 UDP/IP 缓冲区限制

要检查当前 UDP/IP 缓冲区限制,请键入以下命令

sysctl kern.ipc.maxsockbuf

如果该值小于 30146560 字节,您应该将以下行添加到 /etc/sysctl.conf 文件中(必要时创建它)

kern.ipc.maxsockbuf=30146560

/etc/sysctl.conf 的更改在重新启动之前不会生效。 要立即更新值,请以 root 身份键入以下命令

sysctl -w kern.ipc.maxsockbuf=30146560

为 UDP 监听器使用 read-buffer 选项

read-buffer 选项允许用户设置 UDP 监听器的缓冲区大小。 它设置与 UDP 流量关联的操作系统接收缓冲区的大小。 请记住,操作系统必须能够处理此处设置的数字,否则 UDP 监听器将出错并退出。

设置 read-buffer = 0 将导致使用操作系统默认值,并且通常对于高 UDP 性能来说太小。

配置

每个 UDP 输入允许设置绑定地址、目标数据库和目标保留策略。 如果数据库不存在,则在初始化输入时会自动创建。 如果未配置保留策略,则使用数据库的默认保留策略。 但是,如果设置了保留策略,则必须显式创建保留策略。 输入不会自动创建它。

每个 UDP 输入还对其接收的点执行内部批处理,因为批量写入数据库效率更高。 默认批处理大小为 1000,待处理批处理因子为 5,批处理超时为 1 秒。 这意味着输入将写入最大大小为 1000 的批次,但是如果批次在将第一个点添加到批次后的 1 秒内未达到 1000 个点,则无论大小如何,它都会发出该批次。 待处理批处理因子控制一次可以在内存中存在的批处理数量,允许输入传输一个批处理,同时仍在构建其他批处理。

处理

UDP 输入每次读取最多可以接收 64KB,并通过换行符拆分接收到的数据。 然后,每个部分被解释为行协议编码点,并进行相应的解析。

UDP 是无连接的

由于 UDP 是一种无连接协议,因此无法向数据源发出信号,指示是否发生任何错误,以及数据是否已成功索引。 在决定是否以及何时使用 UDP 输入时,应牢记这一点。 内置的 UDP 统计信息对于监控 UDP 输入非常有用。

配置示例

一个 UDP 监听器

# influxd.conf
...
[[udp]]
  enabled = true
  bind-address = ":8089" # the bind address
  database = "telegraf" # Name of the database that will be written to
  batch-size = 5000 # will flush if this many points get buffered
  batch-timeout = "1s" # will flush at least this often even if the batch-size is not reached
  batch-pending = 10 # number of batches that may be pending in memory
  read-buffer = 0 # UDP read buffer, 0 means to use OS default
...

多个 UDP 监听器

# influxd.conf
...
[[udp]]
  # Default UDP for Telegraf
  enabled = true
  bind-address = ":8089" # the bind address
  database = "telegraf" # Name of the database that will be written to
  batch-size = 5000 # will flush if this many points get buffered
  batch-timeout = "1s" # will flush at least this often even if the batch-size is not reached
  batch-pending = 10 # number of batches that may be pending in memory
  read-buffer = 0 # UDP read buffer size, 0 means to use OS default

[[udp]]
  # High-traffic UDP
  enabled = true
  bind-address = ":8189" # the bind address
  database = "mymetrics" # Name of the database that will be written to
  batch-size = 5000 # will flush if this many points get buffered
  batch-timeout = "1s" # will flush at least this often even if the batch-size is not reached
  batch-pending = 100 # number of batches that may be pending in memory
  read-buffer = 8388608 # (8*1024*1024) UDP read buffer size
...

内容来自 README


此页是否对您有帮助?

感谢您的反馈!


Flux 的未来

Flux 即将进入维护模式。 您可以继续像目前一样使用它,而无需对代码进行任何更改。

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。 更快扩展。

获取更新

InfluxDB 3 Core 是一个开源、高速、近实时数据引擎,可实时收集和处理数据,并将其持久化到本地磁盘或对象存储。 InfluxDB 3 Enterprise 构建在 Core 的基础上,增加了高可用性、读取副本、增强的安全性以及数据压缩,以实现更快的查询和优化的存储。 InfluxDB 3 Enterprise 的免费层可供非商业家庭或业余爱好者使用。

有关更多信息,请查看