概要

田んぼの水路の水位をリアルタイムで監視し、大雨や異常な水位変動が発生した場合に、農家や管理者に通知を送信することで、適切な対策を促すことができる。これによって、洪水のリスクを軽減し、農作物の保護と水管理の効率化を実現します。

システム・設置イメージ図

システムイメージ図↓

設置イメージ図(通常時)↓

設置イメージ図(危険時)

追記
現段階で超音波センサで測定した値によって通知を送信することができている。今後、ラズパイを追加してLoRa通信できるように開発していく予定

アイデア詳細

今回製作したシステムの基本機能を紹介する

リアルタイム水位監視：超音波センサで水面までの距離を定期的に測定し、データをラズパイに送信する。
自動警告通知システム：測定した距離から異常な水位上昇を検知するとLineNotifyを通じて警告を通知する。
履歴データの記録 : 測定データを保存し、長期的な水位の変動を可視化する。

全体の処理の流れとしては、常時ラズパイと接続している超音波距離センサーモジュールで水路の水位を測定し、 CSV ファイルに保存し、5回測定するごとにLineに送信されます。
また、測定した値が基準値を超えると水位が危険な状態と判断して、LoRa でラズパイ間を通信し、ラズパイからスマホへと LineNotify を通じて通知を送信します。

使用した部品

今回の製作で使用した部品を紹介する

Raspberry pi 4 × 2
超音波センサ(AJ-SR04M)
ブレッドボード
LoRaモジュール
配線(ジャンパー線など)

実際の配置イメージ

溝に沿うようにセンサの先を固定できるような外装にする予定。センサは、防水使用のものなので実際の設置場所でも正常に動作すると思われる。

LineNotifyの動作画面

センサで測定した水位が危険値の時（今回のプログラムでは、30cmを超えるとき）、警告文と具体的な距離が通知される。また、5回測定ごとにセンサの測定値を送るように動作している。

接続

接続方法は以下の通りになっていて、ジャンパー線でブレッドボードを介して直接接続している。

センサ側	ラズパイ側
AJ-SR04M	Raspberry Pi 4
5V	5V
Trig	Pin 15
Echo	Pin 14
GND	GND

接続図↓

ソースコード

以下、ラズパイのプログラムになります。
センサ側動作プログラムの概要は、距離センサで測定した値が30cmを超えると、測定値とともに危険文が通知されます。さらに、5回測定する毎にCSVファイルに保存した値をまとめて通知してみることができるようになっています。


センサ側動作プログラム
import RPi.GPIO as GPIO
import time
import requests
import csv
import os

# GPIOの設定
GPIO.setmode(GPIO.BCM)
TRIG = 15
ECHO = 14

GPIO.setup(TRIG, GPIO.OUT)
GPIO.setup(ECHO, GPIO.IN)

# Line Notifyのアクセストークン
LINE_NOTIFY_TOKEN = 'トークン'
LINE_NOTIFY_URL = 'https://notify-api.line.me/api/notify'

# CSVファイルの設定
csv_file = 'sensor_data.csv'

# CSVファイルの初期化
with open(csv_file, mode='w', newline='') as file:
    writer = csv.writer(file)
    writer.writerow(['Time', 'Distance (cm)'])  # ヘッダー

def send_line_notify(message, token):
    headers = {
        'Authorization': f'Bearer {token}',
        'Content-Type': 'application/x-www-form-urlencoded'
    }
    payload = {'message': message}
    response = requests.post(LINE_NOTIFY_URL, headers=headers, data=payload)
    return response

def get_distance():
    GPIO.output(TRIG, False)
    time.sleep(2)
    GPIO.output(TRIG, True)
    time.sleep(0.00001)
    GPIO.output(TRIG, False)

    start_time = time.time()
    stop_time = time.time()

    while GPIO.input(ECHO) == 0:
        start_time = time.time()

    while GPIO.input(ECHO) == 1:
        stop_time = time.time()

    time_elapsed = stop_time - start_time
    distance = (time_elapsed * 34300) / 2

    return distance

def read_csv():
    with open(csv_file, mode='r') as file:
        reader = csv.reader(file)
        next(reader)  # ヘッダーをスキップ
        data = [row for row in reader]
    return data

try:
    while True:
        distance = get_distance()
        current_time = time.strftime('%Y-%m-%d %H:%M:%S')

        with open(csv_file, mode='a', newline='') as file:
            writer = csv.writer(file)
            writer.writerow([current_time, f"{distance:.2f}"])  # データ行の追加

        print(f"距離: {distance:.2f} cm")

        if distance > 30:
            message = f"\n⚠️警告: 距離が {distance:.2f} cm を超えました！"
            response = send_line_notify(message, LINE_NOTIFY_TOKEN)
            if response.status_code == 200:
                print("通知が送信されました")
            else:
                print("通知の送信に失敗しました")

        # CSVの内容をLINEに送信
        if time.time() % 60 < 1:  # 1分ごとに送信
            csv_data = read_csv()
            message = "\n📊 センサーデータ:\n" + "\n".join([f"{row[0]}: {row[1]} cm" for row in csv_data])
            response = send_line_notify(message, LINE_NOTIFY_TOKEN)
            if response.status_code == 200:
                print("データが送信されました")
            else:
                print("データ送信に失敗しました")

        time.sleep(1)

except KeyboardInterrupt:
    print("プログラムが中断されました")

finally:
    GPIO.cleanup()

以下のプログラムは、超音波距離センサの動作確認プログラムになります。
ピンをマイコンと接続することで動作確認が可能になります。接続図を参考にしてみてください。


超音波センサ動作確認プログラム
import RPi.GPIO as GPIO
import time

# GPIOの設定
GPIO.setmode(GPIO.BCM)
TRIG = 15
ECHO = 14

GPIO.setup(TRIG, GPIO.OUT)
GPIO.setup(ECHO, GPIO.IN)

def get_distance():
    # センサーの初期化
    GPIO.output(TRIG, False)
    time.sleep(2)

    # トリガー信号を発信
    GPIO.output(TRIG, True)
    time.sleep(0.00001)
    GPIO.output(TRIG, False)

    start_time = time.time()
    stop_time = time.time()

    # エコー信号の開始と終了を計測
    while GPIO.input(ECHO) == 0:
        start_time = time.time()

    while GPIO.input(ECHO) == 1:
        stop_time = time.time()

    # 時間差を計算し、距離を算出
    time_elapsed = stop_time - start_time
    distance = (time_elapsed * 34300) / 2

    return distance

try:
    while True:
        distance = get_distance()
        print(f"距離: {distance:.2f} cm")
        time.sleep(1)

except KeyboardInterrupt:
    print("プログラムが中断されました")

finally:
    GPIO.cleanup()

これから
LoRaを用いた遠距離通信に挑戦していく予定

参考文献

ラズパイ搭載　長距離無線通信ドローンの作成とアドホックネットワークの構築
https://qiita.com/YU_GENE/items/3c96d6f1a75299789700
防水型超音波センサモジュール J S N - S R 0 4 T と A r d u i n o U N O で距離推定して遊んでみた
https://tmoribanner.hateblo.jp/entry/2020/03/15/211023

コメント無し