👁 Image
NetPro.Tdengine 6.0.16

NetPro.Tdengine使用

👁 NuGet

对涛思数据库连接对象Maikebing.Data.Taos的简易封装，使用单例TaosConnection对象

客户端驱动下载地址 客户端与服务器版本必须强一致；

即使使用ip连接，也必须配置fqdn:

• 服务器执行以下命令获取服务器的fqdn值

taosd | grep -i fqdn

• 修改hosts域名解析 添加服务器ip对应的fqdn值作为域名
• 修改C:\TDengine\cfg 配置

# local fully qualified domain name (FQDN)
fqdn h26.taosdata.com #taos数据库远程hostname，既fqdn

# first port number for the connection (12 continuous UDP/TCP port number are used) 
serverPort 6030 #客户端连接端口，默认6030，udp

windows本地客户端测试

.\taos.exe -h h26.taosdata.com -P 6030

响应以下即成功，显示客户端版本为2.4.0.7,服务器必定也是2.4.0.7版本

Welcome to the TDengine shell from Windows, Client Version:2.4.0.7
Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.

Tdengine时区 修改

修改C:\TDengine\cfg下的taos.cfg配置文件中的timezone节点与服务器保持一致； 特别注意Tdengine执行的时区标准为 unix的时间标准，与传统的东8 是+8不一样，在Tdengine需配置为UTC-8

# system time zone
timezone UTC+0 #0时区(伦敦时间)

#timezone UTC-8 #东八区(北京时间)

restful 方式访问Tdengine需注意

官方restful调用文档

调用 rest/sql ，响应时间以服务器时区为准，并且格式为 2022-02-17 12:31:45.375 调用 rest/sqlt，响应时间为unix时间戳

使用

appsetting.json

"TdengineOption": {
 "ConnectionString": [
 {
 "Key": "taos1", //连接串key别名，唯一
 "Value": "Data Source=h26.taosdata.com;DataBase=db_20220120141621;Username=root;Password=taosdata;Port=6030" //别名key对应的连接串
 }
 ]
 },

启用服务

没有基于NetPro.Web.Api 的使用场景，必须手动进行初始化，如下：

IConfiguration Configuration;

public void ConfigureServices(IServiceCollection services)
{
 services.AddTdengine(Configuration);
}

基于NetPro.Web.Api的使用，只需要添加引用后配置以上appsetting.josn配置TaosOption节点即可

当想自定义连接字符串获取方式时，无论是否基于NetPro.Web.Api, 都能通过传入委托来自定义连接字符串获取方式：

public void ConfigureServices(IServiceCollection services)
{
 services.AddTdengineDb(GetConnectionString);
}

public List<ConnectionString> GetConnectionString(IServiceProvider serviceProvider)
{
 return new List<ConnectionString>
 {
 new ConnectionString()
 {
 Key ="remotekey",
 Value = "Data Source=h26.taosdata.com;DataBase=db_netpro;Username=root;Password=taosdata;Port=6030"
 }
 };
}

使用说明

 public class TaosService: ITaosService
 {
 private readonly TdengineMulti _taosdbMulti;
 public TaosService(TdengineMulti taosdbMulti)
 {
 _taosdbMulti = taosdbMulti;
 }

 /// <summary>
 /// 执行Sql
 /// </summary>
 public void Executesql(string sql)
 {
 using var taos= _taosdbMulti.Get("taos1");
 using var command= taos.CreateCommand(@"INSERT INTO data_history_67 
 USING datas TAGS (mongo, 67) 
 values ( 1608173534840 2 false 'Channel1.窑.烟囱温度' '烟囱温度' '122.00' );");
 using var reader= command.ExecuteReader();//command和reader都必须using
 }
 }

更新中...