This application is implemented to monitor a variety of sensors and respond to custom rules depending on sensor type.
Scenario:
Supposing I have N sensors in any place, I can just define X and Y location points and the name of the sensor. Now, My mission is to get the data (without losing it) from any sensor at variable intervals and process it using custom commands for each sensor type. (sense 24/7)
You can use this application in three steps:
- Connect to the API and define your sensor.
- Make your commands to process the received sensor data. (make consumer)
- Just publish the sensors' data via API.
- see your results
The first point:
Sensors can only transfer the data via the internet, and there is no need to be involved in connection challenges or how to connect with sender hardware or software.
Just get the messages from each sensor, including sensor_id, time_stamp, and payload_data.
Big Challenges:
-Velocity of sending the data from sensors so fast
-Probably the connection failed after the right bulk data was sent.
-Each sensor, depending on the type, has a custom rule to process.
-Just a unique URL path used to get the data from sensors.
-Manage the data from any sensors without packet loss or server crashes.
Models:
- sensor_id->UUID
- sensor_name 3 .sensor_location_point(GIS) GIS field
- Sensor_type
- payload_data (some keys:value)JSON field
- Thresholds_data(related payload_data)
Feature:
- ability to involve other sensors' data(stream)
- ability to create a function
- ability to publish the result to another device via JSON
- ability to store all of the sense data(time series)
- Manage to get data with time intervals and detect modifications.
- ....
Picture of project:
- The user accesses the URL to register a sensor
- Get the UUID for each sensor registered
- UUID is important for sending the data from a sensor
- Sensors data must send include(Sensor_id,time_stamp,payload_data)
- The user can make custom rules for each sensor or complex
- The user can obvious the results
- decide to send another device
- for making visualizing
- save in time series data storage
Workflow:
- Authentication and Authorization of the users
- Make a facility for the user to CRUD sensor's information
- GET /sensors/ - Retrieves a list of sensors
- GET /sensors?sid= -Retrieve a specific sensor
- POST /sensors - Creates a new sensor
- PUT /sensors/{sid} - Update a specific sensor
- DELETE /sensors/{sid} - Delete a specific sensor
- Declare a unique URL used to send the sensor data
- POST /S/grabber/{sid}/ - Send the data from specific sensor detect with sid
- Run Message Broker ability to handle high volumes of data, facilitate real-time communication
Schema:
- IoT Node
- Gateway
- Integrator platform
- Visualization
- Prototyping
- storage