{"id":401,"date":"2018-02-28T15:18:04","date_gmt":"2018-02-28T15:18:04","guid":{"rendered":"http:\/\/www.igfasouza.com\/blog\/?p=401"},"modified":"2021-04-27T10:48:48","modified_gmt":"2021-04-27T09:48:48","slug":"raspberry-pi-with-influxdb-and-grafana","status":"publish","type":"post","link":"http:\/\/www.igfasouza.com\/blog\/raspberry-pi-with-influxdb-and-grafana\/","title":{"rendered":"Raspberry Pi with InfluxDB and Grafana"},"content":{"rendered":"

\"\"<\/p>\n

Alright, boss?<\/b><\/p>\n

Grafana<\/strong> is an open source metric analytics & visualization suite. It is most commonly used for visualizing time series data for infrastructure and application analytics but many use it in other domains including industrial sensors, home automation, weather, and process control.<\/p>\n

https:\/\/grafana.com\/<\/a>
\nhttp:\/\/docs.grafana.org\/guides\/getting_started\/<\/a><\/p>\n

InfluxDB<\/strong> is an open-source time series database developed by InfluxData.
\nit is written in Go and optimized for fast, high-availability storage and retrieval of time series data in fields such as operations monitoring, application metrics, Internet of Things sensor data, and real-time analytics. <\/p>\n

https:\/\/www.influxdata.com\/<\/a><\/p>\n

Install InfluxDB on Raspberry Pi
\nhttps:\/\/gist.github.com\/boseji\/bb71910d43283a1b84ab200bcce43c26<\/a><\/p>\n

You can follow the link for more details but basically, I just run this:<\/p>\n

1
2
3
4
5
6
7
<\/div><\/td>
sudo<\/span> apt-get update<\/span> &&<\/span> sudo<\/span> apt install<\/span> apt-transport-https curl
\n
\ncurl -sL<\/span> https:\/\/<\/span>repos.influxdata.com\/<\/span>influxdb.key |<\/span> sudo<\/span> apt-key add<\/span> -
\n
\necho<\/span> "deb https:\/\/repos.influxdata.com\/debian jessie stable"<\/span> |<\/span> sudo<\/span> tee<\/span> \/<\/span>etc\/<\/span>apt\/<\/span>sources.list.d\/<\/span>influxdb.list
\n
\nsudo<\/span> apt-get update<\/span> &&<\/span> sudo<\/span> apt-get install<\/span> influxdb<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

For this example we don\u2019t care about the web-based Admin user interface.<\/p>\n

To start the server<\/p>\n

1
<\/div><\/td>
sudo<\/span> service influxdb start<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

Install Grafana on Raspberry Pi
\nhttps:\/\/github.com\/fg2it\/grafana-on-raspberry\/wiki<\/a><\/p>\n

You can follow the link for more details but basically, I just run this:<\/p>\n

1
2
3
4
5
6
7
8
9
<\/div><\/td>
sudo<\/span> apt-get install<\/span> apt-transport-https curl
\n
\ncurl https:\/\/<\/span>bintray.com\/<\/span>user\/<\/span>downloadSubjectPublicKey?username<\/span>=bintray |<\/span> sudo<\/span> apt-key add<\/span> -
\n
\necho<\/span> "deb https:\/\/dl.bintray.com\/fg2it\/deb jessie main"<\/span> |<\/span> sudo<\/span> tee<\/span> -a<\/span> \/<\/span>etc\/<\/span>apt\/<\/span>sources.list.d\/<\/span>grafana.list
\n
\nsudo<\/span> apt-get update<\/span>
\n
\nsudo<\/span> apt-get install<\/span> grafana<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

To start the server<\/p>\n

1
<\/div><\/td>
sudo<\/span> service grafana-server start<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

With everything installed you are ready to start doing some awesome things.<\/p>\n

I going to show two examples here:
\nOne using sense-hat<\/a> to get the temperature, pressure and humidity value
\nand other using HS110<\/a> to get the energy consumption <\/p>\n

Here is a good InfluxDB getting started
\nhttps:\/\/docs.influxdata.com\/influxdb\/v0.8\/introduction\/getting_started\/<\/a><\/p>\n

1
<\/div><\/td>
influx -precision<\/span> rfc3339<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n
1
<\/div><\/td>
CREATE<\/span> DATABASE<\/span> logger<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

You can test with<\/p>\n

1
<\/div><\/td>
SHOW<\/span> DATABASES<\/span><\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

To run the code you need Install the python package first<\/p>\n

1
<\/div><\/td>
sudo<\/span> pip install<\/span> influxdb<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

Both examples are quite similar. Just change what I write on the table.
\nThis code is a hack from some Google examples.<\/p>\n

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
<\/div><\/td>
import<\/span> argparse
\nimport<\/span> time<\/span>
\nimport<\/span> datetime<\/span>
\nimport<\/span> sys<\/span>
\nfrom<\/span> influxdb import<\/span> InfluxDBClient
\nfrom<\/span> sense_hat import<\/span> SenseHat
\n
\nsense=<\/span>SenseHat(<\/span>)<\/span>
\n 
\n# Set required InfluxDB parameters.<\/span>
\nhost =<\/span> "localhost"<\/span> #Could also set local ip address<\/span>
\nport =<\/span> 8086<\/span>
\nuser<\/span> =<\/span> "root"<\/span>
\npassword =<\/span> "root"<\/span>
\n 
\n# How frequently we will write sensor data from SenseHat to the database.<\/span>
\nsampling_period =<\/span> 5<\/span>
\n
\ndef<\/span> get_args(<\/span>)<\/span>:
\n    '''This function parses and returns arguments passed in'''<\/span>
\n    # Assign description to the help doc<\/span>
\n    parser<\/span> =<\/span> argparse.ArgumentParser<\/span>(<\/span>description=<\/span>'Program writes measurements data from SenseHat to specified influx db.'<\/span>)<\/span>
\n    # Add arguments<\/span>
\n    parser<\/span>.add_argument<\/span>(<\/span>
\n        '-db'<\/span>,<\/span>'--database'<\/span>,<\/span> type<\/span>=<\/span>str<\/span>,<\/span> help<\/span>=<\/span>'Database name'<\/span>,<\/span> required=<\/span>True<\/span>)<\/span>
\n    parser<\/span>.add_argument<\/span>(<\/span>
\n        '-sn'<\/span>,<\/span>'--session'<\/span>,<\/span> type<\/span>=<\/span>str<\/span>,<\/span> help<\/span>=<\/span>'Session'<\/span>,<\/span> required=<\/span>True<\/span>)<\/span>
\n    now =<\/span> datetime<\/span>.datetime<\/span>.now<\/span>(<\/span>)<\/span>
\n    parser<\/span>.add_argument<\/span>(<\/span>
\n        '-rn'<\/span>,<\/span>'--run'<\/span>,<\/span> type<\/span>=<\/span>str<\/span>,<\/span> help<\/span>=<\/span>'Run number'<\/span>,<\/span> required=<\/span>False<\/span>,<\/span>default=<\/span>now.strftime<\/span>(<\/span>"%Y%m%d%H%M"<\/span>)<\/span>)<\/span>
\n   
\n    # Array of all arguments passed to script<\/span>
\n    args=<\/span>parser<\/span>.parse_args<\/span>(<\/span>)<\/span>
\n    # Assign args to variables<\/span>
\n    dbname=<\/span>args.database<\/span>
\n    runNo=<\/span>args.run<\/span>
\n    session=<\/span>args.session<\/span>
\n    return<\/span> dbname,<\/span> session,<\/span>runNo
\n   
\ndef<\/span> get_data_points(<\/span>)<\/span>:
\n    # Get the three measurement values from the SenseHat sensors<\/span>
\n    temperature =<\/span> sense.get_temperature<\/span>(<\/span>)<\/span>
\n    pressure =<\/span> sense.get_pressure<\/span>(<\/span>)<\/span>
\n    humidity =<\/span> sense.get_humidity<\/span>(<\/span>)<\/span>
\n    # Get a local timestamp<\/span>
\n    timestamp=<\/span>datetime<\/span>.datetime<\/span>.utcnow<\/span>(<\/span>)<\/span>.isoformat<\/span>(<\/span>)<\/span>
\n    print<\/span> (<\/span>"{0} {1} Temperature: {2}{3}C Pressure: {4}mb Humidity: {5}%"<\/span> .format<\/span>(<\/span>session,<\/span>runNo,<\/span>
\n    round<\/span>(<\/span>temperature,<\/span>1<\/span>)<\/span>,<\/span>u'u00b0'<\/span>.encode<\/span>(<\/span>'utf8'<\/span>)<\/span>,<\/span>
\n    round<\/span>(<\/span>pressure,<\/span>3<\/span>)<\/span>,<\/span>round<\/span>(<\/span>humidity,<\/span>1<\/span>)<\/span>)<\/span>)<\/span>
\n   
\n    # Create Influxdb datapoints (using lineprotocol as of Influxdb >1.1)<\/span>
\n    datapoints =<\/span> [<\/span>
\n            {<\/span>
\n                "measurement"<\/span>: session,<\/span>
\n                "tags"<\/span>: {<\/span>"runNum"<\/span>: runNo,<\/span>
\n                }<\/span>,<\/span>
\n                "time"<\/span>: timestamp,<\/span>
\n                "fields"<\/span>: {<\/span>
\n                    "temperaturevalue"<\/span>:temperature,<\/span>"pressurevalue"<\/span>:pressure,<\/span>"humidityvalue"<\/span>:humidity
\n                    }<\/span>
\n                }<\/span>
\n            ]<\/span>
\n    return<\/span> datapoints
\n
\n# Match return values from get_arguments()<\/span>
\n# and assign to their respective variables<\/span>
\ndbname,<\/span> session,<\/span> runNo =<\/span>get_args(<\/span>)<\/span>  
\nprint<\/span> "Session: "<\/span>,<\/span> session
\nprint<\/span> "Run No: "<\/span>,<\/span> runNo
\nprint<\/span> "DB name: "<\/span>,<\/span> dbname
\n
\n# Initialize the Influxdb client<\/span>
\nclient =<\/span> InfluxDBClient(<\/span>host,<\/span> port,<\/span> user<\/span>,<\/span> password,<\/span> dbname)<\/span>
\n       
\ntry<\/span>:
\n     while<\/span> True<\/span>:
\n        # Write datapoints to InfluxDB<\/span>
\n        datapoints=<\/span>get_data_points(<\/span>)<\/span>
\n        bResult=<\/span>client.write_points<\/span>(<\/span>datapoints)<\/span>
\n        print<\/span>(<\/span>"Write points {0} Bresult:{1}"<\/span>.format<\/span>(<\/span>datapoints,<\/span>bResult)<\/span>)<\/span>
\n       
\n        sense.show_message<\/span>(<\/span>"OK"<\/span>)<\/span>
\n           
\n        # Wait for next sample<\/span>
\n        time<\/span>.sleep<\/span>(<\/span>sampling_period)<\/span>
\n       
\n        # Run until keyboard ctrl-c<\/span>
\nexcept<\/span> KeyboardInterrupt<\/span>:
\n    print<\/span> (<\/span>"Program stopped by keyboard interrupt [CTRL_C] by user. "<\/span>)<\/span><\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

The HS110 example I just change some lines:<\/p>\n

1
2
3
4
5
6
7
8
9
10
11
12
13
14
<\/div><\/td>
consumption =<\/span> plug.get_emeter_realtime<\/span>(<\/span>)<\/span>[<\/span>\u201cpower\u201d]<\/span>
\n    # Create Influxdb datapoints (using lineprotocol as of Influxdb >1.1)<\/span>
\n    datapoints =<\/span> [<\/span>
\n            {<\/span>
\n                "measurement"<\/span>: session,<\/span>
\n                "tags"<\/span>: {<\/span>"runNum"<\/span>: runNo,<\/span>
\n                }<\/span>,<\/span>
\n                "time"<\/span>: timestamp,<\/span>
\n                "fields"<\/span>: {<\/span>
\n                    "consumption"<\/span>:consumption
\n                    }<\/span>
\n                }<\/span>
\n            ]<\/span>
\n    return<\/span> datapoints<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

To run:<\/p>\n

1
<\/div><\/td>
python igor.py -db<\/span>=logger -sn<\/span>=test1<\/div><\/td><\/tr><\/tbody><\/table><\/div>\n

To setup Grafana:
\nhttp:\/\/localhost:3000<\/p>\n

Go to Datasource->Add New and fill in with your database details
\nUser and psw should be: \u201croot\u201d and \u201croot\u201d by default<\/p>\n

\"\"<\/a><\/p>\n

Create a new dashboard, choose your database and on the tab matrics configure your query.
\n\"\"<\/a><\/p>\n

Edit the dashboard and go to metrics.<\/p>\n

\"\"<\/a><\/p>\n

Choose the database and then configure the query.<\/p>\n

\"\"<\/a><\/p>\n

\n
\n

Sense hat + Grafana = on fly himidity, temperature and pressure dashboard pic.twitter.com\/bp0d8jTXXZ<\/a><\/p>\n

— Igor Souza (@Igfasouza) February 26, 2018<\/a><\/p><\/blockquote>\n<\/div>\n

If you succeed in create your dashboard let a comment below about what are you doing.<\/p>\n","protected":false},"excerpt":{"rendered":"

Alright, boss? Grafana is an open source metric analytics & visualization suite. It is most commonly used for visualizing time series data for infrastructure and application analytics but many use it in other domains including industrial sensors, home automation, weather,… Continue Reading →<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":827,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[24],"tags":[13],"class_list":["post-401","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-raspberry-pi","tag-raspberry-pi"],"_links":{"self":[{"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/posts\/401","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/comments?post=401"}],"version-history":[{"count":15,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/posts\/401\/revisions"}],"predecessor-version":[{"id":1192,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/posts\/401\/revisions\/1192"}],"wp:featuredmedia":[{"embeddable":true,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/media\/827"}],"wp:attachment":[{"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/media?parent=401"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/categories?post=401"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.igfasouza.com\/blog\/wp-json\/wp\/v2\/tags?post=401"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}