使用 TCollector 寫入 TDengine

在這里插入圖片描述
TCollector 是 openTSDB 的一部分,它用來采集客戶端日志發送給數據庫。

只需要將 TCollector 的配置修改指向運行 taosAdapter 的服務器域名(或 IP 地址)和相應端口即可將 TCollector 采集的數據存在到 TDengine 中,可以充分利用 TDengine 對時序數據的高效存儲查詢性能和集群處理能力。

前置條件

要將 TCollector 數據寫入 TDengine 需要以下幾方面的準備工作。

  • TDengine 集群已經部署并正常運行
  • taosAdapter 已經安裝并正常運行。具體細節請參考 taosAdapter 的使用手冊
  • TCollector 已經安裝。安裝 TCollector 請參考 官方文檔

配置步驟

配置 taosAdapter

配置 taosAdapter 接收 TCollector 數據的方法:

  • 在 taosAdapter 配置文件(默認位置 /etc/taos/taosadapter.toml)中使能配置項

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

    其中 taosAdapter 默認寫入的數據庫名稱為 tcollector,也可以修改 taosAdapter 配置文件 dbs 項來指定不同的名稱。user 和 password 填寫實際 TDengine 配置的值。修改過配置文件 taosAdapter 需重新啟動。

  • 使用 taosAdapter 命令行參數或設置環境變量啟動的方式,使能 taosAdapter 接收 tcollector 數據功能,具體細節請參考 taosAdapter 的參考手冊

配置 TCollector

使用 TCollector 需下載其源代碼。其配置項在其源代碼中。注意:TCollector 各個版本區別較大,這里僅以當前 master 分支最新代碼 (git commit: 37ae920) 為例。

修改 collectors/etc/config.pytcollector.py 兩個文件中相應內容。將原指向 OpenTSDB 宿主機的地址修改為 taosAdapter 被部署的服務器域名或 IP 地址,修改端口為 taosAdapter 支持 TCollector 使用的相應端口(默認為 6049)。

示例為源代碼修改內容的 git diff 輸出:

index e7e7a1c..ec3e23c 100644
--- a/collectors/etc/config.py
+++ b/collectors/etc/config.py
@@ -59,13 +59,13 @@ def get_defaults():'http_password': False,'reconnectinterval': 0,'http_username': False,
-        'port': 4242,
+        'port': 6049,'pidfile': '/var/run/tcollector.pid','http': False,'http_api_path': "api/put",'tags': [],'remove_inactive_collectors': False,
-        'host': '',
+        'host': '127.0.0.1','logfile': '/var/log/tcollector.log','cdir': default_cdir,'ssl': False,
diff --git a/tcollector.py b/tcollector.py
index 21f9b23..4c71ba2 100755
--- a/tcollector.py
+++ b/tcollector.py
@@ -64,7 +64,7 @@ ALIVE = True# exceptions, something is not right and tcollector will shutdown.# Hopefully some kind of supervising daemon will then restart it.MAX_UNCAUGHT_EXCEPTIONS = 100
-DEFAULT_PORT = 4242
+DEFAULT_PORT = 6049MAX_REASONABLE_TIMESTAMP = 2209212000  # Good until Tue  3 Jan 14:00:00 GMT 2040# How long to wait for datapoints before assuming# a collector is dead and restarting it
@@ -943,13 +943,13 @@ def parse_cmdline(argv):'http_password': False,'reconnectinterval': 0,'http_username': False,
-            'port': 4242,
+            'port': 6049,'pidfile': '/var/run/tcollector.pid','http': False,'http_api_path': "api/put",'tags': [],'remove_inactive_collectors': False,
-            'host': '',
+            'host': '127.0.0.1','logfile': '/var/log/tcollector.log','cdir': default_cdir,'ssl': False,

驗證方法

重啟 taosAdapter:

sudo systemctl restart taosadapter

手動執行 sudo ./tcollector.py

等待數秒后使用 TDengine CLI 查詢 TDengine 是否創建相應數據庫并寫入數據。

taos> show databases;name              |
=================================information_schema             |performance_schema             |tcollector                     |
Query OK, 3 rows in database (0.001647s)taos> use tcollector;
Database changed.taos> show stables;name              |
=================================proc.meminfo.hugepages_rsvd    |proc.meminfo.directmap1g       |proc.meminfo.vmallocchunk      |proc.meminfo.hugepagesize      |tcollector.reader.lines_dro... |proc.meminfo.sunreclaim        |proc.stat.ctxt                 |proc.meminfo.swaptotal         |proc.uptime.total              |tcollector.collector.lines_... |proc.meminfo.vmallocused       |proc.meminfo.memavailable      |sys.numa.foreign_allocs        |proc.meminfo.committed_as      |proc.vmstat.pswpin             |proc.meminfo.cmafree           |proc.meminfo.mapped            |proc.vmstat.pgmajfault         |
...

提示:

  • TDengine 默認生成的子表名是根據規則生成的唯一 ID 值。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/web/87484.shtml
繁體地址,請注明出處:http://hk.pswp.cn/web/87484.shtml
英文地址,請注明出處:http://en.pswp.cn/web/87484.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

高斯消元法詳解

文章目錄 概念用法特殊情況 我的奇怪方法 概念 什么是高斯消元?讓我們看一看 OI-Wiki 的解釋: 高斯消元法(Gauss–Jordan elimination)是求解線性方程組的經典算法,它在當代數學中有著重要的地位和價值,是線性代數課…

暴雨服務器成功中標華中科技大學集成電路學院服務器采購項目

近日,武漢暴雨信息發展有限公司在激烈的競爭中脫穎而出,成功中標華中科技大學集成電路學院的服務器采購項目。此次中標產品為暴雨旗下的塔式重裝AM400服務器,這一成果標志著暴雨信息在高性能計算領域的卓越實力得到了高校科研機構的高度認可。…

集群聊天服務器---MySQL數據庫的建立

數據庫的建立表格 user表 字段名稱字段類型字段說明約束idINT用戶idPRIMARY KEY, AUTO_INCREMENTnameVARCHAR(50)用戶名NOT NULL, UNIQUEpasswordVARCHAR(50)用戶密碼NOT NULLstateENUM(online, offline)當前登錄狀態DEFAULT offline friend表 字段名稱字段類型字段說明約束…

MongoDB 安裝使用教程

一、MongoDB 簡介 MongoDB 是一個高性能、開源的 NoSQL 文檔型數據庫,使用 BSON(二進制 JSON)格式存儲數據。適合存儲大規模、高并發的非結構化數據,常用于大數據、日志存儲、微服務架構中。 二、下載安裝 2.1 官網下載 訪問 …

FastAPI 小白教程:從入門級到實戰(源碼教程)

目錄 1. FastAPI 基本介紹 安裝 FastAPI 2. 簡單的 CRUD 示例 2.1 創建基本應用 2.2 添加 CRUD 操作??????? 3. 處理跨域請求 (CORS) 4. 普通案例:待辦事項 API??????? 5. 企業案例:認證和數據庫集成 5.1 使用 SQLAlchemy 和 JWT…

java中jasypt是用來做什么的?

思路: 簡要介紹Jasypt:一句話說明它的作用。配置解析:分別解釋password和algorithm的作用。工作流程:說明如何加密敏感數據并在配置文件中使用。安全提醒:強調密鑰管理的重要性。 最終回答: Jasypt&…

牛客周賽 Round 98

1.小紅與奇數 解題思路&#xff1a;如果給定的數是偶數, 由于1是任意正數的因子, 偶數1奇數 若給定的數是奇數, 1/自身, 都變成了偶數 #include <bits/stdc.h> using namespace std; void solve() {int x;cin >> x;if (x & 1)cout << "No" <…

(2)手摸手-學習 Vue3 之 變量聲明【ref 和 reactive】

手摸手-學習 Vue3 之 變量聲明【ref 和 reactive】 前言refreactive 前言 vue3 前端代碼開發過程中&#xff0c;必然會涉及變量聲明&#xff0c;會用到&#xff1a;ref、reactive 。本章節 進行講解說明。 演示的項目&#xff0c;經處理后的結構如下&#xff1a; ref 用途…

[Terence Tao訪談] 無限 | 關注模型 | 矢量場 | 策略性“作弊” | Lean

關注模型 改變視角真的很重要 無限&#xff1a;假設是球形的奶牛 陶哲軒&#xff1a;一個很好的例子是數學中的塞邁雷迪定理&#xff0c;于1970年代得以證明&#xff0c;它涉及在一組數字集合中尋找某種類型的模式&#xff0c;即等差數列&#xff0c;例如3、5、7或10、15、20。…

汽車v型推力桿總成三維5自由度性能及疲勞測試系統

V型推力桿總成裝置&#xff0c;通常設置在載重汽車中、后橋上&#xff0c;成對使用。其一端通過球面銷與車架鉸接&#xff0c;另一端則安裝在車橋上&#xff0c;通過關節軸承與車橋鉸接&#xff0c;其主要作用是穩定車橋&#xff0c;保持車橋的穩定位置&#xff0c;同時克服彈簧…

制動系統故障定義與診斷標準

核心定義&#xff1a; 制動不足 (Brake Insufficiency) 定義&#xff1a;制動系統產生的實際制動力低于預期制動力&#xff0c;但未完全喪失制動能力 關鍵特征&#xff1a; 制動距離增加20%以上 減速度低于預期值30%-50% 制動踏板行程異常增長 等效物理描述&#xff1a;&a…

server-rs

今天早上 看到有人 用cursor寫rust東西了 效果不錯遂嘗試寫一下web serverserver本身這個詞就不確指單單這一個東西在與cursor交流中,還是越來越明白了之前 沒有管過的一些"常識"一個業務服務之所以能“一直處理請求”&#xff0c;是因為有一個“東西”在背后做著持續…

python打卡day59@浙大疏錦行

知識點回顧&#xff1a; SARIMA模型的參數和用法&#xff1a;SARIMA(p, d, q)(P, D, Q)m模型結果的檢驗可視化&#xff08;昨天說的是摘要表怎么看&#xff0c;今天是對這個內容可視化&#xff09;多變量數據的理解&#xff1a;內生變量和外部變量多變量模型 統計模型&#xff…

Redisson的分布式鎖源碼分析2

文章目錄Redisson的讀寫鎖使用加鎖源碼分析釋放鎖源碼分析&#xff1a;Redisson一次加多個鎖RedissonMultiLock加鎖源碼分析&#xff1a;RedissonMultiLock釋放鎖源碼分析&#xff1a;RCountDownLatch介紹&#xff1a;RCountDownLatch源碼分析&#xff1a;RSemaphore分布式信號…

系統架構設計師論文分享-論軟件過程模型及應用

我的軟考歷程 摘要 2023年2月&#xff0c;我所在的公司通過了研發紗線MES系統的立項&#xff0c;該系統為國內紗線工廠提供SAAS服務&#xff0c;旨在提升紗線工廠的數字化和智能化水平。我在該項目中擔任架構設計師&#xff0c;負責該項目的架構設計工作。本文結合我在該項目…

云原生Kubernetes系列 | etcd3.5集群部署和使用

云原生Kubernetes系列 | etcd3.5集群部署和使用 1. etcd集群部署2. etcd集群操作3. 新增etcd集群節點1. etcd集群部署 etcd3.5官網站點: ?? https://etcd.io/docs/v3.5/op-guide/clustering/ ?? https://etcd.io/docs/v3.5/tutorials/how-to-setup-cluster/ [root@localh…

helm安裝配置jenkins

1、k8s1.28.2、helm3.12.0&#xff0c;集群搭建 查看節點運行情況 kubectl get node -o wide openebs部署情況 kubectl get sc -n openebs 2、添加Jenkins Helm倉庫 helm repo add jenkins https://charts.jenkins.iohelm repo update# 查看版本 helm search repo -l jen…

Wagtail - Django 內容管理系統

文章目錄 一、關于 Wagtail1、項目概覽2、相關鏈接資源3、功能特性 二、安裝配置三、使用入門1、快速開始2、兼容性 四、其它社區與支持1、社區資源2、商業支持 開發貢獻參考項目參考文獻 一、關于 Wagtail 1、項目概覽 Wagtail 是一個基于 Django 構建的開源內容管理系統&am…

Spring AI Alibaba 來啦!!!

博客標題&#xff1a;Spring AI Alibaba&#xff1a;深度解析其優勢與阿里云生態的無縫集成 引言 隨著人工智能技術的快速發展&#xff0c;越來越多的企業和開發者開始關注如何將 AI 技術融入到現有的應用開發框架中。Spring AI 作為 Spring 框架在 AI 領域的擴展&#xff0c;…

【論文閱讀39】PINN求邊坡內時空變化的地震動響應(位移、速度、加速度)場分布

論文提出了一種基于物理信息神經網絡&#xff08;PINN&#xff09;和極限分析上界定理相結合的巖體邊坡地震穩定性分析框架&#xff0c;重點考慮了邊坡中的預存裂縫對穩定性的影響。 PINN用來求解巖質邊坡內隨時間和空間變化的地震動響應&#xff08;位移、速度、加速度&#…