Uses the Communicating Sequential Processes also known as asyncronous programming to process real time sensor data in clojure for opensensors.io. We rely on clojure's core.async library heavily.
azondi takes a continous stream of messages from the test Mosquitto MQTT broker and creates an MQTT bridge. Using Server Side Events the data is pushed to the browser.
Clojurescript builds the dataflow model on which processes the data in the browser.
Writing 'quick and dirty' Clojure back-ends is fun, simple and easy. When Clojure systems get larger, separation of concerns becomes a harder problem. We know we should do it (that's progress at least) but it's easier said than done.
Therefore, this project is incubated with Jig. Jig pushes a separation of concerns into configurable components, while retaining the rapid development environment Clojure developers are used to. Jig is designed to be optional at deployment time.
Further documentation on the azondi development workflow using JIG can be found here
This is still an early version not quite read for production use.
We are using azondi to process sensor data on extremely large volumes and in a distributed manner. It is still in development but we welcome any feedback.
Copyright © 2014 opensensors.io
Azondi is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
Azondi is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
You should have received a copy of the GNU General Public License along with Foobar. If not, see http://www.gnu.org/licenses/.