高效寫入數(shù)據(jù)

TDengine 支持多種接口寫入數(shù)據(jù)，包括 SQL，Prometheus，Telegraf，collectd，StatsD，EMQX MQTT Broker，HiveMQ Broker，CSV 文件等，后續(xù)還將提供 Kafka，OPC 等接口。數(shù)據(jù)可以單條插入，也可以批量插入，可以插入一個(gè)數(shù)據(jù)采集點(diǎn)的數(shù)據(jù)，也可以同時(shí)插入多個(gè)數(shù)據(jù)采集點(diǎn)的數(shù)據(jù)。支持多線程插入，支持時(shí)間亂序數(shù)據(jù)插入，也支持歷史數(shù)據(jù)插入。

SQL 寫入

應(yīng)用通過 C/C++, Java, Go, C#, Python, Node.js 連接器執(zhí)行 SQL insert 語(yǔ)句來(lái)插入數(shù)據(jù)，用戶還可以通過 TAOS Shell，手動(dòng)輸入 SQL insert 語(yǔ)句插入數(shù)據(jù)。比如下面這條 insert 就將一條記錄寫入到表 d1001 中：

INSERT INTO d1001 VALUES (1538548685000, 10.3, 219, 0.31);

TDengine 支持一次寫入多條記錄，比如下面這條命令就將兩條記錄寫入到表 d1001 中：

INSERT INTO d1001 VALUES (1538548684000, 10.2, 220, 0.23) (1538548696650, 10.3, 218, 0.25);

TDengine 也支持一次向多個(gè)表寫入數(shù)據(jù)，比如下面這條命令就向 d1001 寫入兩條記錄，向 d1002 寫入一條記錄：

INSERT INTO d1001 VALUES (1538548685000, 10.3, 219, 0.31) (1538548695000, 12.6, 218, 0.33) d1002 VALUES (1538548696800, 12.3, 221, 0.31);

詳細(xì)的 SQL INSERT 語(yǔ)法規(guī)則請(qǐng)見 TAOS SQL 的數(shù)據(jù)寫入章節(jié)。

Tips:

要提高寫入效率，需要批量寫入。一批寫入的記錄條數(shù)越多，插入效率就越高。但一條記錄不能超過 48K（2.1.7.0 之前的版本為 16K），一條 SQL 語(yǔ)句總長(zhǎng)度不能超過 1M 。
TDengine 支持多線程同時(shí)寫入，要進(jìn)一步提高寫入速度，一個(gè)客戶端需要打開 20 個(gè)以上的線程同時(shí)寫。但線程數(shù)達(dá)到一定數(shù)量后，無(wú)法再提高，甚至還會(huì)下降，因?yàn)榫€程頻繁切換，帶來(lái)額外開銷。
對(duì)同一張表，如果新插入記錄的時(shí)間戳已經(jīng)存在，默認(rèn)情形下（UPDATE=0）新記錄將被直接拋棄，也就是說，在一張表里，時(shí)間戳必須是唯一的。如果應(yīng)用自動(dòng)生成記錄，很有可能生成的時(shí)間戳是一樣的，這樣，成功插入的記錄條數(shù)會(huì)小于應(yīng)用插入的記錄條數(shù)。如果在創(chuàng)建數(shù)據(jù)庫(kù)時(shí)使用了 UPDATE 1 選項(xiàng)，插入相同時(shí)間戳的新記錄將覆蓋原有記錄。
寫入的數(shù)據(jù)的時(shí)間戳必須大于當(dāng)前時(shí)間減去配置參數(shù) keep 的時(shí)間。如果 keep 配置為3650天，那么無(wú)法寫入比 3650 天還早的數(shù)據(jù)。寫入數(shù)據(jù)的時(shí)間戳也不能大于當(dāng)前時(shí)間加配置參數(shù) days。如果 days 為 2，那么無(wú)法寫入比當(dāng)前時(shí)間還晚2天的數(shù)據(jù)。

無(wú)模式（Schemaless）寫入

前言
在物聯(lián)網(wǎng)應(yīng)用中，常會(huì)采集比較多的數(shù)據(jù)項(xiàng)，用于實(shí)現(xiàn)智能控制、業(yè)務(wù)分析、設(shè)備監(jiān)控等。由于應(yīng)用邏輯的版本升級(jí)，或者設(shè)備自身的硬件調(diào)整等原因，數(shù)據(jù)采集項(xiàng)就有可能比較頻繁地出現(xiàn)變動(dòng)。為了在這種情況下方便地完成數(shù)據(jù)記錄工作，TDengine 從 2.2.0.0 版本開始，提供調(diào)用 Schemaless 寫入方式，可以免于預(yù)先創(chuàng)建超級(jí)表/子表的步驟，隨著數(shù)據(jù)寫入接口能夠自動(dòng)創(chuàng)建與數(shù)據(jù)對(duì)應(yīng)的存儲(chǔ)結(jié)構(gòu)。并且在必要時(shí)，Schemaless 將自動(dòng)增加必要的數(shù)據(jù)列，保證用戶寫入的數(shù)據(jù)可以被正確存儲(chǔ)。
目前，TDengine 的所有官方支持的連接器支持 Schemaless 的操作接口，詳情請(qǐng)參見 Schemaless 方式寫入接口章節(jié)。這里對(duì) Schemaless 的數(shù)據(jù)表達(dá)格式進(jìn)行了描述。
無(wú)模式寫入方式建立的超級(jí)表及其對(duì)應(yīng)的子表與通過 SQL 直接建立的超級(jí)表和子表完全沒有區(qū)別，您也可以通過 SQL 語(yǔ)句直接向其中寫入數(shù)據(jù)。需要注意的是，通過無(wú)模式寫入方式建立的表，其表名是基于標(biāo)簽值按照固定的映射規(guī)則生成，所以無(wú)法明確地進(jìn)行表意，缺乏可讀性。

無(wú)模式寫入行協(xié)議
TDengine 的無(wú)模式寫入的行協(xié)議兼容 InfluxDB 的行協(xié)議（Line Protocol）、OpenTSDB 的 telnet 行協(xié)議、OpenTSDB 的 JSON 格式協(xié)議。但是使用這三種協(xié)議的時(shí)候，需要在 API 中指定輸入內(nèi)容使用解析協(xié)議的標(biāo)準(zhǔn)。

對(duì)于 InfluxDB、OpenTSDB 的標(biāo)準(zhǔn)寫入?yún)f(xié)議請(qǐng)參考各自的文檔。下面首先以 InfluxDB 的行協(xié)議為基礎(chǔ)，介紹 TDengine 擴(kuò)展的協(xié)議內(nèi)容，允許用戶采用更加精細(xì)的方式控制（超級(jí)表）模式。

Schemaless 采用一個(gè)字符串來(lái)表達(dá)一個(gè)數(shù)據(jù)行（可以向?qū)懭?API 中一次傳入多行字符串來(lái)實(shí)現(xiàn)多個(gè)數(shù)據(jù)行的批量寫入），其格式約定如下：

measurement,tag_set field_set timestamp

其中:

measurement 將作為數(shù)據(jù)表名。它與 tag_set 之間使用一個(gè)英文逗號(hào)來(lái)分隔。
tag_set 將作為標(biāo)簽數(shù)據(jù)，其格式形如 <tag_key>=<tag_value>,<tag_key>=<tag_value>，也即可以使用英文逗號(hào)來(lái)分隔多個(gè)標(biāo)簽數(shù)據(jù)。它與 field_set 之間使用一個(gè)半角空格來(lái)分隔。
field_set 將作為普通列數(shù)據(jù)，其格式形如 <field_key>=<field_value>,<field_key>=<field_value>，同樣是使用英文逗號(hào)來(lái)分隔多個(gè)普通列的數(shù)據(jù)。它與 timestamp 之間使用一個(gè)半角空格來(lái)分隔。
timestamp 即本行數(shù)據(jù)對(duì)應(yīng)的主鍵時(shí)間戳。

tag_set 中的所有的數(shù)據(jù)自動(dòng)轉(zhuǎn)化為 nchar 數(shù)據(jù)類型，并不需要使用雙引號(hào)（")。
在無(wú)模式寫入數(shù)據(jù)行協(xié)議中，field_set 中的每個(gè)數(shù)據(jù)項(xiàng)都需要對(duì)自身的數(shù)據(jù)類型進(jìn)行描述。具體來(lái)說：

如果兩邊有英文雙引號(hào)，表示 BINARY(32) 類型。例如 "abc"。
如果兩邊有英文雙引號(hào)而且?guī)в?L 前綴，表示 NCHAR(32) 類型。例如 L"報(bào)錯(cuò)信息"。
對(duì)空格、等號(hào)（=）、逗號(hào)（,）、雙引號(hào)（"），前面需要使用反斜杠（\）進(jìn)行轉(zhuǎn)義。（都指的是英文半角符號(hào)）
數(shù)值類型將通過后綴來(lái)區(qū)分?jǐn)?shù)據(jù)類型：

序號(hào)	后綴	映射類型	大小(字節(jié))
1	無(wú)或f64	double	8
2	f32	float	4
3	i8	TinyInt	1
4	i16	SmallInt	2
5	i32	Int	4
6	i64或i	Bigint	8

t, T, true, True, TRUE, f, F, false, False 將直接作為 BOOL 型來(lái)處理。

例如如下數(shù)據(jù)行表示：向名為 st 的超級(jí)表下的 t1 標(biāo)簽為 "3"（NCHAR）、t2 標(biāo)簽為 "4"（NCHAR）、t3 標(biāo)簽為 "t3"（NCHAR）的數(shù)據(jù)子表，寫入 c1 列為 3（BIGINT）、c2 列為 false（BOOL）、c3 列為 "passit"（BINARY）、c4 列為 4（DOUBLE）、主鍵時(shí)間戳為 1626006833639000000 的一行數(shù)據(jù)。

st,t1=3,t2=4,t3=t3 c1=3i64,c3="passit",c2=false,c4=4f64 1626006833639000000

需要注意的是，如果描述數(shù)據(jù)類型后綴時(shí)使用了錯(cuò)誤的大小寫，或者為數(shù)據(jù)指定的數(shù)據(jù)類型有誤，均可能引發(fā)報(bào)錯(cuò)提示而導(dǎo)致數(shù)據(jù)寫入失敗。

無(wú)模式寫入的主要處理邏輯

無(wú)模式寫入按照如下原則來(lái)處理行數(shù)據(jù)：
1. 將使用如下規(guī)則來(lái)生成子表名：首先將 measurement 的名稱和標(biāo)簽的 key 和 value 組合成為如下的字符串

"measurement,tag_key1=tag_value1,tag_key2=tag_value2"

需要注意的是，這里的 tag_key1, tag_key2 并不是用戶輸入的標(biāo)簽的原始順序，而是使用了標(biāo)簽名稱按照字符串升序排列后的結(jié)果。所以，tag_key1 并不是在行協(xié)議中輸入的第一個(gè)標(biāo)簽。排列完成以后計(jì)算該字符串的 MD5 散列值 "md5_val"。然后將計(jì)算的結(jié)果與字符串組合生成表名：“t_md5val”。其中的 “t” 是固定的前綴，每個(gè)通過該映射關(guān)系自動(dòng)生成的表都具有該前綴。
2. 如果解析行協(xié)議獲得的超級(jí)表不存在，則會(huì)創(chuàng)建這個(gè)超級(jí)表。
3. 如果解析行協(xié)議獲得子表不存在，則 Schemaless 會(huì)按照步驟 1 或 2 確定的子表名來(lái)創(chuàng)建子表。
4. 如果數(shù)據(jù)行中指定的標(biāo)簽列或普通列不存在，則在超級(jí)表中增加對(duì)應(yīng)的標(biāo)簽列或普通列（只增不減）。
5. 如果超級(jí)表中存在一些標(biāo)簽列或普通列未在一個(gè)數(shù)據(jù)行中被指定取值，那么這些列的值在這一行中會(huì)被置為 NULL。
6. 對(duì) BINARY 或 NCHAR 列，如果數(shù)據(jù)行中所提供值的長(zhǎng)度超出了列類型的限制，自動(dòng)增加該列允許存儲(chǔ)的字符長(zhǎng)度上限（只增不減），以保證數(shù)據(jù)的完整保存。
7. 如果指定的數(shù)據(jù)子表已經(jīng)存在，而且本次指定的標(biāo)簽列取值跟已保存的值不一樣，那么最新的數(shù)據(jù)行中的值會(huì)覆蓋舊的標(biāo)簽列取值。
8. 整個(gè)處理過程中遇到的錯(cuò)誤會(huì)中斷寫入過程，并返回錯(cuò)誤代碼。

備注：
無(wú)模式所有的處理邏輯，仍會(huì)遵循 TDengine 對(duì)數(shù)據(jù)結(jié)構(gòu)的底層限制，例如每行數(shù)據(jù)的總長(zhǎng)度不能超過 48K 字節(jié)（2.1.7.0 之前的版本為 16K）。這方面的具體限制約束請(qǐng)參見 TAOS SQL 邊界限制章節(jié)。

時(shí)間分辨率識(shí)別
無(wú)模式寫入過程中支持三個(gè)指定的模式，具體如下

序號(hào)	值	說明
1	SML_LINE_PROTOCOL	InfluxDB行協(xié)議（Line Protocol)
2	SML_TELNET_PROTOCOL	OpenTSDB 文本行協(xié)議
3	SML_JSON_PROTOCOL	JSON 協(xié)議格式

在 SML_LINE_PROTOCOL 解析模式下，需要用戶指定輸入的時(shí)間戳的時(shí)間分辨率?？捎玫臅r(shí)間分辨率如下表所示：

序號(hào)	時(shí)間分辨率定義	含義
1	TSDB_SML_TIMESTAMP_NOT_CONFIGURED	未定義（無(wú)效）
2	TSDB_SML_TIMESTAMP_HOURS	小時(shí)
3	TSDB_SML_TIMESTAMP_MINUTES	分鐘
4	TSDB_SML_TIMESTAMP_SECONDS	秒
5	TSDB_SML_TIMESTAMP_MILLI_SECONDS	毫秒
6	TSDB_SML_TIMESTAMP_MICRO_SECONDS	微秒
7	TSDB_SML_TIMESTAMP_NANO_SECONDS	納秒

在 SML_TELNET_PROTOCOL 和 SML_JSON_PROTOCOL 模式下，根據(jù)時(shí)間戳的長(zhǎng)度來(lái)確定時(shí)間精度（與 OpenTSDB 標(biāo)準(zhǔn)操作方式相同），此時(shí)會(huì)忽略用戶指定的時(shí)間分辨率。

數(shù)據(jù)模式映射規(guī)則
本節(jié)將說明行協(xié)議的數(shù)據(jù)如何映射成為具有模式的數(shù)據(jù)。每個(gè)行協(xié)議中數(shù)據(jù) measurement 映射為超級(jí)表名稱。tag_set 中的標(biāo)簽名稱為數(shù)據(jù)模式中的標(biāo)簽名，field_set 中的名稱為列名稱。以如下數(shù)據(jù)為例，說明映射規(guī)則：

st,t1=3,t2=4,t3=t3 c1=3i64,c3="passit",c2=false,c4=4f64 1626006833639000000

該行數(shù)據(jù)映射生成一個(gè)超級(jí)表： st，其包含了 3 個(gè)類型為 nchar 的標(biāo)簽，分別是：t1, t2, t3。五個(gè)數(shù)據(jù)列，分別是ts（timestamp），c1 (bigint），c3(binary)，c2 (bool), c4 (bigint）。映射成為如下 SQL 語(yǔ)句：

create stable st (_ts timestamp, c1 bigint, c2 bool, c3 binary(6), c4 bigint) tags(t1 nchar(1), t2 nchar(1), t3 nchar(2))

數(shù)據(jù)模式變更處理
本節(jié)將說明不同行數(shù)據(jù)寫入情況下，對(duì)于數(shù)據(jù)模式的影響。

在使用行協(xié)議寫入一個(gè)明確的標(biāo)識(shí)的字段類型的時(shí)候，后續(xù)更改該字段的類型定義，會(huì)出現(xiàn)明確的數(shù)據(jù)模式錯(cuò)誤，即會(huì)觸發(fā)寫入 API 報(bào)告錯(cuò)誤。如下所示，

st,t1=3,t2=4,t3=t3 c1=3i64,c3="passit",c2=false,c4=4    1626006833639000000
st,t1=3,t2=4,t3=t3 c1=3i64,c3="passit",c2=false,c4=4i   1626006833640000000

第一行的數(shù)據(jù)類型映射將 c4 列定義為 Double，但是第二行的數(shù)據(jù)又通過數(shù)值后綴方式聲明該列為 BigInt，由此會(huì)觸發(fā)無(wú)模式寫入的解析錯(cuò)誤。

如果列前面的行協(xié)議將數(shù)據(jù)列聲明為了 binary，后續(xù)的要求長(zhǎng)度更長(zhǎng)的binary長(zhǎng)度，此時(shí)會(huì)觸發(fā)超級(jí)表模式的變更。

st,t1=3,t2=4,t3=t3 c1=3i64,c5="pass"     1626006833639000000
st,t1=3,t2=4,t3=t3 c1=3i64,c5="passit"   1626006833640000000

第一行中行協(xié)議解析會(huì)聲明 c5 列是一個(gè) binary(4)的字段，第二次行數(shù)據(jù)寫入會(huì)提取列 c5 仍然是 binary 列，但是其寬度為 6，此時(shí)需要將binary的寬度增加到能夠容納新字符串的寬度。

st,t1=3,t2=4,t3=t3 c1=3i64               1626006833639000000
st,t1=3,t2=4,t3=t3 c1=3i64,c6="passit"   1626006833640000000

第二行數(shù)據(jù)相對(duì)于第一行來(lái)說增加了一個(gè)列 c6，類型為 binary(6)。那么此時(shí)會(huì)自動(dòng)增加一個(gè)列 c6，類型為 binary(6)。

寫入完整性
TDengine 提供數(shù)據(jù)寫入的冪等性保證，即您可以反復(fù)調(diào)用 API 進(jìn)行出錯(cuò)數(shù)據(jù)的寫入操作。但是不提供多行數(shù)據(jù)寫入的原子性保證。即在多行數(shù)據(jù)一批次寫入過程中，會(huì)出現(xiàn)部分?jǐn)?shù)據(jù)寫入成功，部分?jǐn)?shù)據(jù)寫入失敗的情況。

錯(cuò)誤碼
如果是無(wú)模式寫入過程中的數(shù)據(jù)本身錯(cuò)誤，應(yīng)用會(huì)得到 TSDB_CODE_TSC_LINE_SYNTAX_ERROR 錯(cuò)誤信息，該錯(cuò)誤信息表明錯(cuò)誤發(fā)生在寫入文本中。其他的錯(cuò)誤碼與原系統(tǒng)一致，可以通過 taos_errstr() 獲取具體的錯(cuò)誤原因。

除使用 C 版本的 API，也可以使用官網(wǎng)連接器，包括 Java/Go/Python/C#/Node.js/Rust 等。此外，在 TDengine v2.4 及后續(xù)版本中，您還可以通過 taosAdapter 采用 RESTful 的方式直接寫入無(wú)模式數(shù)據(jù)。

Prometheus 直接寫入（通過 taosAdapter）

remote_read 和 remote_write 是 Prometheus 數(shù)據(jù)讀寫分離的集群方案。只需要將 remote_read 和 remote_write url 指向 taosAdapter 對(duì)應(yīng)的 url 同時(shí)設(shè)置 Basic 驗(yàn)證即可使用。

remote_read url : http://host_to_taosAdapter:port(default 6041)/prometheus/v1/remote_read/:db
remote_write url : http://host_to_taosAdapter:port(default 6041)/prometheus/v1/remote_write/:db

Basic驗(yàn)證：

username： TDengine 連接用戶名
password： TDengine 連接密碼

示例 prometheus.yml 如下：

remote_write:
  - url: "http://localhost:6041/prometheus/v1/remote_write/prometheus_data"
    basic_auth:
      username: root
      password: taosdata

remote_read:
  - url: "http://localhost:6041/prometheus/v1/remote_read/prometheus_data"
    basic_auth:
      username: root
      password: taosdata
    remote_timeout: 10s
    read_recent: true

Telegraf 直接寫入(通過 taosAdapter)

安裝 Telegraf 請(qǐng)參考官方文檔。

TDengine 新版本（2.3.0.0+）包含一個(gè) taosAdapter 獨(dú)立程序，負(fù)責(zé)接收包括 Telegraf 的多種應(yīng)用的數(shù)據(jù)寫入。

配置方法，在 /etc/telegraf/telegraf.conf 增加如下文字，其中 database name 請(qǐng)?zhí)顚懴Ｍ?TDengine 保存 Telegraf 數(shù)據(jù)的數(shù)據(jù)庫(kù)名，TDengine server/cluster host、username和 password 填寫 TDengine 實(shí)際值：

[[outputs.http]]
  url = "http://<TDengine server/cluster host>:6041/influxdb/v1/write?db=<database name>"
  method = "POST"
  timeout = "5s"
  username = "<TDengine's username>"
  password = "<TDengine's password>"
  data_format = "influx"
  influx_max_line_bytes = 250

然后重啟 telegraf：

sudo systemctl start telegraf

即可在 TDengine 中查詢 metrics 數(shù)據(jù)庫(kù)中 Telegraf 寫入的數(shù)據(jù)。

taosAdapter 相關(guān)配置參數(shù)請(qǐng)參考 taosadapter --help 命令輸出以及相關(guān)文檔。

collectd 直接寫入(通過 taosAdapter)

安裝 collectd，請(qǐng)參考官方文檔。

TDengine 新版本（2.3.0.0+）包含一個(gè) taosAdapter 獨(dú)立程序，負(fù)責(zé)接收包括 collectd 的多種應(yīng)用的數(shù)據(jù)寫入。

在 /etc/collectd/collectd.conf 文件中增加如下內(nèi)容，其中 host 和 port 請(qǐng)?zhí)顚?TDengine 和 taosAdapter 配置的實(shí)際值：

LoadPlugin network
<Plugin network>
  Server "<TDengine cluster/server host>" "<port for collectd>"
</Plugin>

重啟 collectd

sudo systemctl start collectd

taosAdapter 相關(guān)配置參數(shù)請(qǐng)參考 taosadapter --help 命令輸出以及相關(guān)文檔。

StatsD 直接寫入(通過 taosAdapter)

安裝 StatsD 請(qǐng)參考官方文檔。

TDengine 新版本（2.3.0.0+）包含一個(gè) taosAdapter 獨(dú)立程序，負(fù)責(zé)接收包括 StatsD 的多種應(yīng)用的數(shù)據(jù)寫入。

在 config.js 文件中增加如下內(nèi)容后啟動(dòng) StatsD，其中 host 和 port 請(qǐng)?zhí)顚?TDengine 和 taosAdapter 配置的實(shí)際值：

backends 部分添加 "./backends/repeater"
repeater 部分添加 { host:'<TDengine server/cluster host>', port: <port for StatsD>}

示例配置文件：

{
port: 8125
, backends: ["./backends/repeater"]
, repeater: [{ host: '127.0.0.1', port: 6044}]
}

taosAdapter 相關(guān)配置參數(shù)請(qǐng)參考 taosadapter --help 命令輸出以及相關(guān)文檔。

icinga2 可以收集監(jiān)控和性能數(shù)據(jù)并寫入 OpenTSDB，taosAdapter 可以支持接收 icinga2 的數(shù)據(jù)并寫入到 TDengine 中。

icinga2 直接寫入(通過 taosAdapter)

參考鏈接 https://icinga.com/docs/icinga-2/latest/doc/14-features/#opentsdb-writer 使能 opentsdb-writer
使能 taosAdapter 配置項(xiàng) opentsdb_telnet.enable
修改配置文件 /etc/icinga2/features-enabled/opentsdb.conf

object OpenTsdbWriter "opentsdb" {
  host = "host to taosAdapter"
  port = 6048
}

taosAdapter 相關(guān)配置參數(shù)請(qǐng)參考 taosadapter --help 命令輸出以及相關(guān)文檔。

TCollector 直接寫入(通過 taosAdapter)

TCollector 是一個(gè)在客戶側(cè)收集本地收集器并發(fā)送數(shù)據(jù)到 OpenTSDB 的進(jìn)程，taosAdapter 可以支持接收 TCollector 的數(shù)據(jù)并寫入到 TDengine 中。

使能 taosAdapter 配置項(xiàng) opentsdb_telnet.enable 修改 TCollector 配置文件，修改 OpenTSDB 宿主機(jī)地址為 taosAdapter 被部署的地址，并修改端口號(hào)為 taosAdapter 使用的端口（默認(rèn)6049）。

taosAdapter 相關(guān)配置參數(shù)請(qǐng)參考 taosadapter --help 命令輸出以及相關(guān)文檔。

EMQX Broker 直接寫入

MQTT 是流行的物聯(lián)網(wǎng)數(shù)據(jù)傳輸協(xié)議，EMQX 是一開源的 MQTT Broker 軟件，無(wú)需任何代碼，只需要在 EMQX Dashboard 里使用“規(guī)則”做簡(jiǎn)單配置，即可將 MQTT 的數(shù)據(jù)直接寫入 TDengine。EMQX 支持通過發(fā)送到 Web 服務(wù)的方式保存數(shù)據(jù)到 TDengine，也在企業(yè)版上提供原生的 TDengine 驅(qū)動(dòng)實(shí)現(xiàn)直接保存。詳細(xì)使用方法請(qǐng)參考 EMQX 官方文檔。

HiveMQ Broker 直接寫入

HiveMQ 是一個(gè)提供免費(fèi)個(gè)人版和企業(yè)版的 MQTT 代理，主要用于企業(yè)和新興的機(jī)器到機(jī)器M2M通訊和內(nèi)部傳輸，滿足可伸縮性、易管理和安全特性。HiveMQ 提供了開源的插件開發(fā)包?？梢酝ㄟ^ HiveMQ extension - TDengine 保存數(shù)據(jù)到 TDengine。詳細(xì)使用方法請(qǐng)參考 HiveMQ extension - TDengine 說明文檔。