文档文档

使用 Telegraf 写入 CSV 数据

使用 Telegraf file 输入插件读取和解析 CSV 数据为 行协议 并将其写入 InfluxDB 3 Core。Telegraf 是一个基于插件的代理,用于从不同来源收集指标并将它们写入指定的目的地。

配置 Telegraf 以读取 CSV 文件

  1. 在您的 Telegraf 配置文件中添加并启用 inputs.file 插件
  2. 使用 files 选项指定要读取的 CSV 文件列表。CSV 文件必须可被 Telegraf 代理访问。
  3. data_format 选项设置为 csv
  4. 定义所有其他特定于您要写入 InfluxDB 3 Core 的 CSV 数据的 csv_ 配置选项。有关每个 CSV 格式配置选项的详细信息,请参阅 CSV 输入数据格式
[[inputs.file]]
  files = ["/path/to/example.csv"]
  data_format = "csv"
  csv_header_row_count = 0
  csv_column_names = []
  csv_column_types = []
  csv_skip_rows = 0
  csv_metadata_rows = 0
  csv_metadata_separators = [":", "="]
  csv_metadata_trim_set = ""
  csv_skip_columns = 0
  csv_delimiter = ","
  csv_comment = ""
  csv_trim_space = false
  csv_tag_columns = []
  csv_measurement_column = ""
  csv_timestamp_column = ""
  csv_timestamp_format = ""
  csv_timezone = ""
  csv_skip_values = []
  csv_skip_errors = false
  csv_reset_mode = "none"

配置 Telegraf 以写入 InfluxDB

要将数据发送到 InfluxDB 3 Core,请在您的 telegraf.conf 中启用并配置 influxdb_v2 输出插件

[[inputs.file]]
  files = ["/path/to/example.csv"]
  data_format = "csv"
  csv_header_row_count = 0
  csv_column_names = []
  csv_column_types = []
  csv_skip_rows = 0
  csv_metadata_rows = 0
  csv_metadata_separators = [":", "="]
  csv_metadata_trim_set = ""
  csv_skip_columns = 0
  csv_delimiter = ","
  csv_comment = ""
  csv_trim_space = false
  csv_tag_columns = []
  csv_measurement_column = ""
  csv_timestamp_column = ""
  csv_timestamp_format = ""
  csv_timezone = ""
  csv_skip_values = []
  csv_skip_errors = false
  csv_reset_mode = "none"

[[outputs.influxdb_v2]]
  urls = ["http://localhost:8181"]
  token = "
AUTH_TOKEN
"
organization = "" bucket = "
DATABASE_NAME
"
content_encoding = "gzip"

替换以下内容

  • DATABASE_NAME:要写入数据的数据库的名称

  • AUTH_TOKEN:您的 InfluxDB 3 Core 授权令牌。将其存储在密钥存储或环境变量中,以避免暴露原始令牌字符串。

    在 Beta 测试期间,InfluxDB 3 Core 不需要授权令牌。对于 token 选项,请提供任意非空令牌字符串。

    将您的授权令牌存储为环境变量

    避免在您的 Telegraf 配置文件中存储纯文本令牌。将令牌存储为环境变量,然后使用字符串插值在您的配置文件中引用该环境变量。例如

    [[outputs.influxdb_v2]]
      urls = ["http://localhost:8181"]
      token = "${INFLUX_TOKEN}"
      # ...
    

重启 Telegraf 代理 以应用配置更改并将 CSV 数据写入 InfluxDB 3 Core。

其他 Telegraf 配置选项

前面的示例描述了写入 InfluxDB 3 Core 所需的 Telegraf 配置。influxdb_v2 输出插件提供了其他几个配置选项。有关更多信息,请参阅 GitHub 上的 influxdb_v2 插件选项


此页是否对您有帮助?

感谢您的反馈!


Flux 的未来

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

阅读更多

现已正式发布

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

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

有关更多信息,请查看