WTM+InfluxDB时序数据库数据查询并放到DataTable中

一、需求描述

由于WTM默认只支持查询关系型数据库，但实际生产过程中，我们的数据可能会存在时序数据库。
WTM LayUI的架构下，实现通过查询InfluxDB时序数据库数据，并将数据放到DataTable中。
 
二、解决思路

通过Influx语法，将数据查询出来放到List的容器中，然后再在GetSearchQuery方法中返回。 这样无论查询数据放到DataTable还是导出都可以使用。
三、代码实现

GetSearchQuery方法的实现：

1.     public override   IOrderedQueryable<HParameterMonitoring_View> GetSearchQuery()
2.         {
3.            var list= GetInfluxDBData().Result;
4.            return  list.AsQueryable().OrderBy(x=>x.HParameterMonitoring_MachineCode);
5.         }

复制代码

 
 查询InfluxDB数据将其放到List容器中： 

1.         private async Task<List<HParameterMonitoring_View>> GetInfluxDBData()
2.         {
3.             StringBuilder query = new StringBuilder();
4.             StringBuilder queryCount = new StringBuilder();
5.             string machineId = Searcher.SelectedMachineId.ToString();
6.             var dicParm = DC.Set<CMachParm>().CheckContain(Searcher.HPTHAlarmParameterIds, x => x.ID).ToDictionary(s => s.NameEN, v => v);
7.             // List<string> paraList = dicParm.Keys.ToList();
8.             List<ParamName> paraList = new List<ParamName>();
9.             foreach (var para in dicParm)
10.             {
11.                 ParamName obj = new ParamName()
12.                 {
13.                     Name_Cn = para.Value.NameCN,
14.                     Name_En = para.Value.NameEN,
15.                     Unit = para.Value.Unit,
16.                 };
17.                 paraList.Add(obj);
19.             };
20.             int queryStart = DateHelper.ConvertDateTimeInt(Searcher.DateStart ?? DateTime.Now.AddMinutes(-5));
21.             int queryEnd = DateHelper.ConvertDateTimeInt(Searcher.DateEnd ?? DateTime.Now);
23.             List<HParameterMonitoring_View> objList = new List<HParameterMonitoring_View>();
25.             
26.             using (var client = InfluxDBClientFactory.Create(Wtm.ConfigInfo.AppSettings["InfluxDBUrl"], Wtm.ConfigInfo.AppSettings["InfluxDBToken"].ToCharArray()))
27.             {
28.                 client.EnableGzip();//此方法将数据压缩，就不会导致超时的发生
29.                 //bool IsGzipEnabled=client.IsGzipEnabled();
30.                 query.Append($"from(bucket:"{Wtm.ConfigInfo.AppSettings["InfluxDBBucket"]}")");
31.                 query.Append($@"|> range(start: {queryStart},stop:{queryEnd})");
32.                 query.Append("|> filter(fn: (r) => r["_measurement"] == "cncinfo")");
33.                 query.Append($"|> filter(fn: (r) => r["machineId"] == "{machineId}")");
34.                 if (paraList.Count > 0)
35.                 {
36.                     query.Append($"|> filter(fn: (r) => 1!=1");//or  就要是false 因为false或什么 就是什么
37.                     foreach (var para in paraList)
38.                     {
39.                         query.Append($" or r["_field"] == "{para.Name_En}"");//相当于select那些列
40.                     }
41.                     query.Append(")");
42.                 }
45.                
46.                 var fluxTable = await client.GetQueryApi().QueryAsync(query.ToString(), Wtm.ConfigInfo.AppSettings["InfluxDBOrg"],cancellationToken:System.Threading.CancellationToken.None);
48.                 //int z = (Searcher.Page - 1) * Searcher.Limit;
49.                 for (int i = 0; i < fluxTable.Count; i++)
50.                 {//i是参数
51.                     for (int j = 0; j < fluxTable[i].Records.Count; j++)
52.                     {//j是数据
53.                         string time = fluxTable[i].Records[j].GetTimeInDateTime()?.AddHours(8).ToString("yyyy-MM-dd HH:mm:ss");
54.                         string fieldOri = fluxTable[i].Records[j].GetField();
55.                         Dictionary<string, object> values = fluxTable[i].Records[j].Values;
56.                         string NameCn = "";
57.                         string Unit = "";
58.                         foreach (var item in paraList)
59.                         {
60.                             if (item.Name_En == fieldOri)
61.                             {
62.                                 NameCn = item.Name_Cn;
63.                                 Unit = item.Unit;
64.                             }
66.                         };
67.                         HParameterMonitoring_View obj = new HParameterMonitoring_View()
68.                         {
69.                             HParameterMonitoring_MachineCode = values["eqname"]?.ToString(),
70.                             HParameterMonitoring_Param = fieldOri,
71.                             HParameterMonitoring_ParamCn = NameCn,
72.                             HParameterMonitoring_Value = values["_value"]?.ToString() + Unit,
73.                             HParameterMonitoring_UpdateTime = time,
74.                         };
75.                         objList.Add(obj);
77.                     }
78.                 }
79.             };
80.             return objList;
81.         }

复制代码

 
 
四、改善建议

改善点1：每次查询出来都是不带分页的整个list，然后才进行分页
由于要使用WTM的GetSearchQuery，而WTM的分页和排序是在执行完GetSearchQuery方法之后，故没法分页查询。如果要分页查询，只能自己写查询数据库方法不使用GetSearchQuery方法，而是在查询时序数据库的时候，直接用limit进行分页。
 
 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！