TDengine version: 3.3.7.0
TDengine.Connector 3.2.1 无法连接数据库
var connectionString = “protocol=WebSocket;host=127.0.0.1;port=6041;username=root;password=taosdata;path=/ws”;
try
{
var builder = new ConnectionStringBuilder(connectionString);
// 使用using确保资源释放
using (var client = DbDriver.Open(builder))
{
Console.WriteLine("成功连接到TDengine数据库");
// 可选：执行测试查询
using (var rs = client.Query("SELECT SERVER_VERSION()"))
{
while (rs.Read())
{
Console.WriteLine($"TDengine版本: {rs.GetString(0)}");
}
}
}
}
catch (Exception ex)
{
Console.WriteLine($"连接失败: {ex.Message}");
if (ex.InnerException != null)
{
Console.WriteLine($"内部错误: {ex.InnerException.Message}");
}
}
ex.Message "One or more errors occurred. (The server returned status code '404' when status code '101' was expected.)" string
ex.InnerException.Message "The server returned status code '404' when status code '101' was expected." string
用 string connStr = “Data Source=127.0.0.1;Port=6041;Username=root;Password=taosdata;”;
// 🔥 必须用 TDengineConnection（Connector 3.x 专用）
using (TDengineConnection conn = new TDengineConnection(connStr))
{
Console.WriteLine("正在连接...");
conn.Open();
// =============================================
// 能走到这里，就是 100% 成功！
// =============================================
Console.WriteLine("✅ 连接成功！");
// 测试执行语句
}
}
catch (Exception ex)
{
Console.WriteLine("错误：" + ex.ToString());
}
一直卡在conn.Open();
curl 命令正常 
curl -u “root:taosdata” http://localhost:6041/rest/sql -d “select server_status()”
{“code”:0,“column_meta”:[[“server_status()”,“INT”,4]],“data”:[[1]],“rows”:1}
HttpClient 正常
try
{
// 你的服务完全正常，直接调用 REST 接口！
var url = "http://127.0.0.1:6041/rest/sql";
var username = "root";
var password = "taosdata";
var sql = "select server_status()";
using (var client = new HttpClient())
{
// 拼接账号密码
var bytes = Encoding.ASCII.GetBytes($"{username}:{password}");
client.DefaultRequestHeaders.Authorization =
new System.Net.Http.Headers.AuthenticationHeaderValue("Basic", Convert.ToBase64String(bytes));
// 发送请求
var content = new StringContent(sql, Encoding.UTF8, "application/json");
var response = client.PostAsync(url, content).Result;
var result = response.Content.ReadAsStringAsync().Result;
// 输出结果！！！
Console.WriteLine("✅ 查询成功！");
Console.WriteLine("结果：" + result);
}
}
catch (Exception ex)
{
Console.WriteLine("错误：" + ex.ToString());
}