サーバーと可視化と自称IoT女子

五十嵐

その他

2016.11.1

Topics

こんな構成になってます
センサーデータをとって可視化するまでの流れはこうです
データ表示はこうなってます
ソースコードです
可視化しました
Time to say goodbye

こんにちは色々とマイナーチェンジを図りたいです五十嵐a.k.a自称IoT女子です☻☻☻

五十嵐a.k.a.自称IoT女子
2016入社大学院で花の遺伝子を研究するも、日本のインダストリー4.0に夢中となり、その実現を目指す＆その恩恵を直接受けるべく4月より入社し奮闘中
三度の飯よりでんぱ組.inc

今回は、こちら→ラズパイと対話する植物と自称IoT女子の続きです
前回は取得したデータをメイさんが喋ってくれる、ということをやりました
今回はそのデータをサーバーに送ってデータ集積し、更に可視化する、ということをやっていきます

こんな構成になってます

センサーデータをとって可視化するまでの流れはこうです

データ表示はこうなってます

ソースコードです

以前に上げたものが元になっていて、センサーの値を取得します。

#! /usr/bin/env python
# -*- coding: utf-8 -*-
import os
import sys
import glob
import time
import datetime
import re
import subprocess
import spidev
import Adafruit_DHT
from slacker import Slacker
import RPi.GPIO as GPIO
spi = spidev.SpiDev()
spi.open(0, 0)
def get_temp_and_humid(sensor=11, pin=4):
    """温度湿度センサー(DHT11)から温度と湿度を取得する
    """
    # 湿度と温度を取得
    humidity, temperature = Adafruit_DHT.read_retry(sensor, pin)
    # 湿度と温度が正常に取得できていたら、値を返す
    if humidity is not None and temperature is not None:
        return (temperature, humidity)
    else:
        print('Failed to get reading. Try again!')
        sys.exit(1)
def get_moisture(channel):
    """ADCの指定したチャンネルのデータを取得する
    """
    adc = spi.xfer2([1,(8+channel)<<4,0])
    data = ((adc[1]&3) << 8) + adc[2]
    return data
if __name__ == '__main__':
    print("温度,湿度:", get_temp_and_humid())
    print("水分量:",  get_moisture(0))

RaspberryPiに設置しているもの　(RP→kafka)

#! /usr/bin/env python
# -*- coding: utf-8 -*-
import datetime
from sensordata import *
from kafka import KafkaProducer
def get_date():
    """ 現在時刻を取得する
    """
    now = datetime.datetime.now()
    return now.strftime("%Y-%m-%d %H:%M:%S")
def shape_data():
    """ 取得したセンサーデータを整形する
    """
    temp, humid = get_temp_and_humid()
    moisture = get_moisture(0)
    date = get_date()
    result = {"temp": temp,
              "humid": humid,
              "moisture": moisture,
              "date": date}
    return result
def post_kafka():
    """ Kafkaにデータを送信する
    """
    producer = KafkaProducer(bootstrap_servers=["203.104.251.126:9092"])
    message = shape_data()
    producer.send("sensor_data001",
                  str(message).encode("utf-8"))
    producer.flush()
if __name__ == '__main__':
    post_kafka()

サーバーサイドに設置しているもの (kafka→mongoDB)

#! /usr/bin/env python
# -*- coding: utf-8 -*-
from ast import literal_eval
from kafka import KafkaConsumer
from pymongo import MongoClient
def str_to_dict(data):
    """Kafkaで受け取った文字列を辞書型に変換する
    """
    return literal_eval(data)
def insert_data(data):
    """ MongoDBにデータを保存する
    """
    client = MongoClient("localhost:27017")
    db_connect = client["plant001"]
    db_connect["sensor_data"].insert_one(data)
def reseive_kafka():
    """ Kafkaからデータを受け取り、MongoDBに保存する
    """
    consumer = KafkaConsumer("sensor_data001",
                             bootstrap_servers=["localhost:9092"])
    for c in consumer:
        dic = str_to_dict(c.value.decode("utf-8"))
        insert_data(dic)
if __name__ == '__main__':
    reseive_kafka()