feats是什么意思ts在线翻译读音例句

Python操作TDengine并进⾏简单风机预测应⽤

Python操作TDengine并进⾏简单风机预测应⽤

⼀、安装

Linux端安装PythonConnector

1、确保Linux环境下安装了Python环境，我的python版本Python3.6.0。

pipinstallpython3/

3、执⾏命令python进⼊交互式界⾯，输⼊importtaos报错。

4、出现上⾯错误的原因是：⽂件在/usr/lib⽬录下，⽽centos古朗月行16句全诗视频 默认不会找/usr/lib下的⽂件。

解决⽅法：在环境变量/etc/profile中配置路径。

编辑配置⽂件：vim/etc/profile

添加配置：exportLD_LIBRARY_PATH=$LD_LIBRARY_PATH:/usr/lib

使修改⽣效：source/etc/profile

5、再次进⼊python交互式界⾯，导⼊taos模块成功。

python接收MQTT数据

Windows端安装PythonConnector：

1、利⽤pip安装TDengine源代码中srcconnectorpythonwindows⽬录下的python3对应的taos模块。

3、双击exe可执⾏⽂件，安装客户端，默认下⼀步到安装完成即可。

4、通过代码，查看windows是否可以访问TDengine

#!/usr/bin/envpython

#coding=utf-8

>FileName:

#>Author:cuiyufei

#>Mail:XXX@

#>CreatedTime:2019年8⽉22⽇

###importtaos

importpandasaspd

if__name__==\'__main__\':

#连接taos数据库

conn=t(host=\'10.1.131.14\',user=\'root\',password=\'taosdata\',database=\'log\')

#通过获取到的数据库连接conn下的cursor()⽅法来创建游标

cursor=()

#Createadatabasenameddb

#try:

#e(\'createdatabasetest1\')

#exceptExceptionaserr:

#()

#raise(err)

sql=\"SELECT*文言文孙权劝学原文及翻译 FROMlog\"

#read_sql⽅法返回的数据类型是DataFrame

dataframe=_sql(sql,con=conn)

printdataframe

出现如下图错误。

最后发现，是由于客户端版本和服务端版中秋名言名句简短 本不⼀致导致的。

taos-hyouIP

windows端：

Linux端：

taos-V

升级Linux端的taos版本

systemctlstoptaosd

rpm-qa|grep-itdengine

7.x86_64

7.x86_

systemctlstarttaosd

systemctlstatustaosd

升级后，连接成功。

⼆、python操作TDengine

#!/usr/bin/envpython

#coding=utf-8

>FileName:

#>Author:cuiyufei

#>Mail:XXX@

#>CreatedTime:2019年8⽉22⽇

###importtaos

importsys

importdatetime

importrandom

defexitProgram(conn):

()

()

if__name__==\'__main__\':

start_time=me(2019,7,1)

time_interval=lta(seconds=60)

#ConnecttoTDengineserver.

##parameters:

#@host:TDengineserverIPaddress

#@user:UsernameusedtoconnecttoTDengineserver

#@password:Password

#@database:DatabasetousewhenconnectingtoTDe七年级上册语文试卷 ngineserver

#@config:Configurationdirectory

conn=t(host=\"yourIP\",user=\"root\",password=\"taosdata\",config=\"/etc/taos\")

#GenerateacursorobjecttorunSQLcommands

c1=()

#Createadatabasenameddb

try:

e(\'createdatabasedb\')

exceptExceptionaserr:

()

raise(err)

#usedatabase

try:

e(\'usedb\')

exceptExceptionaserr:

()

raise(err)

#createtable

try:

e(\'createtableifnotexistst(tstimestamp,aint,bfloat,cbinary(20))\')

exceptExceptionaserr:

()

raise(err)

#insertdata

foriinrange(1000古朗月行朗读 0):

try:

e(\"insertintotvalues(\'%s\',%d,%f,\'%s\')\"%(start_time,t(1,10),t(1,10)/10.0,\'hello\')配乐诗朗诵欣赏经典 )

exceptExceptionaserr:

()

raise(err)

start_time+=time_interval

#querydataandreturndataintheformoflist

try:

e(\'select*fromdb.t\')

exceptExceptionaserr:

()

raise(err)

#ptionlist

cols=ption

#Usefetchalltofetchdatainalist

data=ll()

try:

e(\'select*fromdb.t\')

exceptExceptionaserr:

()

raise(err)

#Useiteratortogothroughtheretreiveddata

forcolinc1:

print(col)

()

三、接收mqtt数据并存⼊TDengine

从mqtt接收数据，通过模董仲舒传 型进⾏数据预测，然后把数据写⼊TDengine

#!/usr/bin/envpython

#coding=utf-8

>FileName:

#>Author:cuiyufei

#>Mail:XXX@

#>CreatedTime:2019年8⽉22⽇

###asmqtt

importdatetime

alsimportjoblib

frominfluxdbimportInfluxDBClient

impor仓央嘉措最经典的句子 ttaos

importrandom

#INFLUXDB

TAOS_HOST=\"yourIP\"

TAOS_USER=\"root\"

TAOS_PASSWORD=\"taosdata\"

TASO_DB=\'yourdatabase\'

#MQTT

MQTT_HOST=\"yourIP\"

MQTT_PORT=PORT

MQTT_TOPIC=\'yourtopic\'

definsert_influxdb(msg):

current_time=()#.isoformat()

print(+\"\"+\":\"+str(d))

feats=[\'wind_speed\',\'generator_speed\',\'power\',\'wind_direction\',

\'wind_direction_mean\',\'yaw_position\',\'yaw_speed\',\'pitch1_angle\',

\'pitch2_angle\',\'pitch3_angle\',\'pitch1_speed\',\'pitch2_speed\',

\'pitch3_sp芭蕉不展丁香结同向春风各自愁诗意 eed\',\'pitch1_moto_tmp\',\'pitch2_moto_tmp\',\'pitch3_moto_tmp\',

\'acc_x\',\'acc_y\',\'environment_tmp\',\'int_tmp\',

\'pitch1_ng5_tmp\',\'pitch2_ng5_tmp\',\'pitch3_ng5_tmp\',\'pitch1_ng5_DC\',

\'pitch2_ng5_DC\',\'pitch3_ng5_DC\',\'group\']

feats_value=[float(value)forvaluein(eval(d)[1:])]

#风机预测

model=\'./model/\'

clf=(model)

sub_preds=t_proba([feats_value],num_iteration=_iteration_)[:,1]

print(sub_pre过秦论知识点归纳整理 ds[0])

conn=t(host=TAOS_HOST,user=TAOS_USER,password=TAOS_PASSWORD,database=TASO_DB)

cursor=()

try:

#e(\"insertintotvalues(\'%s\',%d,%.14f,\'%s\')\"%(current_time,feats_value[0],feats_value[1],\'hello\'))

e(\"insertintowind_driven_generatorvalues(\'%s\',%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f,%f

,%f,%f,%f,%f,%f)\"%(current_time,feats_value[0],feats_value[1],feats_value[2],feats_value[3],feats_value[4],feats_value[5],feats_value[6],feats_val

ue[7],feats_value[8],feats_value[9],feats_value[10],feats_value[11],feats_value[12],feats_value[13],feats_value[14],feats_value[15],feats_value[16],f

eats_value[17],feats_value[18],feats_value[19],feats_value[20],feats_value[21],feats_value[22],feats_value[23],feats_value[24],feats_value[25],feats_

value[26],sub_preds[0]))

exceptExceptionaserr:

()

raise(err)

()

if__name__==\'__main__\':

#influxdb_client=InfluxDBClient(host=INFLUXDB_HOST,port=INFLUXDB_PORT,username=INFLUXDB_USER,password=INFLUXDB_PASSWORD,d

atabase=INFLUXDB_DB)

mqtt_client=()

mqtt__connect=lambdaself,mosq,obj,rc:ibe(MQTT_TOPIC)

mqtt__message=lambdaclient,userdata,msg:insert_influxdb(msg)

mqtt_t(MQTT_HOST,MQTT_PORT,60)

try:

mqtt__forever()

exceptKeyboardInterrupt:

print(\"\")

参考⽂章