カテゴリー: サイト関連

いよいよ「太陽光発電、 通知メールがなくなる」。さてどうしようか、2025/12/07時点で、一番下に添付したメールが朝9:00ころに届いている。これを、代替できるLINE通知する仕組みを作ってみました。 12/14に取得した結果は次の通り、ほぼ同じ結果で十分な結果と言えるでしょう。

自作したLINEでの表示例　と【フロンティアモニター】のレポート

下記の通り、2025年12月13日の発電量をお知らせいたします。

発電量：7.52kWh

下記の通り、2025年12月13日の電力量をお知らせいたします。

発電量：7.52kWh
売電量：0.28kWh
買電量：53.99kWh
今月の目標売電量(223kWh)に対して、28%達成しました。
今月の目標消費電力量(1,106kWh)に対して、641kWh消費しました。

下記の通り、2025年12月07日-2025年12月13日の電力量をお知らせいたします。

発電量：96.83kWh
売電量：31.50kWh
買電量：281.26kWh
今月の目標売電量(223kWh)に対して、28%達成しました。
今月の目標消費電力量(1,106kWh)に対して、641kWh消費しました。

実装方針

・従来の通知メールに含まれる発電量等の計測値データはすべて含める
・通知メールの種類はいくつかあるが、元データは１つなので、引数で送信メッセージの内容を切り替える
・CRONで起動指定する

この方針で、ここまでで作成した実装をベースに集計＋メッセージ送信するスクリプトを作成します。まずは、iPython上で動作確認して、hsBox上に移植しました。
以下のスクリプトを /home/hsbox/pyd/power_report.py に配置し、後述の設定を行いました。

スクリプト実装（例　★印の箇所は要更新）

# power_report.py
import pandas as pd
from datetime import datetime, timedelta
import os
import sys
import argparse
import requests

# ==================== 設定エリア ====================
NAS_PATH = r"/mnt/nas＜★NASマウント＋パス＞"  #★
IFTTT_WEBHOOK_URL0 = "https://maker.ifttt.com/trigger/{event}/with/key/{your_key}"  
IFTTT_EVENT_NAME = "＊＊＊＊＊＊"  # IFTTTで作ったイベント名★
your_key="＊＊＊＊＊＊＊＊"       # ←ここを自分のものに変更★
IFTTT_WEBHOOK_URL = IFTTT_WEBHOOK_URL0.replace("{your_key}", your_key)
# ====================================================


def send_line_message(title: str, body: str, timestamp: str):
    payload = {
        "value1": title,
        "value2": body,
        "value3": timestamp
    }
    url = IFTTT_WEBHOOK_URL.replace("{event}", IFTTT_EVENT_NAME)
    try:
        response = requests.post(url, headers={"Content-Type": "application/json"}, json=payload, timeout=10)
        if response.status_code == 200:
            print("LINE通知成功")
        else:
            print(f"エラー: {response.status_code}")
    except Exception as e:
        print(f"LINE通知失敗: {e}")
        
def load_day_data(target_date: datetime) -> pd.DataFrame:
    date_str = target_date.strftime("%Y%m%d")
    file_path = fr"{NAS_PATH}/power_{date_str}.parquet"
    if not os.path.exists(file_path):
        raise FileNotFoundError(f"データが見つかりません: {file_path}")
    return pd.read_parquet(file_path)

def calc_daily_summary(df: pd.DataFrame, date_label: str):
    # 数値化
    df["value1"] = pd.to_numeric(df["value1"], errors="coerce")  # 発電 kW
    df["value2"] = pd.to_numeric(df["value2"], errors="coerce")  # 買電 kW
    df["value3"] = pd.to_numeric(df["value3"], errors="coerce")  # 売電 kW
    df["value4"] = pd.to_numeric(df["value4"], errors="coerce") / 6   # 消費 kWh（既に1時間積算値）

    # 10分間隔と仮定して正確にkWh計算
    interval_min = 10
    hours_per_record = interval_min / 60.0

    total_gen_kwh  = df["value1"].mean() * len(df) * hours_per_record
    total_buy_kwh  = df["value2"].mean() * len(df) * hours_per_record
    total_sell_kwh = df["value3"].mean() * len(df) * hours_per_record
    total_use_kwh  = total_buy_kwh + total_gen_kwh - total_sell_kwh   # 電力収支で算出（最も正確）

    return {
        "date": date_label,
        "gen": round(total_gen_kwh, 2),
        "buy": round(total_buy_kwh, 2),
        "sell": round(total_sell_kwh, 2),
        "use": round(total_use_kwh, 2)
    }

def calc_week_summary(days=7, da=-8 ):
    """過去days日分の集計（今日を除く昨日まで）"""
    base_day = datetime.now().date()
    results = []
    for i in range(1+8+da, days + 1+8+da):
        target_date = base_day - timedelta(days=i)
        try:
            df = load_day_data(target_date)
            date_label = target_date.strftime("%m/%d")
            summary = calc_daily_summary(df, date_label)
            results.append(summary)
        except Exception as e:
            print(f"{target_date} のデータ読み込み失敗: {e}")
    
    if not results:
        return None
    
    total_gen = sum(r["gen"] for r in results)
    total_buy = sum(r["buy"] for r in results)
    total_sell = sum(r["sell"] for r in results)
    total_use = sum(r["use"] for r in results)

    lines = [f"【過去{days}日間実績】"]
    for r in reversed(results):  # 古い順→新しい順
        lines.append(f"{r['date']}: 発電{r['gen']} kWh")
    lines.append("")
    lines.append(f"合計発電量: {total_gen:.1f} kWh")
    lines.append(f"合計買電量: {total_buy:.1f} kWh")
    lines.append(f"合計売電量: {total_sell:.1f} kWh")
    lines.append(f"合計消費量: {total_use:.1f} kWh")
    
    return "\n".join(lines)

def main():
    parser = argparse.ArgumentParser(description="電力データ集計＆LINE通知")
    parser.add_argument("--da", type=int, default=0, help="日付加算。-1=昨日, 0=今日, 1=明日…")
    parser.add_argument("--ptn", type=str, default="f", choices=["p", "f", "w"],
                        help="p=発電量のみ, f=全項目, w=週間集計")
    args = parser.parse_args()

    # --- 対象日の決定 ---
    base_date = datetime.now()
    if args.da != 0:
        base_date += timedelta(days=args.da)
    
    # 今日の場合、現在時刻までのデータのみ読み込む（ファイルは当日分全部ある前提）
    target_date = base_date.date()    
    date_label = base_date.strftime("%Y/%m/%d")
    
    if args.ptn == "w":
        message = calc_week_summary(7,args.da)
        if message:
            send_line_message("太陽光発電1週間データ",message,"-")
            message=f"{message}\n"
        else:
            send_line_message("太陽光発電","週間集計データが取得できませんでした","-")
            message="週間集計データが取得できませんでした"
            print(message)
        return
    else:
        try:
            df = load_day_data(base_date)
        except Exception as e:
            send_line_message("太陽光発電",f"⚠️ {date_label} のデータがありません\n{e}","-")
            message = f"⚠️ {date_label} のデータがありません\n{e}"
            print(message)
            return

    summary = calc_daily_summary(df, date_label)

    # --- メッセージ作成 ---
    if args.ptn == "p":
        message = f"☀️ {base_date.date()} 発電量\n{summary['gen']} kWh"
    else:  # f
        message = f"⚡️ {base_date.date()}  電力実績\n" \
                  f"発電量　：{summary['gen']} kWh\n" \
                  f"買電量　：{summary['buy']} kWh\n" \
                  f"売電量　：{summary['sell']} kWh\n" \
                  f"消費電力量：{summary['use']} kWh"

    send_line_message("太陽光発電データ",message,"-OK-")
    print(message)

import sys
if "ipykernel_launcher.py" in sys.argv[0]:
    # ここに実行したい引数を書く（好きな組み合わせでOK）
    sys.argv = ["power_report.py"]              # ← ptnなし → f 扱い（今日分フル）
    #sys.argv = ["power_report.py", "--da", "-1"]         # 昨日分フル
    #sys.argv = ["power_report.py", "--ptn", "p"]         # 今日の発電量だけ
    # sys.argv = ["power_report.py", "--ptn", "w"]         # 週間集計

if __name__ == "__main__":
    main()

使用方法・CRON設定方法（CRON起動設定 例）

30 19 * * * /usr/bin/python3 /home/hsbox/pyd/power_report.py --da 0 --ptn p
19:30に当日の発電量を通知

0 9 * * * /usr/bin/python3 /home/hsbox/pyd/power_report.py --da -1 --ptn f
AM9:00に前日の発電量・売電量・買電量・消費電力を通知

1 9 * * 7 /usr/bin/python3 /home/hsbox/pyd/power_report.py --da -8 --ptn w
日曜日 AM9:00に前日までの7日間の発電量・売電量・買電量・消費電力を通知

IFTTTの設定

IFTTTでの設定は、随時更新されるため参考程度で見てください。詳細はWebhooksやLINEの項目を確認してください。 ※これは、2025/12/10時点の情報です。

Webhooksの「Your key」の確認方法

1. IFTTT にログイン

https://ifttt.com
 にアクセスし、ログインします。

2. Webhooks サービスページへ移動

以下の公式ページを開く
👉 https://ifttt.com/maker_webhooks

3. 右上の「Settings」をクリック

画面右上に Settingsという青いボタンがあります。

4. “Webhooks Settings” の欄を確認

開いたページに以下のような記載があります：

URL
https://maker.ifttt.com/use/＊＊＊＊＊＊＊＊＊＊


この key（＊＊＊＊＊＊＊の部分） が個人専用の Webhooks Key です。
このkeyをスクリプト(power_report.py)のyour_keyに設定してください

IFTTTの Applet 作成例（※画面は2025年12月現在のものです）

Appletの名称は自分にわかりやすいように任意に設定してください。

イベント（THEN）に「Receive a web request」を選択し、Event Nameを設定します。このEvent Nameをスクリプト（power_report.py）内のIFTTT_EVENT_NAMEに設定します。

THAT（実行内容）に LINEの「Send message to self」を選択し、自分のLINE accountを設定します。 Messageは、上のように設定すれば、設定完了です。

この設定は、自分あてのメッセージ送信なので、このスクリプトに限らず、他のメッセージ送信にも応用できます。

以下、2025/12/07に届いた通知メール

件名：【フロンティアモニター】 12月06日 電力量レポート


内容：
＊＊＊＊　様

日頃より【フロンティアモニター】ホームエネルギーモニタリングサービスをご利用いただき、誠にありがとうございます。

【システム終了のお知らせ】
2025年12月22日（月）をもって本計測装置のサービスを終了いたします。
なお、システムの都合により、一部サービス終了のタイミングについては前後する可能性がございますので、ご承知おきください。
詳しくはお客様ご利用サイトのお知らせ欄をご覧ください。

本メール発信は、メールシステムメンテナンスにより、１日遅延する場合があります。メンテナンスの日程は、お客様ログイン画面の「お知らせ」欄に随時記載いたします。
メンテナンス時はご不便をおかけしますが、何卒ご承知おきくださいますようお願いいたします。

下記の通り、2025年12月06日の電力量をお知らせいたします。

発電量：19.98kWh
売電量：9.56kWh
買電量：37.58kWh
今月の目標売電量(223kWh)に対して、14%達成しました。
今月の目標消費電力量(1,106kWh)に対して、293kWh消費しました。

省エネ目標が01月01日から変更されておりません。

発電・消費電力量は季節ごとにかわりますので、目標も毎月更新されることをおすすめします。

日没後に送られてくる当日分発電量

＊＊＊＊　様

日頃より【フロンティアモニター】ホームエネルギーモニタリングサービスをご利用いただき、誠にありがとうございます。

【システム終了のお知らせ】
2025年12月22日（月）をもって本計測装置のサービスを終了いたします。
なお、システムの都合により、一部サービス終了のタイミングについては前後する可能性がございますので、ご承知おきください。
詳しくはお客様ご利用サイトのお知らせ欄をご覧ください。

本メール発信は、メールシステムメンテナンスにより、１日遅延する場合があります。メンテナンスの日程は、お客様ログイン画面の「お知らせ」欄に随時記載いたします。
メンテナンス時はご不便をおかけしますが、何卒ご承知おきくださいますようお願いいたします。

下記の通り、2025年12月06日の発電量をお知らせいたします。

発電量：19.98kWh















今後ともフロンティアモニターをよろしくお願いいたします。
★なお、お心当たりのない方は、お手数ではございますが、下記メールアドレスまでご連絡頂きますようお願いいたします。
★このメールは送信専用メールアドレスから配信しています。このまま返信いただいてもお答えできませんのでご了承ください。
-----------------------------------------------
ソーラーフロンティア株式会社
【フロンティアモニター】お客様サービスセンター
電話：0570-053115(受付時間：9:00-17:00)※日曜、祝祭日、メーデー、年末年始を除く
メール：information@solar-frontier.com
-----------------------------------------------

上の内容のうち、太字部分に相当する情報を、LINEで通知するようにしてみました。
参考にしてみてください。

※追記情報

LINEへの通知はIFTTTをPROアカウントで利用している場合でも件数制限があるようです。たぶん、月間50件くらいの制限だと思われます。通常はE-mailでの通知にして、頻度が少ない異常の検知をした場合にだけ使うようにするのがよさそうです。

関連記事