Arduinoとサーバプログラム

Question

正しい値をサーバーに送りたい

Arduinoからシリアル通信をした後にサーバーに送るプログラムを書いています。
そこで、正しい値が取れない、または正しい値は取れているけど、出力がうまくいかないという点で困っています。

###値の送信はうまくいっているが、正しい値を送れていないコード

import asyncio
import serial
import time
import datetime
import json
import urllib.request
import concurrent.futures
import re
from serial.tools import list_ports
#import splite3

ser=serial.Serial('/dev/cu.usbmodem14401',115200,timeout=None)


def upload_data(json_data):
    #url="http://192.168.0.11:3000" #home
    method = "POST"
    headers = {"Content-Type" : "application/json"}

    request = urllib.request.Request(url, data=json_data, method=method, headers=headers)
    try:
        with urllib.request.urlopen(request) as response:
            response_body = response.read().decode("utf-8")
            print(response_body)
    except urllib.error.URLError as e:
            print(e.reason)

def func1():
    while True:
        line=ser.readline()
        #line.strip('b','\r\n')
        print(line)
        
seq=[]

async def run():
    for line in ser.readline().rstrip():
        ut=time.time()
        dt = datetime.datetime.fromtimestamp(ut)
        joined_seq=seq.append(chr(line)) 
        joined_seq = ''.join(str(v)for v in seq)
        #dev=[info.device for info in list_ports.comports()]
        if chr(line)=='\n':
            obj =  {"time" : str(dt), "ID" : 12345,"Data":joined_seq} # Send Data
            json_data = json.dumps(obj).encode("utf-8")
            upload_data(json_data)
        #time.sleep(1)

if __name__=='__main__':
    while 1:
        #executor=concurrent.futures.ThreadPoolExecutor(max_workers=2)
        #executor.submit(func1)
        loop = asyncio.get_event_loop()
        loop.run_until_complete(run())

実行結果

Successfully Received >   {"time": "2021-12-20 19:49:55.907691", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:49:56.915803", "ID": 12345, "Data": "\r"}
Successfully Received >   {"time": "2021-12-20 19:49:57.920313", "ID": 12345, "Data": "\n"}
Successfully Received >   {"time": "2021-12-20 19:49:58.927146", "ID": 12345, "Data": "4"}
Successfully Received >   {"time": "2021-12-20 19:49:59.933469", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:50:00.940842", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:50:01.948506", "ID": 12345, "Data": "\r"}
Successfully Received >   {"time": "2021-12-20 19:50:02.966437", "ID": 12345, "Data": "\n"}
Successfully Received >   {"time": "2021-12-20 19:50:03.971292", "ID": 12345, "Data": "4"}
Successfully Received >   {"time": "2021-12-20 19:50:04.978614", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:50:05.983044", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:50:06.987425", "ID": 12345, "Data": "\r"}
Successfully Received >   {"time": "2021-12-20 19:50:07.989914", "ID": 12345, "Data": "\n"}

正しい値は出ているが、値の送信がうまくっていないコード

import asyncio
import serial
import time
import datetime
import json
import urllib.request
import concurrent.futures
import re
from serial.tools import list_ports
#import splite3

ser=serial.Serial('/dev/cu.usbmodem14401',115200,timeout=None)


def upload_data(json_data):
    #url="http://192.168.0.11:3000" #home
    method = "POST"
    headers = {"Content-Type" : "application/json"}

    request = urllib.request.Request(url, data=json_data, method=method, headers=headers)
    try:
        with urllib.request.urlopen(request) as response:
            response_body = response.read().decode("utf-8")
            print(response_body)
    except urllib.error.URLError as e:
            print(e.reason)

def func1():
    while True:
        line=ser.readline()
        #line.strip('b','\r\n')
        print(line)
        
seq=[]

async def run():
    for line in ser.readline().rstrip():
        ut=time.time()
        dt = datetime.datetime.fromtimestamp(ut)
        joined_seq=seq.append(chr(line)) 
        joined_seq = ''.join(str(v)for v in seq)
        #dev=[info.device for info in list_ports.comports()]
        if chr(line)=='\n':
            obj =  {"time" : str(dt), "ID" : 12345,"Data":joined_seq} # Send Data
            json_data = json.dumps(obj).encode("utf-8")
            upload_data(json_data)
        #time.sleep(1)

if __name__=='__main__':
    while 1:
        #executor=concurrent.futures.ThreadPoolExecutor(max_workers=2)
        #executor.submit(func1)
        loop = asyncio.get_event_loop()
        loop.run_until_complete(run())

実行結果

Successfully Received >   {"time": "2021-12-20 19:53:00.254192", "ID": 12345, "Data": "0\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:01.258051", "ID": 12345, "Data": "0\r\n0\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:02.257321", "ID": 12345, "Data": "0\r\n0\r\n0\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:03.256606", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:04.260266", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:05.263327", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n400\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:06.262898", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n400\r\n402\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:07.266468", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n400\r\n402\r\n409\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:08.270060", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n400\r\n402\r\n409\r\n402\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:09.269093", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n400\r\n402\r\n409\r\n402\r\n402\r\n"}
Successfully Received >   {"time": "2021-12-20 19:53:10.272321", "ID": 12345, "Data": "0\r\n0\r\n0\r\n0\r\n400\r\n400\r\n402\r\n409\r\n402\r\n402\r\n411\r\n"}

これは配列だからかなと感じています

下のようになればいいなという風に考えています。
（受信側プログラムはHttp.jsというプログラムで受信しています。）

理想のプログラム完成の実行例

Successfully Received >   {"time": "2021-12-20 19:53:00.254192", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:53:01.258051", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:53:02.257321", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:53:03.256606", "ID": 12345, "Data": "0"}
Successfully Received >   {"time": "2021-12-20 19:53:04.260266", "ID": 12345, "Data": "400"}
Successfully Received >   {"time": "2021-12-20 19:53:05.263327", "ID": 12345, "Data": "400"}
Successfully Received >   {"time": "2021-12-20 19:53:06.262898", "ID": 12345, "Data": "402"}
Successfully Received >   {"time": "2021-12-20 19:53:07.266468", "ID": 12345, "Data": "409"}
Successfully Received >   {"time": "2021-12-20 19:53:08.270060", "ID": 12345, "Data": "402"}
Successfully Received >   {"time": "2021-12-20 19:53:09.269093", "ID": 12345, "Data": "402"}
Successfully Received >   {"time": "2021-12-20 19:53:10.272321", "ID": 12345, "Data": "411"}
Successfully Received >   {"time": "2021-12-20 19:53:11.271874", "ID": 12345, "Data": "409"}
Successfully Received >   {"time": "2021-12-20 19:53:12.275307", "ID": 12345, "Data": "409"}

Arduinoのプログラムについて

#include <Wire.h>

#include "SparkFunCCS811.h" //Click here to get the library: http://librarymanager/All#SparkFun_CCS811


int count = 0;


int list_num =3;
int co2_list[3] = {0,0,0};


#define CCS811_ADDR 0x5B //Default I2C Address
//#define CCS811_ADDR 0x5A //Alternate I2C Address

CCS811 mySensor(CCS811_ADDR);

void setup()
{
  Serial.begin(115200);
  //Serial.println("CCS811 Basic Example");

  Wire.begin(); //Inialize I2C Hardware


  if (mySensor.begin() == false)
  {
    Serial.print("CCS811 error. Please check wiring. Freezing...");
    while (1);
  }
}

void loop()
{
  //Check to see if data is ready with .dataAvailable()
  if (mySensor.dataAvailable())
  {
    //If so, have the sensor read and calculate the results.
    //Get them later
    mySensor.readAlgorithmResults();
   
  }
  for(int i =list_num;i > 1;i--){
    co2_list[i-1] = co2_list[i-2];
  }
  co2_list[0] = mySensor.getCO2();
  int co2_ave;
  co2_ave = (co2_list[0] + co2_list[1] +co2_list[2])/3.0; 
  Serial.println(co2_list[0]);
  //Serial.print(",");
  //Serial.println(co2_ave);
  

  delay(1000); //Don't spam the I2C bus
}

二酸化炭素センサーを使用しています。配線は間違えておらず、Arduino付帯のシリアルモニタでは正しく出力されることを確認しています。

ご回答いただけると嬉しいです。よろしくお願いします。

受信側のプログラム(Node.js)

var http = require('http');


var server = http.createServer();


server.on('request', function(req,res){
	
	if(req.method == 'POST'){
		
		res.writeHead(200, {'Content-Type' : req.headers['content-type']});
    	
    	
    	req.on('data', function(data){
    		
    		var text = data.toString('utf8');
     		
     		res.write('Successfully Received >   ' + text);
			
    		
    		console.log(req.method + ' "' + req.headers['user-agent'] + '"');
     		console.log('Client Request > ' + data);
    	});

		
		req.on('end', function(){
			// スマートフォンへのデータの返信を終了
			res.end();
		});
	}
	
	else {
		res.writeHead(200, {'Content-Type': 'text/plain'});
		res.write('Hello World\n');
		res.end();
	}
});


server.listen(3000);

Comments

[y_waiwai]

そのそれぞれについて、どういう値が送られてるんでしょうか

[hirokitrain13]

CO2センサーで取得した値(二酸化炭素濃度）を送信しています。

[thkana]

1. プログラムの違う場所を何らかの方法で比較して示していただけませんか?
私にはどうにも「同じプログラム」に見えてしまうのですが。

2.「値の送信はうまくいっているが、正しい値を送れていない」
前半と後半が矛盾しているように思います。「送信がうまくいく」とは「正しい値が送られる」ことをいうのではないのですか? つまり、なにが正しくて、なにが間違っているのですか?