小 T 導(dǎo)讀：taosAdapter 是 TDengine 這款時(shí)序數(shù)據(jù)庫（Time Series Database）的配套工具，是 TDengine 集群和應(yīng)用程序之間的橋梁和適配器。當(dāng)我們需要從數(shù)據(jù)收集代理軟件（如 Telegraf、StatsD、collectd 等）攝取數(shù)據(jù)時(shí)，使用 taosAdapter 能讓這一操作變得更加高效。此外，它還提供了 InfluxDB/OpenTSDB 兼容的數(shù)據(jù)攝取接口，允許 InfluxDB/OpenTSDB 應(yīng)用程序無縫移植到 TDengine。本文將整體介紹一下 taosAdapter，方便大家使用。

taosAdapter 主要提供以下功能：

• RESTful 接口
• 兼容 InfluxDB v1 寫接口
• 兼容 OpenTSDB JSON 和 telnet 格式寫入
• 無縫連接到 Telegraf
• 無縫連接到 collectd
• 無縫連接到 StatsD
• 支持 Prometheus remote_read 和 remote_write

taosAdapter 部署方法

安裝 taosAdapter

有兩種安裝方式，你可以選擇進(jìn)入濤思數(shù)據(jù)官網(wǎng)（http://www.fjzmyy.cn/）下載 TDengine server 安裝包，無需任何額外操作即可安裝好 taosAdapter。

這種方式下，如果你需要將 taosAdapter 分離部署在 TDengine server 之外的服務(wù)器上，則應(yīng)該在該服務(wù)器上安裝完整的 TDengine 來安裝 taosAdapter。除此之外，你還可以選擇使用源代碼編譯生成 taosAdapter，具體可參考如下文檔（https://github.com/taosdata/taosadapter/blob/3.0/BUILD-CN.md）。

啟動(dòng)/停止 taosAdapter

在 Linux 系統(tǒng)上 taosAdapter 服務(wù)默認(rèn)由 systemd 管理，使用命令 systemctl start taosadapter 可以啟動(dòng) taosAdapter 服務(wù)，使用命令 systemctl stop taosadapter 可以停止 taosAdapter 服務(wù)。

移除 taosAdapter

使用命令 rmtaos 可以移除包括 taosAdapter 在內(nèi)的 TDengine server 軟件。

升級(jí) taosAdapter

taosAdapter 和 TDengine server 需要使用相同版本，請通過升級(jí) TDengine server 來升級(jí) taosAdapter。

taosAdapter 支持通過命令行參數(shù)、環(huán)境變量和配置文件來配置，默認(rèn)配置文件是 /etc/taos/taosadapter.toml。其中，命令行參數(shù)優(yōu)先于環(huán)境變量優(yōu)先于配置文件，命令行用法是 arg=val，如 taosadapter -p=30000 --debug=true，詳細(xì)參數(shù)列表可參見：https://docs.taosdata.com/reference/taosadapter/。

接口

TDengine RESTful 接口

你可以使用任何支持 http 協(xié)議的客戶端訪問 RESTful 接口地址 http://<fqdn>:6041/rest/sql 來寫入數(shù)據(jù)到 TDengine 或從 TDengine 中查詢數(shù)據(jù)。細(xì)節(jié)請參考官方文檔（https://docs.taosdata.com/connector/rest-api/）。

InfluxDB

你可以使用任何支持 http 協(xié)議的客戶端訪問 Restful 接口地址 http://<fqdn>:6041/<APIEndPoint> 來寫入 InfluxDB 兼容格式的數(shù)據(jù)到 TDengine。EndPoint 如下：

/influxdb/v1/write

支持 InfluxDB 查詢參數(shù)如下：

• db 指定 TDengine 使用的數(shù)據(jù)庫名
• precision TDengine 使用的時(shí)間精度
• u TDengine 用戶名
• p TDengine 密碼

注意：目前不支持 InfluxDB 的 token 驗(yàn)證方式，僅支持 Basic 驗(yàn)證和查詢參數(shù)驗(yàn)證。

OpenTSDB

同樣，你可以使用任何支持 http 協(xié)議的客戶端訪問 Restful 接口地址 http://<fqdn>:6041/<APIEndPoint> 來寫入 OpenTSDB 兼容格式的數(shù)據(jù)到 TDengine。EndPoint 如下：

/opentsdb/v1/put/json/<db>
/opentsdb/v1/put/telnet/<db>

collectd

配置 taosAdapter 接收 collectd 數(shù)據(jù)的方法如下：

• 在 taosAdapter 配置文件（默認(rèn)位置為 /etc/taos/taosadapter.toml）中使能配置項(xiàng)：

...
[opentsdb_telnet]
enable = true
maxTCPConnections = 250
tcpKeepAlive = false
dbs = ["opentsdb_telnet", "collectd", "icinga2", "tcollector"]
ports = [6046, 6047, 6048, 6049]
user = "root"
password = "taosdata"
...

其中 taosAdapter 默認(rèn)寫入的數(shù)據(jù)庫名稱為 collectd，也可以修改 taosAdapter 配置文件 dbs 項(xiàng)來指定不同的名稱。user 和 password 填寫實(shí)際 TDengine 配置的值，修改過配置文件后 taosAdapter 需重新啟動(dòng)。

StatsD

配置 taosAdapter 接收 StatsD 數(shù)據(jù)的方法如下：

• 在 taosAdapter 配置文件（默認(rèn)位置 /etc/taos/taosadapter.toml）中使能配置項(xiàng)：

...
[statsd]
enable = true
port = 6044
db = "statsd"
user = "root"
password = "taosdata"
worker = 10
gatherInterval = "5s"
protocol = "udp"
maxTCPConnections = 250
tcpKeepAlive = false
allowPendingMessages = 50000
deleteCounters = true
deleteGauges = true
deleteSets = true
deleteTimings = true
...

其中 taosAdapter 默認(rèn)寫入的數(shù)據(jù)庫名稱為 statsd，也可以修改 taosAdapter 配置文件 db 項(xiàng)來指定不同的名稱。同樣，user 和 password 填寫實(shí)際 TDengine 配置的值，如果修改了配置文件，taosAdapter 需重新啟動(dòng)。

在上述兩種接口下，也可以使用 taosAdapter 命令行參數(shù)或設(shè)置環(huán)境變量啟動(dòng)的方式，使 taosAdapter 能接收 collectd/StatsD 數(shù)據(jù)。更多接口及其配置方法，請參考 https://docs.taosdata.com/reference/taosadapter/。

內(nèi)存使用優(yōu)化方法

taosAdapter 將監(jiān)測自身運(yùn)行過程中的內(nèi)存使用率，并通過兩個(gè)閾值（pauseQueryMemoryThreshold 及 pauseAllMemoryThreshold）進(jìn)行調(diào)節(jié),有效值范圍為 -1 到 100 之間的整數(shù)，單位為系統(tǒng)物理內(nèi)存的百分比。

• 當(dāng)超過 pauseQueryMemoryThreshold 閾值時(shí)將停止處理查詢請求。http 返回內(nèi)容為 code 503、body “query memory exceeds threshold”
• 當(dāng)超過 pauseAllMemoryThreshold 閾值時(shí)停止處理所有寫入和查詢請求。http 返回內(nèi)容為 code 503、body “memory exceeds threshold”

當(dāng)內(nèi)存回落到閾值之下時(shí)恢復(fù)對應(yīng)功能。狀態(tài)檢查接口 http://<fqdn>:6041/-/ping

• 正常返回 code 200
• 無參數(shù)。如果內(nèi)存超過 pauseAllMemoryThreshold 將返回 code 503
• 請求參數(shù) action=query。如果內(nèi)存超過 pauseQueryMemoryThreshold 或 pauseAllMemoryThreshold 將返回 code 503

我們可以根據(jù)具體項(xiàng)目應(yīng)用場景和運(yùn)營策略進(jìn)行相應(yīng)調(diào)整，建議使用運(yùn)營監(jiān)控軟件及時(shí)進(jìn)行系統(tǒng)內(nèi)存狀態(tài)監(jiān)控。負(fù)載均衡器也可以通過這個(gè)接口檢查 taosAdapter 運(yùn)行狀態(tài)。點(diǎn)擊 https://docs.taosdata.com/reference/taosadapter/ 可查看參數(shù)詳情。

如何從舊版本 TDengine 遷移到 taosAdapter

在 TDengine server 2.2.x.x 或更早期版本中，taosd 進(jìn)程包含一個(gè)內(nèi)嵌的 HTTP 服務(wù)。如前文所述，taosAdapter 是一個(gè)使用 systemd 管理的獨(dú)立軟件，擁有自己的進(jìn)程，并且兩者有一些配置參數(shù)和行為是不同的，請見下表：

taosAdapter 主要通過參數(shù) restfulRowLimit 來控制結(jié)果的返回條數(shù)，-1 代表無限制，默認(rèn)無限制。該參數(shù)控制以下接口返回：

• http://<fqdn>:6041/rest/sql
• http://<fqdn>:6041/prometheus/v1/remote_read/:db

如果出現(xiàn)故障，我們可以通過命令 systemctl status taosadapter 來檢查 taosAdapter 運(yùn)行狀態(tài)，也可以通過設(shè)置 –logLevel 參數(shù)或者環(huán)境變量 TAOS_ADAPTER_LOG_LEVEL 來調(diào)節(jié) taosAdapter 日志輸出詳細(xì)程度，有效值包括：panic、fatal、error、warn、warning、info、debug 以及 trace。

寫在最后

受文章篇幅所限，本文并未包含 taosAdapter 應(yīng)用手冊的所有技術(shù)細(xì)節(jié)，如需查詢相關(guān)配置內(nèi)容，可以移步到 TDengine 官網(wǎng)-技術(shù)文檔進(jìn)行更具體了解。此外，歡迎大家掃碼添加小助手小T，進(jìn)入 TDengine 用戶交流群，在本群中，你不僅可以與有同樣業(yè)務(wù)場景的小伙伴進(jìn)行交流，還可以獲得官方技術(shù)人員的專業(yè)支持。