Home Explore Help
Sign In
kennyh
/
emqx4.3
1
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Tree: a55017ffaa
Branches Tags
emqx4.3
/
scripts
/
test
/
influx
Thales Macedo Garitezi e073bc90bc refactor(buffer_worker): rename `s/queue/buffer/g` 2 years ago
..
certs 9fc586f670 test: add influx docker test certs 3 years ago
README.md 24f476e35f test: add README to influxdb test script 2 years ago
docker-compose.yaml fbfd4a2565 test: use EMQX_IMAGE_TAG for influx test script 3 years ago
emqx.conf 21e933e9bb test: add rule to influx-bridge.conf and add newlines 3 years ago
influx-bridge.conf e073bc90bc refactor(buffer_worker): rename `s/queue/buffer/g` 2 years ago
start.sh 424d6ed34b test: improve start.sh script for influxdb tests 3 years ago

README.md

Test influxdb integration

This script starts two EMQX nodes and a influxdb server in docker container. The bootstraping rule engine and data bridge config is provided in influx-bridge.conf which got included in the bootstraping config bundle emqx.conf.

Start the cluster

./start.sh

How to run tests

The rule and bridge are configured to pipe data from MQTT topic t/# to the 'myvalues' measurement in the 'mqtt' bucket.

Manual verification steps

  • Start the cluster
  • Send mqtt messages to topic /t/a with a JSON object as MQTT paylaod like {"value": 1}
  • Observe data in influxdb curl -k -H 'Authorization: Token abcdefg' -G 'https://localhost:8086/query?pretty=true' --data-urlencode "db=mqtt" --data-urlencode "q=SELECT * from myvalues"

Example output the curl query against influxdb:

{"results":[{"statement_id":0,"series":[{"name":"myvalues","columns":["time","clientid","value"],"values":[["2023-02-28T11:13:29.039Z","a1",123]]}]}]