ESP 8266 Daten senden an Pi DB

tutter · Oct 21st 2021

Hallo an alle,

mein ESP 8266 soll die Daten per Wlan an den Pi senden. Dieser verfügt über ein PostgreSql Datenbank. Die übermittelten Werte sollen in die Datenbank gespeichert werden,

hierzu sammelt ein MCP3008 kräftig Daten.

Leider bekomme ich die TCP Verbindung nicht hin! Ich erhalte stets "connection failed"

IP des Host ist richtig. Laut einer Doku soll der Port 5555 genutzt werden. Ist der beim pi zu?

C

[code]
#include <MCP3008.h>
//#include <SPI.h>
/*
#define CS_PIN D8
#define CLOCK_PIN D5
#define MOSI_PIN D7
#define MISO_PIN D6
*/

#include <ESP8266WiFi.h>
//#include <WiFi.h>







IPAddress PGIP(192,168,178,29);        // your PostgreSQL server IP

const char* ssid = "FRITZ!Box 7490";      //  your network SSID (name)
const char* pass = "strenggeheim";      // your network password
const char* host = "192.168.178.29";
const char user[] = "postgres";       // your database user
const char password[] = "postgres";   // your database password
const char dbname[] = "test";         // your database name







//define pin connections

//MCP3008 adc(D5, D7, D6, D8);
//MCP3008 adc(GPF14, GPF13, GPF12, GPF15);


MCP3008 adc(14, 13, 12, 15);
//MCP3008 adc(CLOCK_PIN, MOSI_PIN, MISO_PIN, CS_PIN);


void setup()
    {
  //open serial port
  Serial.begin(115200); 
      
    WiFi.begin(ssid, pass);
    Serial.print("Connecting");
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");  
      }
      Serial.println("");
      Serial.println("WiFi connected");
      Serial.println("IP address: ");
      Serial.println(WiFi.localIP());
    


 
}

void loop()
{
  Serial.println("---------------------------------------");
  Serial.println("Value1:" + String(adc.readADC(0)));  
  Serial.println("Value2:" + String(adc.readADC(1)));  
  Serial.println("Value3:" + String(adc.readADC(2)));  
  Serial.println("Value4:" + String(adc.readADC(3)));  
  Serial.println("Value5:" + String(adc.readADC(4)));  
  Serial.println("Value6:" + String(adc.readADC(5)));  
  Serial.println("Value7:" + String(adc.readADC(6)));
  Serial.println("Value8:" + String(adc.readADC(7)));  
  delay(1000);  

// WiFiClient class für den Aufbau einer TCP Verbindung
Serial.print("Connection to ");
Serial.println(host);

WiFiClient client;
const int httpPort = 5555;
if(!client.connect(host, httpPort)){
  Serial.println("Connection failed");
  return;
  }



  //Senden der Daten an Server (Pi)
client.print(String("GET htp://192.68.178.29/postgre-php?")+ 
                ("&temperature=") + String(adc.readADC(0)) +
                ("&humidity=") + String(adc.readADC(0)) +
                " HTTP/1.1\r\n" +
          "Host: " + host + "\r\n" +
          "Connection: close\r\n\r\n");
unsigned long timeout = millis();
while (client.available() == 0) {
  if (millis() - timeout >1000 ){
    Serial.println(">>> Client Timeout !");
    client.stop();
    return;
    }
  
  }          

while(client.available()){
  String line = client.readStringUntil('\r');
  Serial.print(line);
  
  }
  Serial.println();
  Serial.println("closing connection");


  
  
}
[/code]

Display More

Bernd666 · Oct 21st 2021

Moin tutter,

schau dir in der Arduino Ide die Beispiele für den ESP8266 an. Ins besondere PostHTTPClient.ino.

Das ist einfacher als hier alles zu schreiben.

73 de Bernd

VeryPrivat · Oct 22nd 2021

Quote from tutter (Quellcode Zeile 93)

client.print(String("GET htp://192.68.178.29/postgre-php?")+

Bist Du sicher, dass hier nicht http:// stehen sollte? Mit einem t habe ich das noch nie gesehen...

Wobei, wenn Du tatsächlich nur "connection failed" erhältst, kommst Du gar nicht so weit.

Leider kenne ich diese "PostgreSql" Datenbank nicht - aber die lauscht tatsächlich auf Port 5555 nach den TCP Daten? Keine hilfreiche (Fehler)meldung auf Seite des PI?

raspiprojekt · Oct 22nd 2021

Der Standardport für postgre ist 5432, es sei denn, du hast an der config der Datenbank rumgefummelt.

msol · Oct 22nd 2021

Quote from tutter

GET htp://192.68.178.29/postgre-php?

Außer dem t fehlt da wohl auch noch eine 1 für eine vollständige 168

tutter · Oct 22nd 2021

erstmal vielen Dank euch allen. Leider ist es heute schon zu spät für mich, deswegen schau ich mir das erst morgen an.

tutter · Oct 22nd 2021

Ok ich habe das Skript heute doch noch mal mir angeschaut. Ich konnte dank eurer Hilfe noch diverse Fehler ausbauen.

Nun erhalte ich aber ">>> Client Timeout !".

Der SQL Befehl funktioniert den konnte ich testen. Was kann ich nun noch testen? An was kann es liegen?

VeryPrivat · Oct 23rd 2021

Schön, dass Du einen Schritt weiter bist. Aufgrund Deiner Erfahrung hier im Forum (143 Beiträge) sollte es eigentlich selbstverständlich sein, dass wir nur raten können, solange wir nicht wissen, was Du genau machst. Es wäre also sehr hilfreich, wenn Du die Änderungen oder den aktuellen Code von dem Du "sprichst" postest...
Da sich vermutlich die Meisten nicht so intensiv wie Du mit dem Thema beschäftigt haben, wäre es auch hilfreich, wenn Du uns die Quelle auf Basis deren Du Deinen Code gemacht hast nennen könntest.

Wie testest Du den SQL Befehl? Welchen "Testbefehl" hast Du verwendet?

tutter · Oct 24th 2021

VeryPrivat da hast du natürlich recht!

Wie ich das testen soll habe ich mich am Anfang auch gefragt. Deswegen habe ich erst einmal das getestet was ich testen kann. Deswegen habe ich einen php Aufruf mit $_GET gemacht zb: http://192.168.178.29/postgre.php?temperatur=34&humidity=45 Danach habe ich geschaut ob dies in der Datenbank ankam.

Ja das tat es. Somit war es möglich Daten in Datenbank zu schreiben.

Nun musste es ja an dem Skript vom ESP liegen.

Hier überlegte ich mir die ganze Zeit warum der ESP an den Port 5555 oder 5432 senden soll. 5555 ist ein Port den der Pi nicht kennt! und 5432 (Postgre) würde nur etwas bringen wenn ich direkt in die DB "ballern" könnte. Da ich das aber nicht kann und den Umweg über HTTP machen muss, muss es doch ein HTTP-Port sein?!.

Da ich in solchen Themen nicht so tief in Thema bin, half nur "Weiterbildung" und sie da es muss Port 80 sein.

Noch mal vielen Dank an die vielen guten Ideen und Hinweise!

Ein Frage hätte ich noch. Ich würde gern 60 Sekunden lang die Werte sammeln (vielleicht in einem Array?) und im Anschluss nur die Min, Max und Durchschnittswert hochladen. Also jede Minute, pro gemessenen Wert, jeweils Min, Max und average.

Gibt es eine Möglichkeit dafür? Ist das zu viel für den kleinen ESP?

Somit ergibt sich:

PHP:

PHP

<html>
<body>



<?php
ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);
error_reporting(E_ALL);


$cn = pg_connect("host=192.168.178.29 port=5432 dbname=test  user=postgres password=postgres");

if($cn)
{
echo "connected";
}

$b1 = $_GET['temperature'];
$b2 = $_GET['humidity'];

$query = "Insert INTO test (temperature, humidity, created_at) VALUES ('$b1','$b2',now())";
$result = pg_query($cn,$query);
echo "Insertion Success!<br>";


?>

</body>
</hmtl>

Display More

ESP:

C

[code]
#include <MCP3008.h>
//#include <SPI.h>
/*
#define CS_PIN D8
#define CLOCK_PIN D5
#define MOSI_PIN D7
#define MISO_PIN D6
*/

#include <ESP8266WiFi.h>
//#include <WiFi.h>







IPAddress PGIP(192,168,178,29);        // your PostgreSQL server IP

const char* ssid = "FRITZ!Box 7490";      //  your network SSID (name)
const char* pass = "streng geheim";      // your network password
const char* host = "192.168.178.29";
const char user[] = "postgres";       // your database user
const char password[] = "postgres";   // your database password
const char dbname[] = "test";         // your database name







//define pin connections

//MCP3008 adc(D5, D7, D6, D8);
//MCP3008 adc(GPF14, GPF13, GPF12, GPF15);


MCP3008 adc(14, 13, 12, 15);
//MCP3008 adc(CLOCK_PIN, MOSI_PIN, MISO_PIN, CS_PIN);


void setup()
    {
  //open serial port
  Serial.begin(115200); 
      
    WiFi.begin(ssid, pass);
    Serial.print("Connecting");
    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print(".");  
      }
      Serial.println("");
      Serial.println("WiFi connected");
      Serial.println("IP address: ");
      Serial.println(WiFi.localIP());
    


 
}

void loop()
{
  Serial.println("---------------------------------------");
  Serial.println("Value1:" + String(adc.readADC(0)));  
  Serial.println("Value2:" + String(adc.readADC(1)));  
  Serial.println("Value3:" + String(adc.readADC(2)));  
  Serial.println("Value4:" + String(adc.readADC(3)));  
  Serial.println("Value5:" + String(adc.readADC(4)));  
  Serial.println("Value6:" + String(adc.readADC(5)));  
  Serial.println("Value7:" + String(adc.readADC(6)));
  Serial.println("Value8:" + String(adc.readADC(7)));  
  delay(1000);  

// WiFiClient class für den Aufbau einer TCP Verbindung
Serial.print("Connection to ");
Serial.println(host);

WiFiClient client;
const int httpPort = 80; //vorher 5555
if(!client.connect(host, httpPort)){
  Serial.println("Connection failed");
  return;
  }



  //Senden der Daten an Server (Pi)
client.print(String("GET http://192.168.178.29/postgre.php?")+ 
                ("&temperature=") + String(adc.readADC(0)) +
                ("&humidity=") + String(adc.readADC(0)) +
                " HTTP/1.1\r\n" +
          "Host: " + host + "\r\n" +
          "Connection: close\r\n\r\n");
unsigned long timeout = millis();
while (client.available() == 0) {
  if (millis() - timeout >1000 ){
    Serial.println(">>> Client Timeout !");
    client.stop();
    return;
    }
  
  }          

while(client.available()){
  String line = client.readStringUntil('\r');
  Serial.print(line);
  
  }
  Serial.println();
  Serial.println("closing connection");


  
  
}
[/code]

Display More

__blackjack__ · Oct 24th 2021

tutter Einfach so Zeichenketten, die man von aussen übers Netz bekommt, in eine SQL-Anfrage einzusetzen ist eine ganz schlechte Idee.

tutter · Oct 24th 2021

__blackjack__ : Ja das ist ein erster Schritt, in die richtige Richtung. Sicher kann ich das noch auf $_Post umstellen. Im nächsten Schritt würde ich gern etwas mit API´s machen. Aber es läuft erstmal und das war das erste Ziel. Außerdem kann ich beruhigt sein, da es in einem separaten Netz läuft das nur für so ein Spielkram gemacht ist.

Aber danke für den Hinweis!

VeryPrivat · Oct 24th 2021

Quote from tutter

Ich würde gern 60 Sekunden lang die Werte sammeln (vielleicht in einem Array?) und im Anschluss nur die Min, Max und Durchschnittswert hochladen. Also jede Minute, pro gemessenen Wert, jeweils Min, Max und average

Das ist eigentlich relativ einfach. Dazu brauchst Du kein Array.:

Für den Mittelwert addiere einfach alle Werte und dividiere nachdem du die gewünschte Anzahl erreicht hast durch die Anzahl. Achte beim Addieren darauf, dass die Summiervariable nicht überläuft.
Max: Initialisiere eine Variable MAX mit 0. Ist der aktuelle Wert höher als der in der MAX Variable, dann schreibe diesen Wert in die MAX Variable. Nach der gewünschten Anzahl von Werten steht der Wert drinnen, der das Maximum war.
Min: Analog zu MAX halt nur mit einem größeren Wert als das mögliche Maximum initialisieren und den jeweils kleineren Wert in die Variable übernehmen.

Quote from tutter

Gibt es eine Möglichkeit dafür? Ist das zu viel für den kleinen ESP?

Wenn Du Dich ausgiebig damit beschäftigst, wirst Du Dich noch wundern, was man mit einem ESP alles machen kann.

raspiprojekt · Oct 25th 2021

Quote from tutter

Hier überlegte ich mir die ganze Zeit warum der ESP an den Port 5555 oder 5432 senden soll. 5555 ist ein Port den der Pi nicht kennt! und 5432 (Postgre) würde nur etwas bringen wenn ich direkt in die DB "ballern" könnte. Da ich das aber nicht kann und den Umweg über HTTP machen muss, muss es doch ein HTTP-Port sein?!.

Wenn du das so machst muß es natürlich der http-Port (80) sein. Ich nutze nur noch den ESP als Sensor. Inzwischen spare ich mir das Scripten und nutze ESPeasy. Solltest du dir mal anschauen.

tutter · Oct 25th 2021

VeryPrivat das ist ein sehr guter Ansatz! das teste ich morgen gleich mal aus! Danke für die Tipps

ESP 8266 Daten senden an Pi DB

Post by Hofei (Oct 21st 2021).

Post by WaldiBVB (Oct 22nd 2021).

Post by WaldiBVB (Oct 22nd 2021).