Commit 58cb80ab authored by charankumar's avatar charankumar

Update assignment3.md

parent 84a3ad41
......@@ -105,4 +105,39 @@ Sample Document:
### Reference:
https://kairosdb.github.io/docs/restapi/QueryMetrics.html
https://pypi.org/project/kairosdb-python/
## Task 3: Working with MQTT & REDIS
# Description
Data from different sites will be pushed with frequency of 10 seconds for the parameters PM10,PM2.5,SO2,NO2 via mqtt.
data can be of different quality - Good ( 0 ), Maintainance ( 1 ), Error ( 2 )
Based on the quality of data update to different redis database.
sample data format:
```json
{
"data" : { "PM10" : 100 , "PM2.5": 23, "SO2":21, "NO2": 32}
"site_id" : "site_100",
"data_quality": 1
}
```
Use Redis for caching/storing information
create consumer's which consumes data from these topics and store to a redis db based on data quality.
### Tools to use:
1. Pycharm / VSCode
2. MQTT - (paho-mqtt)
3. REDIS - (redis)
### Reference:
https://www.emqx.com/en/blog/how-to-use-mqtt-in-python
https://docs.redis.com/latest/rs/references/client_references/client_python/
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment