由于項(xiàng)目?IoTSharp 需要支持?InfluxDB??， 因此進(jìn)行了初步嘗試， 雖然?Flux 語(yǔ)法初次學(xué)習(xí)， 但查詢語(yǔ)句卻似曾相識(shí)， 如果改一下 標(biāo)點(diǎn)符號(hào)， 你會(huì)完全認(rèn)為他是 C#的拉姆達(dá)表達(dá)式，?

首先看一下寫入數(shù)據(jù):

using (var writeApi = influxDBClient.GetWriteApi()){//// Write by Point//var point = PointData.Measurement("temperature").Tag("location", "west").Field("value", 55D).Timestamp(DateTime.UtcNow.AddSeconds(-10), WritePrecision.Ns);writeApi.WritePoint("bucket_name", "org_id", point);//// Write by LineProtocol//writeApi.WriteRecord("bucket_name", "org_id", WritePrecision.Ns, "temperature,location=north value=60.0");//// Write by POCO//var temperature = new Temperature {Location = "south", Value = 62D, Time = DateTime.UtcNow};writeApi.WriteMeasurement("bucket_name", "org_id", WritePrecision.Ns, temperature);}

寫入數(shù)據(jù)看起來(lái)類似于 1.0 但是 增加了 bucket 和org這些信息。?

新版本的查詢則更有意思：

from(bucket: "iotsharp-bucket")|> range(start: v.timeRangeStart, stop: v.timeRangeStop)|> filter(fn: (r) => r["_measurement"] == "TelemetryData")|> filter(fn: (r) => r["DeviceId"] == "a649a429-e82c-406b-8b8e-a3ba48c868fb")|> yield()

_measurement 相當(dāng)于表名 ?

DeviceId 其實(shí)類似 濤思時(shí)序數(shù)據(jù)庫(kù)中的 tags 字段，?

同時(shí) ， 也有類似group之類的語(yǔ)句， 比如

|> group(columns: [""_field""])

如果你想只要 年齡或者 用戶名之類的字段 可以使用 類似下面的用法

??|>?filter(fn:?(r)?=>?r["_field"]?==?"age"?or?r["_field"]?==?"username"?)?

欲了解更多C#中訪問(wèn)?InfluxDB 2.0 的方法， 可以參考我們的代碼:

https://gitee.com/IoTSharp/IoTSharp/blob/master/IoTSharp/Storage/InfluxDBStorage.cs?

總結(jié)

以上是生活随笔為你收集整理的InfluxDB 2.0 之Flux语法篇的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。