Compile the plugins
plugins/go.mod
module plugins
go 1.13
replace github.com/emqx/kuiper => /$kuiper
require (
github.com/emqx/kuiper v0.0.0-00010101000000-000000000000 // indirect
github.com/taosdata/driver-go v0.0.0-20200723061832-5be6460b0c20
)
go mod edit -replace github.com/emqx/kuiper=/$kuiper
go build --buildmode=plugin -o /$kuiper/plugins/sinks/Taos@v1.0.0.so /$kuiper/plugins/sinks/taos.go
Rule Actions Description
| Name |
Type |
Optional |
Description |
| ip |
string |
false |
Database ip |
| port |
int |
false |
Database port |
| user |
string |
false |
Username |
| password |
string |
false |
Password |
| database |
string |
false |
Database name |
| table |
string |
false |
Table Name |
| fields |
[]string |
true（Replace with data key when not filling in） |
Table field collection |
Operation example
To create a database or table, refer to the following documents:
https://www.taosdata.com/cn/getting-started/
Create a stream
curl --location --request POST 'http://127.0.0.1:9081/streams' --header 'Content-Type:application/json' --data '{"sql":"create stream demoStream(time string, age BIGINT) WITH ( DATASOURCE = \"device/+/message\", FORMAT = \"json\");"}'
Create a rule
curl --location --request POST 'http://127.0.0.1:9081/rules' --header 'Content-Type:application/json' --data '{"id":"demoRule","sql":"SELECT * FROM demoStream;","actions":[{"taos":{"port":0,"ip":"127.0.0.1","user":"root","password":"taosdata","database":"dbName","table":"tableName","fields":["time","age"]}}]}'
Send data
mosquitto_pub -h broker.emqx.io -m '{"time":"2020-01-11 18:18:18", "age" : 18}' -t device/device_001/message
