Telegraf HTTP Listener V2插件接收含measurement字段的JSON数据时返回400 Bad Request错误的排查与解决咨询

我来帮你梳理这个问题的排查思路和解决办法，先从你的场景入手分析：

你的问题场景 #

你尝试通过Python脚本向Telegraf的http_listener_v2插件发送包含measurement字段的JSON日志数据，但持续收到400 Bad Request错误，不确定是Telegraf配置问题还是JSON数据格式不符合插件预期。

你的Python测试代码 #

import requests
import json
import time
from datetime import datetime, timezone

TELEGRAF_URL = "http://telegraf:8080"

while True:
    log_data = {
        "measurement": "log",  # Measurement name
        "timestamp": datetime.now(timezone.utc).isoformat(),
        "message": "Test log",
        "status": 200
    }
    
    try:
        response = requests.post(TELEGRAF_URL, json=log_data)
        if response.status_code != 204:
            print('changes')
            print(f"Erreur {response.status_code}: {response.text}")
    except Exception as e:
        print(f"Erreur d'envoi : {e}")
    
    print(log_data)
    time.sleep(1)

你的Telegraf配置片段 #

service_address = ":8080"
  paths = ["/"]
  data_format = "json"
  json_time_key = "timestamp"
  json_time_format = "iso8601"
  json_name_key = "measurement"  # Measurement key

收到的错误信息 #

运行Python脚本后持续输出：

Script version: v2.2 - Using json_v2 format
changes
Erreur 400: {"error":"http: bad request"}
{'measurement': 'log', 'time': '2025-03-19T11:45:03.369950+00:00', 'fields': {'message': 'Test log', 'status': 200}}
changes
Erreur 400: {"error":"http: bad request"}
{'measurement': 'log', 'time': '2025-03-19T11:45:04.375164+00:00', 'fields': {'message': 'Test log', 'status': 200}}

你已尝试的操作 #

• 确认Telegraf配置中包含了measurement和timestamp相关的解析配置
• 检查JSON数据结构，确保measurement字段存在

问题排查与解决步骤 #

1. 先补全Telegraf配置的必填结构

你提供的配置片段缺少了[[inputs.http_listener_v2]]的外层块定义，这会导致Telegraf完全无法识别这部分配置，自然无法启动HTTP监听器插件。正确的完整配置应该是：

[[inputs.http_listener_v2]]
  service_address = ":8080"
  paths = ["/"]
  data_format = "json"
  json_time_key = "timestamp"
  json_time_format = "iso8601"
  json_name_key = "measurement"

补全后重启Telegraf，这是解决问题的前提。

2. 调整JSON数据格式适配Telegraf解析

400错误通常是请求体无法被Telegraf解析，可尝试以下调整：

• 将单条数据包裹为数组发送：Telegraf的JSON解析器对数组格式的兼容性更稳定，修改Python请求代码：

  # 把单条log_data包裹成数组
  response = requests.post(TELEGRAF_URL, json=[log_data])
  

• 优化timestamp格式兼容性：部分Telegraf版本对带微秒的ISO8601字符串解析可能存在问题，可切换为Unix纳秒时间戳：
  Python代码修改：

  "timestamp": int(datetime.now(timezone.utc).timestamp() * 1e9),
  

  同时更新Telegraf配置：

  json_time_format = "unix_nano"
  

3. 查看Telegraf调试日志定位精准问题

启动Telegraf时加上--debug参数，能看到详细的请求解析错误（比如字段缺失、时间格式不匹配等），这是定位问题最直接的方法：

telegraf --config /path/to/your/telegraf.conf --debug

4. 确认请求头正确性

虽然requests.post的json参数会自动设置Content-Type: application/json，但可手动指定再次确认：

headers = {"Content-Type": "application/json"}
response = requests.post(TELEGRAF_URL, json=log_data, headers=headers)

总结 #

最可能的根源是Telegraf配置缺少外层插件定义块，先补全配置重启插件。如果仍有问题，通过调试日志查看具体解析错误，再针对性调整数据格式即可解决400错误。

备注：内容来源于stack exchange，提问作者Happy Emotion