You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

InfluxDB通过Axios返回乱码数据问题求助

解决Axios调用InfluxDB API返回乱码的问题

问题原因

你在请求头里设置了Accept-Encoding: gzip,这会告知InfluxDB返回gzip压缩后的二进制数据,但Axios默认不会自动解压这类响应,导致你拿到的是原始压缩字节流,显示为乱码。而InfluxDB控制台会自动处理解压,所以能正常展示数据。

解决方案

方案1:移除压缩请求头(最简单)

直接删掉Accept-Encoding: gzip,让InfluxDB返回未压缩的明文数据,Axios就能正常解析:

return await axios({
  url: url,
  method: 'POST',
  headers: {
    Authorization: `Token ${process.env.INFLUXDB_API_TOKEN}`,
    'Content-Type': 'application/vnd.flux',
    Accept: 'application/json'
  },
  timeout: 60000,
  data: query,
});

方案2:保留压缩并手动解压(适合带宽敏感场景)

如果想继续用压缩传输节省带宽,需要配置Axios处理gzip解压:

Node.js环境(自带zlib库)
const zlib = require('zlib');
const { promisify } = require('util');
const gunzip = promisify(zlib.gunzip);

return await axios({
  url: url,
  method: 'POST',
  headers: {
    Authorization: `Token ${process.env.INFLUXDB_API_TOKEN}`,
    'Content-Type': 'application/vnd.flux',
    Accept: 'application/json',
    'Accept-Encoding': 'gzip'
  },
  timeout: 60000,
  data: query,
  responseType: 'arraybuffer', // 指定接收二进制数据
  transformResponse: async (data) => {
    const decompressedBuffer = await gunzip(data);
    return JSON.parse(decompressedBuffer.toString('utf8'));
  }
});
浏览器环境(需安装pako库)

先安装依赖:npm install pako

import pako from 'pako';

return await axios({
  url: url,
  method: 'POST',
  headers: {
    Authorization: `Token ${process.env.INFLUXDB_API_TOKEN}`,
    'Content-Type': 'application/vnd.flux',
    Accept: 'application/json',
    'Accept-Encoding': 'gzip'
  },
  timeout: 60000,
  data: query,
  responseType: 'arraybuffer',
  transformResponse: (data) => {
    const decompressedStr = pako.gunzip(new Uint8Array(data), { to: 'string' });
    return JSON.parse(decompressedStr);
  }
});

额外优化建议

你在请求里指定了Accept: application/json,但InfluxDB控制台返回的是CSV格式,建议在Flux查询末尾添加|> to(format: "json"),强制返回JSON格式,避免后续解析出错:

from(bucket: "plc-metrics")
  |> range(start: 1693256400, stop: 1693310660)
  |> filter(fn: (r) => r._measurement == "PLC_Sim8e786f156e5d1f06-total_count")
  |> sort(columns: ["_time"], desc: true)
  |> limit(n: 2000)
  |> group()
  |> to(format: "json")

内容的提问来源于stack exchange,提问作者Jantoma21

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.12 03:28:20