TDengine安装,python客户端测试,接入DBeaver

Dec 09 2021

TDengine安装,python客户端测试,接入DBeaver

阿里云代理

分类：linux图文教程阅读次数

已被围观 605 次

服务端TDengine设备

依据文档推荐，现在支撑linux裸机设备，不建议docker设备，所以咱们这儿裸机设备

1.通过这个https://www.taosdata.com/assets-download/TDengine-server-2.2.0.5-Linux-x64.deb链接下载设备文件

2.放置此文件到192.168.0.13服务器上，通过指令sudo dpkg -i TDengine-server-2.2.0.5-Linux-x64.deb 设备

3.通过指令发动TDengine数据库sudo systemctl start taosd

4.参阅https://www.taosdata.com/cn/getting-started/#Quick%20Start上的指令可以去创立数据库和表检验

python客户端容器

以python做一个docker容器为例。这儿有一个很奇葩的地方，每一种TDengine的联接方法都必须要设置一个taos.cfg的途径，和设备一个独立的客户端程序

创立一个Dockerfile和一个检验文件sub.py ，一个requirements.txt文件，假如不用faker库，requirements.txt文件也不需要

Dockerfile内容如下

FROM python:3.9.7 ADD . . RUN wget https://www.taosdata.com/assets-download/TDengine-client-2.2.0.5-Linux-x64.tar.gz RUN tar -xzf TDengine-client-2.2.0.5-Linux-x64.tar.gz WORKDIR /TDengine-client-2.2.0.5 RUN ./install_client.sh WORKDIR / RUN git clone --depth 1 https://github.com/taosdata/TDengine.git RUN pip install -r requirements.txt  -i https://pypi.tuna.tsinghua.edu.cn/simple RUN pip install ./TDengine/src/connector/python -i https://pypi.tuna.tsinghua.edu.cn/simple CMD ["python","test.py"]

检验主文件test.py

import time  import taos from faker import Faker  fake = Faker() print() conn = taos.connect(host="192.168.0.13", user="root", password="taosdata", config="C:\TDengine\cfg") c1 = conn.cursor() import datetime  # 创立数据库 # c1.execute('create database db') c1.execute('use db') print("开端时间") print(time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())))  # # 建表 # c1.execute('create table tb (ts timestamp, temperature int, humidity float)') # # 刺进数据 start_time = datetime.datetime(2018, 11, 1) # affected_rows = c1.execute("insert into tb_ts_kv_t values (\'%s\', 'DEVICE', '1eb3c1d1d5db250860b6553ce011990', 'DCT', '1623200', True, '123', '456', 3.0)" %start_time) # 批量刺进数据 time_interval = datetime.timedelta(seconds=1) sqlcmd = ['insert into tb_ts_kv_t values'] for irow in range(1, 1000):  sqlcmd = ['insert into tb_ts_kv_t values']  start_time += time_interval  sqlcmd.append("('" + str(start_time) + "', 'DEVICE', '"+fake.company()+"', '"+fake.name()+"', '" + str(  irow) + "', True, '"+fake.word()+"', '456', " + str(irow * 1.2) + ")")  exestring = ' '.join(sqlcmd)  # sqlcmd.append('(\'%s\', %d, %f)' %(start_time, irow, irow*1.2))  affected_rows = c1.execute(exestring) print("完毕时间") print(time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())))  c1.execute('select * from tb_ts_kv_t') for data in c1:  print("ts=%s, temperature=%d, humidity=%f" %(data[0], data[4],data[-1]))