ekuiper-new/docs/zh_CN/plugins/sinks/influxdb.md

InfluxDB Sink

该插件将分析结果发送到InfluxDB中

编译插件&创建插件

在编译之前，请对源代码做如下更改：

• 在 go.mod 文件中增加对 InfluxDB 库文件的引用
• 把文件 plugins/sinks/influxdb.go 中的第一行 // +build influxdb 删除

# cd $kuiper_src
# go build --buildmode=plugin -o plugins/sinks/InfluxDB.so plugins/sinks/influxdb.go
# zip influx.zip plugins/sinks/InfluxDB.so
# cp influx.zip /root/tomcat_path/webapps/ROOT/
# bin/cli create plugin sink influx -f /tmp/influxPlugin.txt
# bin/cli create rule influx -f /tmp/influxRule.txt

重新启动Kuiper服务器以激活插件。

属性

Property name	Optional	Description
addr	true	The addr of the InfluxDB
measurement	true	The measurement of the InfluxDb (like table name)
username	false	The InfluxDB login username
password	false	The InfluxDB login password
databasename	true	The database of the InfluxDB
tagkey	true	The tag key of the InfluxDB
tagvalue	true	The tag value of the InfluxDB

示例用法

下面是选择温度大于50度的样本规则，和一些配置文件仅供参考。

/tmp/influxRule.txt

{
  "id": "influx",
  "sql": "SELECT * from  demo_stream where temperature < 50",
  "actions": [
    {
      "log": {},
      "influx":{
       "addr": "http://192.168.100.245:8086",
       "username": "",
       "password": "",
       "measurement": "test",
       "databasename": "databasename",
       "tagkey": "tagkey",
       "tagvalue": "tagvalue"
      }
    }
  ]
}

/tmp/influxPlugin.txt

{
  "file":"http://localhost:8080/influx.zip"
}

plugins/go.mod

module plugins

go 1.14

require (
        github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
        github.com/influxdata/influxdb-client-go v1.2.0
        github.com/influxdata/influxdb1-client v0.0.0-20200515024757-02f0bf5dbca3 // indirect
)

replace github.com/emqx/kuiper => /root/goProject/kuiper