表題の通り、1秒ごとの数値が1列ずつに格納されているCSVデータを読み取り、
1秒おきにIoTプラットフォームへ全くそのまま送信したいと考えております。
現在のコードは以下です。
### CSV_to_.py
import pandas as pd
import csv
import datetime
import subprocess
import sys
from pathlib import Path
# Set Parameters
ADDR = "********"
PORT = "********"
TOPIC = "********"
QOS = "********"
ID = "********" #本来のコードには実値が入っています
#CSVファイルをリスト形式で出力
f = '20210902.csv'
df = pd.read_csv(f, encoding="shift-jis").values.tolist()
for row in df:
DATA = ',' . join(map(str,row))
print(DATA)
cmd = "mosquitto_pub --host " + str(ADDR) +" --port "+ str(PORT) + " --qos 0 --topic " + str(TOPIC) + " -m '," + str(DATA) + ", ' -i " + str(ID)
proc = subprocess.run(cmd, shell = True)
time.sleep(1)
上記コードを実行すると、
2021/9/2 5:02,0,22.8,1.5,0,0,2.7,98,0,1
Error: The connection was lost.
と表記されラズパイ内でのデータ表示は可能ですが
IoTプラットフォームへデータが送信できていない状態です。
どなたか修正方法についてご教示いただけますと幸いです。
IoTプラットフォーム側で受け取る値が、strで全項目文字列として
取り扱われているのではないかと設定を見直したところ正常にデータ送信が可能となりました。
皆さまのご意見大変参考になりました。ありがとうございます。
DATAに値が入っておらず
というのはどのように確認したのでしょうか? 例えばcmd = ...
とproc = ...
の間にprint(cmd)
としたり、cmd = ...
の先頭のmosquitto_pub
を何か引数を画面表示するとか何かのファイルに追記するだけのプログラムに挿し替えてみて、どのような文字列になるかを確かめて質問に追記してみてはどうでしょう?