Delphi 11中实现InfluxDB集成的相关问题咨询

Demo无响应排查步骤 #

• 版本匹配校验：你使用的开源库默认适配InfluxDB 1.x版本，若本地部署的是2.x/3.x版本，两者的API端点、鉴权逻辑完全不兼容，会直接导致请求无返回。可先执行influxd version命令确认你部署的InfluxDB版本。
• 配置参数核对：打开Demo源码的配置模块，确认你已经将默认的服务地址、端口、鉴权信息、库名/桶名修改为本地实际的配置值，同时检查服务器防火墙、安全组是否放开了InfluxDB默认的8086端口访问权限。
• 依赖组件检查：该库依赖Indy网络组件实现HTTP请求，若你的Delphi版本未预装Indy，或Indy版本低于10.6，会出现HTTP请求静默失败的情况，可先在组件面板确认TIdHTTP组件可以正常调用。
• 异常捕获调试：在Demo的核心请求逻辑外层添加try...except异常捕获块，输出具体错误信息：返回401代表鉴权失败、404代表API路径不匹配、400代表写入的行协议格式错误。

轻量替代实现思路 #

如果不想二次修改开源库代码，可以直接封装InfluxDB官方REST API实现对接，代码量小且兼容性更强：

• 1.x版本写入示例代码：

uses IdHTTP, System.Classes, System.SysUtils;

procedure InfluxDB1xWrite(measurement, tags, fields, timestamp: string);
var
  http: TIdHTTP;
  reqBody: TStringStream;
begin
  http := TIdHTTP.Create(nil);
  reqBody := TStringStream.Create(Format('%s,%s %s %s', [measurement, tags, fields, timestamp]), TEncoding.UTF8);
  try
    http.Request.Username := '你的用户名';
    http.Request.Password := '你的密码';
    http.Post('http://<你的服务IP>:8086/write?db=<你的库名>', reqBody);
  finally
    reqBody.Free;
    http.Free;
  end;
end;

• 2.x/3.x版本只需调整请求头和接口路径：添加请求头Authorization: Token <你的访问Token>，POST路径修改为http://<你的服务IP>:8086/api/v2/write?org=<你的组织名>&bucket=<你的桶名>&precision=s即可。
  查询操作同理，向对应/query（1.x）或/api/v2/query（2.x）端点发送GET/POST请求即可获取返回结果。

内容的提问来源于stack exchange，提问作者Nizarazu