mqtt von extern steuren

mehraltfraumann Gast 27.12.2022 12:19 #7297847

Lesenswert?

•

Hallo guten Tag,

ich habe hier ein Gerät was auf MQTT reagiert.
Mein mosquitto Broker läuft auf einem Raspberry.

Ich würde gerne über eine  Website das Gerät von überall aus Steuern.
Da gibt es bestimmt leichte Wege. Aber ich habe noch keinen gefunden....
...
Ich habe schon versucht mit ngrok eine Apache2 Html Seite zu starten und 
öffentlich zu machen.
Diese HTML Seite soll an einen python-Server, der auf dem Port 8000 
hört,  Daten senden wenn,  man auf einen Button klickt.

Der Python Server soll dann den Befehl os.system('mosquitto_pub  ( 
...)') durchführen.
Das klappt aber irgendwie nur wenn ich die öffentliche Seite auf meinem 
PC ausführe. Man sieht dann, dass sich jemand einloggt beim Python 
Server.

Wenn  ich die Seite auf meinem Handy ausführe sehe ich keine Aktivität 
mehr beim Python Server. Somit funktionieren die mosquitto_pub  ( ...) 
Befehle auch nicht.

Also wie mache ich es, dass der Python server auch erreicht wird?

    const socket = new WebSocket('ws://127.0.0.1:8000');  /// ??????????


Hier ist der Server:

import asyncio
import websockets
import os
# create handler for each connection
async def handler(websocket, path):
    data = await websocket.recv()
    reply = f"Data12312312 recieved as:{data}!"
    os.system('mosquitto_pub -t /test -h xxx.xxx.xxx.xxx -m "1"') 
    await websocket.send(reply)
 ## handles messages?
async def handler(websocket):
    async for message in websocket:
        print(message)
        reply = f" recieved data from browser:!"
        if '1' in message:
            print ('there was a one')
            os.system('mosquitto_pub -t /test -h xxx.xxx.xxx.xxx -m "1"')
        if '2' in message:
             print ('there was a 2')
             os.system('mosquitto_pub -t /test -h xxx.xxx.xxx.xxx -m "2"')
        if '3' in message:
            print ('there was a 3')
            os.system('mosquitto_pub -t /test -h xxx.xxx.xxx.xxx -m "3"')
        if '4' in message:
            print ('there was a 4')
            os.system('mosquitto_pub -t /test -h xxx.xxx.xxx.xxx -m "4"')
start_server = websockets.serve(handler, "localhost", 8000)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()


Danke ...

Antwort Zitieren Bearbeiten Thread verschieben Thread sperren Anmeldepflicht aktivieren Anpinnen Thread löschen Thread mit anderem zusammenführen Beitrag melden

Thomas W. Gast 27.12.2022 12:41 #7297872

Lesenswert?

•

▲
▼

mehraltfraumann schrieb:

So richtig zu Verstehen ist Dein Beitrag nicht, aber
>

>     const socket = new WebSocket('ws://127.0.0.1:8000');  /// ??????????

ist genau das, was Du willst: Nur Zugriff von Localhost (vulgo die 
eigene Maschine).

Willst Du willst dass andere darauf spielen sollen, musst Du die 
IP-Adresse des Netzwerk-Interface (WLAN, Ethernet) angeben.

Gruesse

Th.

Antwort Zitieren Bearbeiten Löschen Beitrag melden

J. S. (jojos) 27.12.2022 12:49 #7297877

Lesenswert?

•

▲
▼

Die Default Einstellungen für die Sicherheit verbieten erstmal den 
Zugriff außerhalb von 127.1, muss man in der mosquito configuration 
angeben wenn es erlaubt sein soll.

Antwort Zitieren Bearbeiten Löschen Beitrag melden

Εrnst B. (ernst) 27.12.2022 12:53 #7297881

Lesenswert?

•

▲
▼

Das hier:
mehraltfraumann schrieb:
> os.system('mosquitto_pub -t /test -h xxx.xxx.xxx.xxx -m "1"')

ist auch ganz schlechter und potentiell gefährlicher Stil.
Sobald du statt "1" da irgendwelche Daten einsetzt die du durch den 
Websocket bekommen hast, bist du nur noch eine kleine Unachtsamkeit von 
der Remote Code Execution entfernt.

Python kann auch selber mqtt "sprechen", z.B.

pip3 install paho-mqtt,

from paho.mqtt import client as mqtt_client

usw.

Damit fällt dann auch die umgekehrte Richtung leichter, wenn die 
Webseite z.B. auch noch Messwerte aus dem mqtt anzeigen soll.


Ach ja, wenn dein Python-Programm nicht viel mehr machen soll, als MQTT 
-> Websocket zu übersetzen: Der mosquitto-Server kann das auch selber.
Einfach in der mosquitto-conf eintragen

listener 8000
protocol websockets
http_dir /irgendwo/htdocs

aus dem http_dir kann der auch gleich deine Webseite + JS ausliefern, 
d.H. den apache bist du im selben Schritt auch gleich los.

Antwort Zitieren Bearbeiten Löschen Beitrag melden

mehraltfraumann Gast 27.12.2022 13:05 #7297891

Lesenswert?

•

▲
▼

Thomas W. schrieb:
> zu Verstehen ist Dein Beitrag n

ich weiß.

Meine Website ist öffentlich ( immer nur kurzzeitig, um das zu testen)
Durch einen Button-Klick soll diese Website eine Nachricht an meinen 
Broker senden können.

Aber wie ?

Er ist von außen ja gar nicht zugänglich.
Er ist  lokal zugänglich über mqtt 1883 und 8080 als websocket  per 
mqtt.
Der python Server ist auch nicht erreichbar denke ich?
Er hört auf Port 8000.
Aber meine öffentlich  Website mit dem Button hat ja keine Ahnung wo der 
Python-Server ist.
Bzw.

const socket = new WebSocket('ws://127.0.0.1:8000');  /// ??????????

reicht nicht aus.

Kann man den den auch öffentlich machen?
Oder kann die Website den trotzdem erreichen?

Εrnst B. schrieb:
> aus dem http_dir kann der auch gleich deine Webseite + JS ausliefern,
> d.H. den apache bist du im selben Schritt auch gleich los.

Die ersten beiden Zeilen habe ich schon ( bloß mit 8080)
listener 8000
protocol websockets

Das hier habe ich noch  nicht:

http_dir /irgendwo/htdocs

Werde ich mal testen.

Danke :D

Angehängte Dateien:

Bildschirmfoto_vom_2022-12-27_12-55-08.png (45 KB)

Antwort Zitieren Bearbeiten Löschen Beitrag melden

mehraltfraumann Gast 27.12.2022 16:07 #7298073

Lesenswert?

•

▲
▼

Mosquitto hat jetzt die Html seite auf  dem 80 am laufen.

Ich kann auch darauf von extern zugreifen.

Soll ich jetzt ein Javascript dazu einbinden auf der html-Seite, dass 
dann den Broker ansprechen kann bei Button-Click?

Antwort Zitieren Bearbeiten Löschen Beitrag melden

Εrnst B. (ernst) 27.12.2022 17:03 #7298138

Lesenswert?

•

▲
▼

mehraltfraumann schrieb:
> Soll ich jetzt ein Javascript dazu einbinden auf der html-Seite

musst du. Ohne Javascript spricht der Webbrowser kein Websocket und erst 
recht kein Mqtt-over-Websocket.

"Eclipse Paho" ist zwar etwas älter, tut aber:

Dokumentation hier:
https://www.eclipse.org/paho/files/jsdoc/Paho.MQTT.Client.html

Download hier:
https://projects.eclipse.org/projects/iot.paho/downloads
-> JavaScript client 1.0.3

Antwort Zitieren Bearbeiten Löschen Beitrag melden

mehraltfraumann Gast 27.12.2022 17:37 #7298185

Lesenswert?

•

▲
▼

habe das jetzt mit paho getestet.
Kann zwar lokal zu meinem Broker senden  und auch zu test.mosquitto.org.
Aber wenn ich die Seite veröffentliche sendet der gar nicht zu meinem 
broker oder wenn ich an test.mosquitto.org senden möchte kommt 
folgendes:

Also in der Konsole bei Firefox:

Laden fehlgeschlagen für das <script> mit der Quelle "https://b663-188-96-145-0.ngrok.io/mqttws31.js". b663-188-96-145-0.ngrok.io:8:1
Uncaught DOMException: The operation is insecure. mqttws31.js:979
    _doConnect https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js:979
    connect https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js:849
    connect https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js:1799
    <anonym> https://b663-188-96-145-0.ngrok.io/:74
Mutations-Ereignisse sollten nicht mehr verwendet werden. Verwenden Sie MutationObserver stattdessen. analyser.js:485:17

Antwort Zitieren Bearbeiten Löschen Beitrag melden

mehraltfraumann Gast 27.12.2022 17:44 #7298193

Lesenswert?

•

▲
▼

hier sagen die am Ende dass sie ssl verwenden, damit der Fehler nicht 
auftritt ...
keine Ahnung was man da beachten muss bei Mosquitto..

https://github.com/eclipse/paho.mqtt.javascript/issues/207

Ich könnte ja  testweise irgendeinen sicheren Server ansteuern.

Antwort Zitieren Bearbeiten Löschen Beitrag melden

Jörg Gast 27.12.2022 18:30 #7298237

Lesenswert?

•

▲
▼

Hmm, das scheint mir alles etwas kompliziert...

Ich würde komplett auf JS und Websockets verzichten und eine simple 
Flask App in Python schreiben:

from flask import Flask
app = Flask(__name__)
@app.route('/dingelchen/an')
def dingelchen_an():
    # Paho Code zum publishen hier einfügen #
    return 'Dingelchen eingeschaltet'
@app.route('/dingelchen/aus')
def dingelchen_aus():
    # Paho Code zum publishen hier einfügen #
    return 'Dingelchen ausgeschaltet'
if __name__ == '__main__':
   app.run()


Dazu vll. noch einen Auth Header checken und es sollte gut sein.

Antwort Zitieren Bearbeiten Löschen Beitrag melden

mqtt von extern steuren

Antwort schreiben