src/sample/XXX.Plugin.Tdengine/Service/TaosService.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Maikebing.Data.Taos;
using System.Security.Cryptography;
using System.Text;
using System.Data;

namespace XXX.Plugin.Tdengine
{
    public interface ITaosService
    {
        Task CreateDatabaseAsync(DatabaseConfig database, string dbKey = "taos1");
        Task CreateSuperTableAsync(SuperTable superTable, string dbKey = "taos1");
        Task InsertAsync(TaosAo taosAo, string dbKey = "taos1");
        Task InsertTestAsync();
    }

    public class TaosService : ITaosService
    {
        private readonly ITdengineMulti _taosdbMulti;
        private readonly ITaosProxy _taosProxy;
        public TaosService(ITdengineMulti taosdbMulti,
            ITaosProxy taosProxy)
        {
            _taosdbMulti = taosdbMulti;
            _taosProxy = taosProxy;
        }

        /// <summary>
        /// 插入
        /// </summary>
        /// <returns></returns>
        public async Task InsertTestAsync()
        {
            var number = RandomNumberGenerator.GetInt32(0, 1000);
            var sql = @$"
                       INSERT INTO power.device_{"db001"} 
                       USING power.meters
                       TAGS ('device_db001') 
                       VALUES({DateTimeOffset.Now.ToUnixTimeMilliseconds()},{number})";

            using var taos = _taosdbMulti["power"];
            using var command = taos.CreateCommand(sql);
            using var reader = await command.ExecuteReaderAsync();
            if (reader.Read())
            {
                var ts = reader.GetDateTime("ts");
            }
        }

        /// <summary>
        /// 插入
        /// </summary>
        /// <param name="taosAo"></param>
        /// <param name="dbKey"></param>
        /// <returns></returns>
        public async Task InsertAsync(TaosAo taosAo, string dbKey = "taos1")
        {
            // INSERT INTO d1001 USING meters TAGS ("Beijng.Chaoyang", 2) VALUES (now, 10.2, 219, 0.3

            //根据设备找到合适数据库，
            //根据设备找到合适超级表，