HEMSでデータが取得出来るようになったので、時系列でグラフ化してみる。
自宅では特に発電してるわけでもないので、「定時積算電力量計測値(逆方向計測値)」とか、履歴はいらないか。
ここでは「瞬時電流計測値」「瞬時電力計測値」「積算電力量計測値(正方向計測値)」「積算電力量計測値(逆方向計測値)」を測り、cacti の scriptsで動かして5分毎のデータをグラフ化。
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
#
# smartmeter.py3
#
from __future__ import print_function
import sys
import serial
import time
# Bルート認証ID（東京電力パワーグリッドから郵送で送られてくる）
rbid = "AAAABBBBCCCCDDDD"
# Bルート認証パスワード（東京電力パワーグリッドからメールで送られてくる）
rbpwd = "PASSWORDDDDDDD"
# シリアルポートデバイス名
#serialPortDev = 'COM3' # Windows の場合
serialPortDev = '/dev/ttyUSB0' # Linux(ラズパイなど）の場合
#serialPortDev = '/dev/cu.usbserial-A103BTPR' # Mac の場合
#
ser = serial.Serial(serialPortDev, 115200)
#
# Bルート認証パスワード設定
wcom="SKSETPWD C " + rbpwd + "\r\n"
ser.write(str.encode(wcom))
# Bルート認証ID設定
wcom="SKSETRBID " + rbid + "\r\n"
ser.write(str.encode(wcom))
scanRes = {} # スキャン結果の入れ物
scanRes["Channel"]="33"
scanRes["Channel Page"]="09"
scanRes["Pan ID"]="24EF"
scanRes["Addr"]="00FFEEDDCCBBAA99"
scanRes["LQI"]="3C"
scanRes["PairID"]="12345678"
# スキャン結果からChannelを設定。
wcom="SKSREG S3 " + scanRes["Pan ID"] + "\r\n"
ser.write(str.encode(wcom))
#print(ser.readline(), end="") # エコーバック
ser.readline()
#print(ser.readline(), end="") # OKが来るはず（チェック無し）
ser.readline()
# スキャン結果からPan IDを設定
wcom="SKSREG S3 " + scanRes["Pan ID"] + "\r\n"
ser.write(str.encode(wcom))
#print(ser.readline(), end="") # エコーバック
ser.readline()
#print(ser.readline(), end="") # OKが来るはず（チェック無し）
ser.readline()
# 直接指定しちゃう
ipv6Addr = "FE80:0000:0000:0000:02FF:EEDD:CCBB:AA99"
#
# いきなり SKJOINをしてもつながらないことがあるため、SKPINGしてみます。
#
while True:
wcom="SKPING " + ipv6Addr + "\r\n"
ser.write(str.encode(wcom))
time.sleep(1)
# print(ser.readline(), end="") # echo
# print(ser.readline(), end="") # res
pingres = ser.readline() #
if pingres.startswith(b"OK"):
break
#
#
#
# PANA 接続シーケンスを開始します。
#time.sleep(1)
wcom="SKJOIN " + ipv6Addr + "\r\n"
ser.write(str.encode(wcom))
# PANA 接続完了待ち（10行ぐらいなんか返してくる）
bConnected = False
while not bConnected :
line = ser.readline()
# print(line, end="")
if line.startswith(b"EVENT 24") :
# print("PANA 接続失敗")
sys.exit() #### 糸冬了 ####
elif line.startswith(b"EVENT 25") :
# 接続完了！
bConnected = True
# これ以降、シリアル通信のタイムアウトを設定
ser.timeout = 2
# スマートメーターがインスタンスリスト通知を投げてくる
# (ECHONET-Lite_Ver.1.12_02.pdf p.4-16)
#print(ser.readline(), end="") #無視
while True:
# ECHONET Lite フレーム作成
# 参考資料
# ・ECHONET-Lite_Ver.1.12_02.pdf (以下 EL) : 最新版は ver 1.13_02
# ・Appendix_H.pdf (以下 AppH) : 最新版は J (2018/07/30現在)
# for EPC = 0xE7 (瞬時電力計測値)
echonetLiteFrame = b"" # echonetLiteFrame type is byte
echonetLiteFrame += b'\x10\x81' # EHD (参考:EL p.3-2) : 2byte目は \x81(電文形式１） or \x82（電文形式２）
echonetLiteFrame += b'\x00\x01' # TID (参考:EL p.3-3) : TID= Transaction ID
# ここから EDATA
echonetLiteFrame += b'\x05\xFF\x01' # SEOJ (参考:EL p.3-3 AppH p.3-408～) : コントローラクラス規定
echonetLiteFrame += b'\x02\x88\x01' # DEOJ (参考:EL p.3-3 AppH p.3-274～) : 低圧スマート電力量メータクラス規定
echonetLiteFrame += b'\x62' # ESV(62:プロパティ値読み出し要求) (参考:EL p.3-5) : Get
echonetLiteFrame += b'\x01' # OPC(1個)(参考:EL p.3-7)
# echonetLiteFrame += "\x02" # OPC(2個)(参考:EL p.3-7) : ２つのデータを取得する。
echonetLiteFrame += b'\xE7' # EPC(参考:EL p.3-7 AppH p.3-275) : 瞬時電力計測値
echonetLiteFrame += b'\x00' # PDC(参考:EL p.3-9)
# echonetLiteFrame += "\xE8" # EPC(参考:EL p.3-7 AppH p.3-275) : 瞬時電流計測値 R相T相
# echonetLiteFrame += "\x00" # PDC(参考:EL p.3-9)
# コマンド送信
com1 = "SKSENDTO 1 {0} 0E1A 1 {1:04X} ".format(ipv6Addr, len(echonetLiteFrame))
command = com1.encode() + echonetLiteFrame
ser.write(command)
ser.readline()
# print(ser.readline(), end="") # EVENT 21 が来るはず（チェック無し）
ser.readline()
# print(ser.readline(), end="") # OKが来るはず（チェック無し）
ser.readline()
line = ser.readline() # ERXUDPが来るはず
# print(line, end="")
# 取りこぼしたりして変なデータを拾うことがあるので
# チェックを厳しめにしてます。
if line.startswith(b"ERXUDP") :
line = line.decode()
cols = line.strip().split(' ')
res = cols[8] # UDP受信データ部分
#tid = res[4:4+4];
seoj = res[8:8+6]
#deoj = res[14,14+6]
ESV = res[20:20+2]
#OPC = res[22,22+2]
if seoj == "028801" and ESV == "72" :
# スマートメーター(028801)から来た応答(72)なら
EPC = res[24:24+2]
if EPC == "E7" :
# 内容が瞬時電力計測値(E7)だったら
hexPower = line[-8:] # 最後の4バイト（16進数で8文字）が瞬時電力計測値
intPower = int(hexPower, 16)
outputE7=intPower
break
#####################################################################################################
#
# for EPC = 0xE8 (瞬時電流計測値)
#
while True:
# ECHONET Lite フレーム作成
# 参考資料
# ・ECHONET-Lite_Ver.1.12_02.pdf (以下 EL)
# ・Appendix_H.pdf (以下 AppH)
# for EPC = 0xE7 (瞬時電力計測値)
echonetLiteFrame = b""
echonetLiteFrame += b'\x10\x81' # EHD (参考:EL p.3-2) : 2byte目は \x81(電文形式１） or \x82（電文形式２）
echonetLiteFrame += b'\x00\x01' # TID (参考:EL p.3-3) : TID= Transaction ID
# ここから EDATA
echonetLiteFrame += b'\x05\xFF\x01' # SEOJ (参考:EL p.3-3 AppH p.3-408～) : コントローラクラス規定
echonetLiteFrame += b'\x02\x88\x01' # DEOJ (参考:EL p.3-3 AppH p.3-274～) : 低圧スマート電力量メータクラス規定
echonetLiteFrame += b'\x62' # ESV(62:プロパティ値読み出し要求) (参考:EL p.3-5) : Get
echonetLiteFrame += b'\x01' # OPC(1個)(参考:EL p.3-7)
# echonetLiteFrame += "\x02" # OPC(2個)(参考:EL p.3-7) : ２つのデータを取得する。
# echonetLiteFrame += "\xE7" # EPC(参考:EL p.3-7 AppH p.3-275) : 瞬時電力計測値
# echonetLiteFrame += "\x00" # PDC(参考:EL p.3-9)
echonetLiteFrame += b'\xE8' # EPC(参考:EL p.3-7 AppH p.3-275) : 瞬時電流計測値 R相T相
echonetLiteFrame += b'\x00' # PDC(参考:EL p.3-9)
# コマンド送信
com1 = "SKSENDTO 1 {0} 0E1A 1 {1:04X} ".format(ipv6Addr, len(echonetLiteFrame))
command = com1.encode() + echonetLiteFrame
ser.write(command)
# print(ser.readline(), end="") # エコーバック
ser.readline()
# print(ser.readline(), end="") # EVENT 21 が来るはず（チェック無し）
ser.readline()
# print(ser.readline(), end="") # OKが来るはず（チェック無し）
ser.readline()
line = ser.readline() # ERXUDPが来るはず
# print(line, end="")
# 取りこぼしたりして変なデータを拾うことがあるので
# チェックを厳しめにしてます。
if line.startswith(b"ERXUDP") :
line = line.decode()
cols = line.strip().split(' ')
res = cols[8] # UDP受信データ部分
#tid = res[4:4+4];
seoj = res[8:8+6]
#deoj = res[14,14+6]
ESV = res[20:20+2]
#OPC = res[22,22+2]
if seoj == "028801" and ESV == "72" :
# スマートメーター(028801)から来た応答(72)なら
EPC = res[24:24+2]
if EPC == "E8" :
# 内容が瞬時電流力計測値(E8)だったら
# hexPower = line[-8:] # 最後の4バイト（16進数で8文字）が瞬時電力計測値
# intPower = int(hexPower, 16)
rCur = res[-8:-4]
tCur = res[-4:]
intrCur = round( float( int(rCur, 16) * 0.1 ), 1)
inttCur = round( float( int(tCur, 16) * 0.1 ), 1)
break
##################################################################################################
#
# for EPC = 0xE0 (積算電力量計測値(正方向計測値)）
#
while True:
# ECHONET Lite フレーム作成
# 参考資料
# ・ECHONET-Lite_Ver.1.12_02.pdf (以下 EL)
# ・Appendix_H.pdf (以下 AppH)
# for EPC = 0xE7 (瞬時電力計測値)
echonetLiteFrame = b""
echonetLiteFrame += b'\x10\x81' # EHD (参考:EL p.3-2) : 2byte目は \x81(電文形式１） or \x82（電文形式２）
echonetLiteFrame += b'\x00\x01' # TID (参考:EL p.3-3) : TID= Transaction ID
# ここから EDATA
echonetLiteFrame += b'\x05\xFF\x01' # SEOJ (参考:EL p.3-3 AppH p.3-408～) : コントローラクラス規定
echonetLiteFrame += b'\x02\x88\x01' # DEOJ (参考:EL p.3-3 AppH p.3-274～) : 低圧スマート電力量メータクラス規定
echonetLiteFrame += b'\x62' # ESV(62:プロパティ値読み出し要求) (参考:EL p.3-5) : Get
echonetLiteFrame += b'\x01' # OPC(1個)(参考:EL p.3-7)
# echonetLiteFrame += "\x02" # OPC(2個)(参考:EL p.3-7) : ２つのデータを取得する。
# echonetLiteFrame += "\xE7" # EPC(参考:EL p.3-7 AppH p.3-275) : 瞬時電力計測値
# echonetLiteFrame += "\x00" # PDC(参考:EL p.3-9)
echonetLiteFrame += b'\xE0' # EPC(参考:EL p.3-7 AppH p.3-275) : 積算電力量計測値
echonetLiteFrame += b'\x00' # PDC(参考:EL p.3-9)
# コマンド送信
com1 = "SKSENDTO 1 {0} 0E1A 1 {1:04X} ".format(ipv6Addr, len(echonetLiteFrame))
command = com1.encode() + echonetLiteFrame
ser.write(command)
# print(ser.readline(), end="") # エコーバック
ser.readline()
# print(ser.readline(), end="") # EVENT 21 が来るはず（チェック無し）
ser.readline()
# print(ser.readline(), end="") # OKが来るはず（チェック無し）
ser.readline()
line = ser.readline() # ERXUDPが来るはず
# print(line, end="")
# 取りこぼしたりして変なデータを拾うことがあるので
# チェックを厳しめにしてます。
if line.startswith(b"ERXUDP") :
line = line.decode()
cols = line.strip().split(' ')
res = cols[8] # UDP受信データ部分
#tid = res[4:4+4];
seoj = res[8:8+6]
#deoj = res[14,14+6]
ESV = res[20:20+2]
#OPC = res[22,22+2]
if seoj == "028801" and ESV == "72" :
# スマートメーター(028801)から来た応答(72)なら
EPC = res[24:24+2]
if EPC == "E0" :
# 内容が瞬時電流力計測値(E8)だったら
hexPower = line[-8:] # 最後の4バイト（16進数で8文字）が瞬時電力計測値
# intPower = int(hexPower, 16)
# floatPower = round ( float( int( hexPower, 16) * 0.1 ),1)
# cacti の Data Source で COUNTER を使いたい、となるとデータは intでなくてはいけなくて、floatはだめ。
# なので、係数を使わずにそのままにする。
intPower = int( hexPower, 16)
break
##################################################################################################
#
# for EPC = 0xE3 (積算電力量計測値(逆方向計測値)）
#
while True:
# for EPC = 0xE3
echonetLiteFrame = b""
echonetLiteFrame += b'\x10\x81' # EHD (参考:EL p.3-2) : 2byte目は \x81(電文形式１） or \x82（電文形式２）
echonetLiteFrame += b'\x00\x01' # TID (参考:EL p.3-3) : TID= Transaction ID
# ここから EDATA
echonetLiteFrame += b'\x05\xFF\x01' # SEOJ (参考:EL p.3-3 AppH p.3-408～) : コントローラクラス規定
echonetLiteFrame += b'\x02\x88\x01' # DEOJ (参考:EL p.3-3 AppH p.3-274～) : 低圧スマート電力量メータクラス規定
echonetLiteFrame += b'\x62' # ESV(62:プロパティ値読み出し要求) (参考:EL p.3-5) : Get
echonetLiteFrame += b'\x01' # OPC(1個)(参考:EL p.3-7)
echonetLiteFrame += b'\xE3' # EPC(参考:EL p.3-7 AppH p.3-275) : 積算電力量計測値
echonetLiteFrame += b'\x00' # PDC(参考:EL p.3-9)
# コマンド送信
com1 = "SKSENDTO 1 {0} 0E1A 1 {1:04X} ".format(ipv6Addr, len(echonetLiteFrame))
command = com1.encode() + echonetLiteFrame
ser.write(command)
ser.readline()
ser.readline()
ser.readline()
line = ser.readline() # ERXUDPが来るはず
# 取りこぼしたりして変なデータを拾うことがあるので
# チェックを厳しめにしてます。
if line.startswith(b"ERXUDP") :
line = line.decode()
cols = line.strip().split(' ')
res = cols[8] # UDP受信データ部分
#tid = res[4:4+4];
seoj = res[8:8+6]
#deoj = res[14,14+6]
ESV = res[20:20+2]
#OPC = res[22,22+2]
if seoj == "028801" and ESV == "72" :
# スマートメーター(028801)から来た応答(72)なら
EPC = res[24:24+2]
if EPC == "E3" :
# 内容が瞬時電流力計測値(E8)だったら
hexPower = line[-8:] # 最後の4バイト（16進数で8文字）が瞬時電力計測値
# intPower = int(hexPower, 16)
intPowerM = int(hexPower, 16)
break
#######################################################################################################
#
print ("E7:{0} E8r:{1} E8t:{2} E0:{3} E3:{4}".format(outputE7,intrCur,inttCur,intPower,intPowerM),end="")
#
#
ser.close()
出力はcactiに食わせる形式にしていて、E7:瞬時電力計測値,E8r:瞬時電流計測値(R相),E8t:瞬時電流計測値(T相),E0:積算電力量計測値(正方向計測値),E3:積算電力量計測値(逆方向計測値)。
raspberrypi:~/smartmeter3# python3 /usr/share/cacti/scripts/smartmeter.py3 E7:686 E8r:7.0 E8t:1.0 E0:86704 E3:10瞬間電力値、瞬間電流値は５分に１回のピンポイントの計測なので、瞬発的な消費は拾えてないこともある。
瞬間電流値の５分グラフ（T相、R相）
電子レンジ、電気ポットなどでの瞬間ピークが出ている。
瞬間電力値
積算電力量を cactiの counterでグラフ化したもの。
５分データだと、最小単位（0.1 KWH)を超えないときがある。もっと細かな数値が取れると良いけど HEMS機器の出力積算電力量単位(EPC 0xE1)が 0.1 kWhなので難しい。
今後は、この資料のP.32にもあるように、「通信負担を軽減する目的から、１つのパケットで複数のコマンド処理が可能なマルチゲットコマンド（エコーネットコンソーシアムが定義）などの実装が推奨される。」を行ってみることか？ 最近はいろいろな Bルート製品が出ているのも気になる。