![]() Maybe it was before I started with docker… When I started to troubleshoot this, I started wondering why I have used a third-party broker. ![]() I used CloudMQTT as a broker, but after upgrading HA to 0.107 it stopped working for some reason. Next for exploring more powerful features of eKuiper? Refer to below for how to apply eKuiper in edge and integrate with AWS / Azure IoT cloud.In this post, I created a simple PHP-to-MQTT integration for Telldus Tellstick. You can also refer to eKuiper dashboard documentation for better using experience. To stop the test, just press ctrl + c in bin/kuiper query command console, or input exit and press enter. ![]() If having any problems, please take a look at log/stream.log. kuiper > select * from demo WHERE temperature > 30 Please try to publish another message with temperature less than 30, and it will be filtered by WHERE condition of the SQL. If everything goes well, you can see the message is print on docker bin/kuiper query window. # mosquitto_pub -h -m '' -t devices/device_001/messages ![]() Publish sensor data to topic devices/device_001/messages of server tcp://:1883 with any MQTT client tools. Kuiper > select * from demo where temperature > 30 # bin/kuiper create stream demo '(temperature float, humidity bigint) WITH (FORMAT="JSON", DATASOURCE="devices/+/messages")' Below steps will create a stream named demo, and data are sent to devices/device_001/messages topic, while device_001 could be other devices, such as device_002, all of those data will be subscribed and handled by demo stream. Let's say the temperature & humidity data are sent to, and those data will be processed in your LOCAL RUN eKuiper docker instance. docker run -p 9081:9081 -d -name ekuiper -e MQTT_SOURCE_DEFAULT_SERVERS= lfedge/ekuiper: $tagĬreate a stream - the stream is your stream data schema, similar to table definition in database. ![]() is a public MQTT test server hosted by EMQ. This sample uses server locating at tcp://:1883. It's recommended to use alpine image in this tutorial (refer to eKuiper Docker for the difference of eKuiper Docker image variants). ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |