Python: Wieso kann ich nur eine Nachricht über die Socketverbindung senden?

Moin alle zusammen,

ich habe folgende Frage:

Ich habe zwei Python-Dateien geschrieben:

Client.py:

import socket

W = '\033[0m' # white
R = '\033[31m' # red
G = '\033[32m' # green
O = '\033[33m' # orange
B = '\033[34m' # blue
P = '\033[35m' # purple

def excp():
  print(R+"Es ist ein Fehler aufgetreten!"+W)
   
client = socket.socket()
client.connect((ip, port))
used = []

while True:
  command = str(input("Nachricht: "))
  used.append(command)
  command = command.encode()
  client.send(command)
  msg = client.recv(1024).decode()
  print(msg)
  print(used)

Port und IP sind natürlich definiert.

Server.py:

import socket

W = '\033[0m' # white
R = '\033[31m' # red
G = '\033[32m' # green
O = '\033[33m' # orange
B = '\033[34m' # blue
P = '\033[35m' # purple

def excp():
  print(R+"Es ist ein Fehler aufgetreten!"+W)
  
def sendOutput(msg):
  client.sendto(str(msg).encode(), (ip, port))
 
server = socket.socket()
server.bind((ip, port))
server.listen(1)

while True:
  client, client_addr = server.accept()
  print(f" {client_addr} Client wurde mit dem Server verbunden") 
  msg = client.recv(1024).decode()
  print(msg)

sendOutput(msg)

Das funktioniert auch alles. Nur kann ich vom Client aus nur eine Nachricht schicken, bei der Zweiten kommt nichts mehr beim Server an und auch nicht wieder zurück. Was ist denn falsch?

Vielen Dank im Voraus. :)

1 Antwort

Destranix

Von gutefrage auf Grund seines Wissens auf einem Fachgebiet ausgezeichneter Nutzer

Programmieren & Softwareentwicklung

26.09.2022, 14:37

Der Server akzeptiert das Socket des Clients, gibt etwas aus, empfängt die Nachricht...

...und wartet dnan wieder darauf, ein neues Socket anzunehmen.

Du müsstest entweder einen neuen Thread/Process starten, der sich um die Kommunikation kümmert während der main-Thread weiter auf neue Verbindungen wartet.
Oder du akzeptierst neue verbindungen erst, wenn du mit der Kommunikation fertig bist.

Ähnliche Beiträge

Python Socket Programmierung Error?

#Server
import socket
ip_input = input("Gib deine IP an: ")
ip_input = str(ip_input)
IP_SERVER = ip_input
DISCONNECT_MESSAGE = "!DISCONNECT"
def start():
  server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  server.bind( (IP_SERVER, 5050) )
  print("Server gestartet")
  server.listen()
  conn, addr = server.accept()
  print(f"Client with IP {conn} connected")
  while True:
    msg = server.recv(1024)
    msg.decode("utf-8")
    print(f"Message: {msg}")
    if msg == DISCONNECT_MESSAGE:
      server.close()
      conn.close()
if __name__ == "__main__":
  start()
#Client
import socket
def start():
  server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  server.connect( ("192.168.1.100", 5050) )
  while True:
    msg = str(input("Your Message: "))
    msg = msg.encode()
    server.send(msg)
    answer = server.recv(1024)
    answer = answer.decode("utf-8")
    print(f"Antwort: {answer}")
if __name__ == "__main__":
  start()
#Error

Gib deine IP an: 192.168.1.100

Server gestartet

Client with IP <socket.socket fd=372, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('192.168.1.100', 5050), raddr=('192.168.1.100', 60324)> connected

Traceback (most recent call last):

File "c:\Users\User\OneDrive\Python\Server_2.py", line 26, in <module>

start()

File "c:\Users\User\OneDrive\Python\Server_2.py", line 17, in start

msg = server.recv(1024)

OSError: [WinError 10057] Eine Anforderung zum Senden oder Empfangen von Daten wurde verhindert, da der Socket nicht verbunden ist und (beim Senden über einen Datagrammsocket mit einem sendto-Aufruf) keine Adresse angegeben wurde

...zum Beitrag

Python Socket Programmierung?

Moin Moin,

ich hab grad einen socket chat programmiert. soweit funktioniert auch alles aber ich bekomme immer diesen einen Error. Vielleicht hat wer von euch eine Idee was ich hier falsch gemacht habe.

Server Code:

import socket 
import threading


HEADER = 64
PORT = 5050
SERVER = socket.gethostbyname(socket.gethostname())
ADDR = (SERVER, PORT)
FORMAT = 'utf-8'
DISCONNECT_MESSAGE = "!DISCONNECT"


server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(ADDR)


def handle_client(conn, addr):
    print(f"[NEW CONNECTION] {addr} connected.")


    connected = True
    while connected:
        msg_length = conn.recv(HEADER).decode(FORMAT)
        if msg_length:
            msg_length = int(msg_length)
            msg = conn.recv(msg_length).decode(FORMAT)
            if msg == DISCONNECT_MESSAGE:
                connected = False


            print(f"[{addr}] {msg}")
            conn.send("Msg received".encode(FORMAT))


    conn.close()
        


def start():
    server.listen()
    print(f"[LISTENING] Server is listening on {SERVER}")
    while True:
        conn, addr = server.accept()
        thread = threading.Thread(target=handle_client, args=(conn, addr))
        thread.start()
        print(f"[ACTIVE CONNECTIONS] {threading.activeCount() - 1}")



print("[STARTING] server is starting...")
start()

# Und hier der Client Code:

import socket


HEADER = 64
PORT = 5050
FORMAT = "utf-8"
DISCONNECT_MESSAGE = "!DISCONNECT"
SERVER = "192.168.1.14"
ADRR = (SERVER, PORT)


client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(ADRR)


def send(msg):
    message = msg.encode(FORMAT)
    msg_length = len(message)
    send_length = str(msg_length).encode(FORMAT)
    send_length += b' ' * (HEADER - len(send_length))
    client.send(send_length)
    client.send(message)
    print(client.recv(2048).decode(FORMAT))


while True:
    input = input("Deine Nachricht: ")
    send(input)

#Der Error:

Name Error: name "hallo" is not defined

...zum Beitrag

Unicode decode error?

Hi,

Immer wenn ich mehr als einen Befehl eingebe kommt der Error:

UnicodeDecodeError: 'utf-8' codec can't decode byte 0x84 in position 1048: invalid start byte

Code:

import socket


ip = "192.168.1.100"
port = 5555


s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((ip, port))
s.listen(1)
conn, addr = s.accept()


while True:
    command = input("Command: ")
    if command=="!DISCONNECT":
        conn.close()
        s.close()
    conn.send(command.encode())
    output = conn.recv(4096)
    output.decode("utf8").strip()
    print(f"{output}")

...zum Beitrag

Python Socket Server TCP Status erkennen?

Hi, ich suche jetzt leider schon seit Stunden:

Ich hätte gerne in der Bedingung der While-Schleife irgendetwas stehen was den Status von TCP überprüft, also ob der Client noch anwesend ist, oder nicht, ohne das mit einem Timeout regeln zu müssen.

Geht das?

LG.

import socket
import time

host = '0.0.0.0'
port = 5000
timeout = 5.0

def server_program():
    print('listen on: '+host)
    ss = socket.socket()
    ss.bind((host, port))
    ss.listen(5)
    (conn, address) = ss.accept()
    #WAITNING FOR SOCKET
    
    print("Client: " + str(address))
    
    
    timestamp = time.time()
    while timestamp+timeout>time.time():
        c = 0
        data = conn.recv(1024*10)
        #datay = data.decode()
        if not data:
            None
        else:
            #print('return: "'+str(datay)+'"')
            conn.send(data)
            timestamp = time.time()
        time.sleep(0.1)

    conn.close()


if __name__ == '__main__':
    server_program()

...zum Beitrag

Python Socket geht nicht?

Moin,

mein Client Code stürzt immer ab.

# Server Code
import socket


class txt_chat:
    def __init__(self):
        self.IP_SERVER = socket.gethostbyname(socket.gethostname())
        self.DISCONNECT_MESSAGE = "!DISCONNECT"


    def start(self):
        server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        server.bind( (self.IP_SERVER, 5050) )
        print("Server gestartet")
        server.listen()
        conn, addr = server.accept()
        print(f"Client with IP {conn} connected")


        while True:
            msg = server.recv(1024)
            msg.decode("utf-8")
            print(f"Message: {msg}")


            if msg == self.DISCONNECT_MESSAGE:
                server.close()
                conn.close()


txt = txt_chat()
txt.start()

# Client Code (Der nicht funktioniert)

import socket


class txt_chat:
    def start():
        server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        server.connect( ("192.168.1.14", 5050) )


        while True:
            msg = str(input("Your Message: "))
            msg = msg.encode()
            server.send(msg)


            answer = server.recv(1024)
            answer = answer.decode("utf-8")
            print(f"Antwort: {answer}")


txt = txt_chat()
txt.start()

#Error
Traceback (most recent call last):
  File "C:\Users\User\OneDrive\Python\client2.py", line 18, in <module>
    txt.start()
TypeError: start() takes 0 positional arguments but 1 was given

...zum Beitrag

Zielcomputer verweigert Verbindung - Python, Socket?

Moin Freunde, ich bin noch recht neu auf dem Gebiet.

Ich wollte gerne einen Server einrichten, der auf einem PC läuft und mich dann über einen anderen PC verbinden. Und das alles in Python mit Sockets. Ich habe folgendes geschrieben:

Server.py:

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

port = input("Über welchen Port soll der Server laufen?: ")

s.bind(("0.0.0.0", int(port)))

s.listen(5)

name = socket.gethostname()

while True:

clientsocket, address = s.accept()

print(G+f"Verbindung von " + name + " wurde hergestellt!")

clientsocket.send(bytes("Wilkommen auf dem Server", "utf-8"))

Client.py:

import socket

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

port = input("Über welchen Port soll die Verbindung aufgebaut werden?: ")

ip = input("Wie lautet die IP des Servers?: ")

s.connect((ip, int(port)))

input("")

Das funktioniert alles auch gut soweit, allerdings sagt mir mein zweiter PC, dass mir mein erster PC die Verbindung verweigert: ConnectionRefusedError: [WinError 10061]

Könnt ihr mir helfen?

LG und vielen Dank im Voraus,

Lucskiii

...zum Beitrag

Wie sende ich DNS Cookies mit dnslib?

Ich möchte mit dnslib die DNS-Antworten von den jeweiligen Anfragen mit einem DNS-Cookie versehen. Ich habe auch bereits etwas dafür in meinen Code implementiert, jedoch funktioniert das noch nicht so. Kann mir jemand sagen, was ich da brauche?

Der Code:

import socket
from dnslib import *

DNS_PORT = 53

dns_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
dns_socket.bind(('', DNS_PORT))

print(f"DNS-Server hört auf Port {DNS_PORT}...")

def dns_forward(domain):
    try:
        ip_address = socket.gethostbyname(domain)
        return ip_address
    except socket.error:
        return '185.199.111.153' #Error 404

while True:
    data, address = dns_socket.recvfrom(1024)

    dns_message = DNSRecord.parse(data)
    dns_request = str(dns_message.q.qname)
    
    dns_answer = dns_forward(dns_request)
    
    client_ip = address[0]
    client_port = address[1]

    dns_cookie = ("4096")

    if client_ip == '192.168.0.113'
        dns_response = DNSRecord(DNSHeader(id=dns_message.header.id, qr=1, aa=1, ra=1), q=dns_message.q)
        dns_response.add_answer(RR(dns_request, QTYPE.A, rdata=A(dns_answer)))
        dns_response.add_ar(RR(dns_request, QTYPE.OPT, rdata=TXT(dns_cookie)))
        dns_socket.sendto(dns_response.pack(), address)
    
    print(f"DNS-Anfrage von {client_ip} mit Port {client_port} für {dns_request} die Antwort ist {dns_answer}")

Die Fehlermeldung:

Traceback (most recent call last):
 File "c:\Users\Stoppersocke\Documents\Projects\MDM Bypass\test5.py", line 35, in <module>
  dns_socket.sendto(dns_response.pack(), address)
           ^^^^^^^^^^^^^^^^^^^
 File "C:\Users\Stoppersocke\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.11_qbz5n2kfra8p0\LocalCache\local-packages\Python311\site-packages\dnslib\dns.py", line 339, in pack
  ar.pack(buffer)
 File "C:\Users\Stoppersocke\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.11_qbz5n2kfra8p0\LocalCache\local-packages\Python311\site-packages\dnslib\dns.py", line 885, in pack
  for opt in self.rdata:
TypeError: 'TXT' object is not iterable

...zum Beitrag

Python variable ändern (erhöhen oder verringern)?

Ich bin ein absoluter Anfänger was programmieren angeht, lerne aber immer mehr und mehr dazu. Ich möchte für etwas ein Python Script erstellen, was auf meinem Pi die ganze Zeit läuft und die MQTT Nachrichten mitliest, um diese auszuführen und/oder eine Nachricht zurück zu senden.

Ich habe versucht eine Nachricht zu senden der den wert der Variable um 1 erhöhen soll und damit auch die While schleife aktivieren soll. Jedoch funktioniert es nicht, da die variable nicht in "def on_message" verfügbar ist und es die Erhöhung quasi nicht nach außen austrägt.

Was gibt es für Möglichkeiten die variable zu erhöhen, sodass sich die while schleife aktiviert? Und gibt es auch andere Ansätze wie man eine diese Schleife machen kann?

Script:

import paho.mqtt.client as mqtt
import os
import subprocess
import time
import smbus2
import bme280

#Bme280_basic Temperature
# BME280 sensor address (default address)
address = 0x76
# Initialize I2C bus
bus = smbus2.SMBus(1)
# Load calibration parameters
calibration_params = bme280.load_calibration_params(bus, address)
# to activate loop
y = int(1)
#Temperature loop
while y == 2:
      data = bme280.sample(bus, address, calibration_params)

      # Extract temperature, pressure, and humidity
      temperature_celsius = data.temperature      
      # Print the readings
      print("Temperature: {:.2f} °C".format(temperature_celsius))
      # Wait for a few seconds before the next reading
      time.sleep(2)
      #print(y)
else:
      print("stopped") 
    
#Connection successfull
def on_connect(client, userdata, flags, rc):
  print("Connected to MQTT broker")


#Checking for messages to execute code
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
    if msg.payload.decode() == "temp_bme280_start":
        print("Calling script to for temperature start...")
        # activate loop by adding 1
        y += 1   
        print(y)
    if msg.payload.decode() == "temp_bme280_stop":
        print("Calling script to for temperature stop...")
        # deactivate loop by remove 1
        y -= 1  
        print(y)  

def on_subscribe(client, userdata, mid, granted_qos):
    print("Subscribed to topic : " + str(mid) +" with QoS" + str(granted_qos))

client = mqtt.Client()

client.username_pw_set( "userxxx" , "passwortxxx" )

client.connect( "192.16x.xxx.xxx", 1883, 60)

client.subscribe( "frame/monitor" , qos=1)

client.on_connect = on_connect

client.on_message = on_message

client.loop_forever()

Würde Chat GPT sowas lösen können?

...zum Beitrag

Python Socket Encoding Error?

Hi, jedesmal wenn ich versuche mit dem Client eine Nachricht zu senden stürzt mir der Server ab. 

import socket
import threading


class TxtSocket:
    
    def __init__(self, host=socket.gethostbyname(socket.gethostname()) , port=5555, connection = 0, disconnect="!DISCONNECT"):
        self.host = host
        self.port = port
        self.connection = connection
        self.disconnect = disconnect
        self.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.s.bind((self.host, self.port))
        print("Socket was created")


    def handle(self, conn, addr):
        while True:
            connection = threading.active_count() -1
            print(f"Connections: {connection}")
            data = conn.recv(1024).decode("utf8")
            if data == self.disconnect:
                conn.close()


            elif not data:
                break
            addr = str(addr[0])
            addr.encode()
            data.encode()
            print(type(data))
            print(type(addr))
            print(f"{addr}: {data}")
            self.s.send(addr[0], data)
        


    def server(self):
        self.s.listen(26)
        print("Server is listening")
        while True:
            conn, addr = self.s.accept()
            print(f"{addr} is now connected.")
            t = threading.Thread(target=self.handle, args=(conn, addr))
            t.start()
        


if __name__ == "__main__":
    txtsocket = TxtSocket()
    txtsocket.server()
 


#Client      
import socket


def Text():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((socket.gethostbyname(socket.gethostname()), 5555))
    print("Connected")
    while True:
        message = input("Deine Nachricht: ")
        message = message.encode("utf8")
        s.send(message)
Text()

ERROR:

Socket was created

Server is listening

('10.0.0.11', 55353) is now connected.

Connections: 1

10.0.0.11: s

Exception in thread Thread-1:

Traceback (most recent call last):

File "C:\Users\Tobias\AppData\Local\Programs\Python\Python39\lib\threading.py", line 954, in _bootstrap_inner

self.run()

File "C:\Users\Tobias\AppData\Local\Programs\Python\Python39\lib\threading.py", line 892, in run

self._target(*self._args, **self._kwargs)

File "C:\Users\Tobias\OneDrive\Python\Server.py", line 30, in handle

self.s.send(addr[0], data)

TypeError: a bytes-like object is required, not 'str'

...zum Beitrag

[Errno 10061] Es konnte keine Verbindung hergestellt werden, da der Zielcomputer die Verbindung verweigerte?

Moin,

ich versuche derzeit ein Backdoor-System für mein "Zweitsystem" zu schreiben.

Der Quelltext:

import os
import socket

s = socket.socket()
host = '127.0.0.1'
port = 8080
s.connect((host, port))

print("Verbunden")
print("")

while 1:
  command = s.recv(1024)
  command = command.decode()
  print("Kommando erhalten")

  if command == "view_cwd":
    files = os.getcwd()
    files = str(files)
    s.send("".encode())
    s.send(command.encode())
    print("Ausgefuehrt")
  else:
    print("")
    print("Command regognised")

Der Fehler der auftritt ist:

[Errno 10061] Es konnte keine Verbindung hergestellt werden, da der Zielcomputer die Verbindung verweigerte.

Wie kann ich das beheben?

PS: Mein OS ist Windows 10 Home.

Vielen Dank für eure Antworten. 😀

...zum Beitrag

Python Programmieren - Socket Server Ich versuche zurzeit einen Socket Sever zu machen. Es kommt aber leider immer eine Fehlermeldung. Kann mir jemand helfen?

Der Server kann die Daten nur empfangen, wenn der Client und der Server auf dem selben PC laufen. Sonst funktioniert es nicht. Wie kann ich den Fehler beheben? Hier einmal die Fehlermeldung: s.connect(('127.0.0.1', 50010)) ConnectionRefusedError: [WinError 10061] Es konnte keine Verbindung hergestellt werden, da der Zielcomputer die Verbindung verweigerte

Server.py :

import socket

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

server_socket.bind(('127.0.0.1', 50010)) server_socket.listen(1) while True: (client_socket, addresse) = server_socket.accept() print(client_socket.recv(1024))

Client.py :

import time, socket s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect(('127.0.0.1', 50010))

while True: msg = str(input("message: ")) msg = msg.encode() s.send(msg)

msg = s.recv(1024)
msg = msg.decode()
print("sent: " + msg)
print()

s.close()

...zum Beitrag

NameError: name 'guild' is not defined?

import discord
import time
from discord.ext import commands
import random

intents = discord.Intents.default()
intents.message_content = True

client = discord.Client(intents=intents)

@client.event
async def on_ready():
    print(''' 

Bereit!

 ''')
    await client.change_presence(activity=discord.Game(name="Python 3.9"))

@client.event
async def on_message(message):
    if message.author == client.user:
        return

    while 5 > 1:
        if message.content.startswith('$py'):
            time.sleep(1)
            await message.channel.send('Hey')
            await message.channel.send('https://cdn.discordapp.com/emojis/1021051851967320114.webp?size=4096')
            await guild.create_text_channel('Python 3.9')
client.run('My Token')

error: await guild.create_text_channel('Python 3.9')

NameError: name 'guild' is not defined

...zum Beitrag

Warum kann ich mit Python keine personalisierten Commands programmieren?

Ich wollte bei Python ein Bot mit personalisierten Commands schreiben. Aber immer wenn ich in Discord den Command "!test" ausführe passiert nichts.

import discord
from discord.ext import commands

intents = discord.Intents.default()
bot = commands.Bot(command_prefix='!', intents=intents)
token = ""

@bot.event
async def on_ready():
    print(f"{'-'*40}\nDiscord Bot ist online als {bot.user.name}")

@bot.command()
async def test(ctx):
    await ctx.send(ctx.author)

bot.run(token)

Weiß jemand was bei dem Code falsch ist und wie man es lösen könnte?

...zum Beitrag

Wo ist der Fehler in meinem Python Code (MQTT)?

Ich habe ein Python Script erstellt, damit später bei Nachrichten bestimmte befehle ausgeführt werden. Beim ersten Script(Openhab_Mqtt.py) habe ich beim Testen 3 Terminals aufgemacht und beim 2.(Openhab_Mqttv2.py) auch genau gleiche Sorgehensweise.

Im 1. Terminal habe ich das Python Script gestartet mit:

python Openhab_Mqttv2.py

Output:
Script 1: Connected to MQTT broker
Script 2: Connected to MQTT broker
Connected to MQTT broker

Im 2. Terminal habe ich die Nachricht ausgegeben bei Nachrichten mit:

mosquitto_sub -t "main/messager" -v -u xxx -P xxx

Output(Nach T3):
Script 1: main/messager test
Script 2: main/messager test

Und im 3. Terminal habe ich eine Nachricht gesendet mit:

mosquitto_pub -t "main/messager" -m "test" -u xxx-P xxx

Output:
Script 1: Payload: test und BLA...
Script 2:

Ich kann einfach nicht den Fehler finden, warum es bei Openhab_Mqtt.py funktioniert und bei Openhab_Mqttv2.py nicht funktioniert.

Openhab_Mqtt.py DATA:

import paho.mqtt.client as mqtt
import os
import time
import bme280_temp
import smbus2
import bme280
import threading

def on_subscribe(client, userdata, mid, granted_qos):
 print("Subscribed to topic : " + str(mid) +" with QoS" + str(granted_qos))


def on_connect(client, userdata, flags, rc):
 print("Connected to MQTT broker")


def on_message(client, userdata, msg): 
 print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
 print("Payload: " + msg.payload.decode())
 if msg.payload.decode() == "send_signal":
  print("Calling script to send signal...")
  IR_Signal()
 if msg.payload.decode() == "temp_bme280_start":
  print("Calling script to for temperature start...")
  userdata["counter"] += 1
  print(str(userdata["counter"]))
  client.publish("frame/monitor", "START", qos=0, retain=True)
  Temp_sensor() 
 if msg.payload.decode() == "temp_bme280_stop":
  print("Calling script to for temperature stop...")
  userdata["counter"] -= 1
  print(str(userdata["counter"]))
  client.publish("frame/monitor", "STOP", qos=0, retain=True)
 if msg.payload.decode() == "test":
  print("BLA...")  
  print(str(["counter"])) 
  os.system("vcgencmd measure_temp") 
 else:
  pass    



#Bme280_basic Temperature
address = 0x76
bus = smbus2.SMBus(1)
calibration_params = bme280.load_calibration_params(bus, address)

def Temp_sensor():
 data = bme280.sample(bus, address, calibration_params)
 temperature_celsius = data.temperature      
 print("Temperature: {:.2f} °C".format(temperature_celsius))
 time.sleep(2)
    
 
def IR_Signal():
 os.system("irsend SEND_ONCE pioneer_vsx-301 KEY_POWER")
 print ("Signal Send!")


client = mqtt.Client()
client.on_message = on_message 
client.on_connect = on_connect
client.user_data_set({"counter": 0})
client.username_pw_set( "xx" , "xx" )
client.connect( "192.x.x.x", 1883, 60)
client.subscribe( "main/messager" , qos=0)


client.loop_forever()

Openhab_Mqttv2.py

import paho.mqtt.client as mqtt
import time
import smbus2
import bme280
import threading


# Getting information
def on_subscribe(client, userdata, mid, granted_qos):
 print("Subscribed to topic : " + str(mid) +" with QoS" + str(granted_qos))
                                                                 
def on_connect(client, userdata, flags, rc):
 print("Connected to MQTT broker")


# Damit loops nicht am anfang durchstarten 
TempLoop_running = False


# Checking for messages to execute code
def on_message(client, userdata, msg):
 print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
 print("Payload: " + msg.payload.decode())
 if msg.payload.decode() == "Temp_Start":
  start_TempLoop()
 if msg.payload.decode() == "Temp_Stop":
  stop_TempLoop()
 if msg.payload.decode() == "test":
  print("TESTING...")
  client.publish("main/messager", "START", qos=0, retain=True)
 else:
  pass



# Execute things here ->


# Getting Temperature
address = 0x76
bus = smbus2.SMBus(1)
# Load calibration parameters
calibration_params = bme280.load_calibration_params(bus, address)
def Temperature_loop():
 global TempLoop_running
 while TempLoop_running:
  data = bme280.sample(bus, address, calibration_params)
  #Extract temperature, pressure, and humidity
  temperature_celsius = data.temperature      
  #Print the readings
  print("Temperature: {:.2f} °C".format(temperature_celsius))
  # Nachricht an das entsprechende Topic senden
  client.publish("Temp/Loop", "Temperature: {:.2f} °C".format(temperature_celsius))
  # Wartezeit, um die Ausgabe zu verlangsamen
  time.sleep(2)
# Funktion zum Starten der Temperatur Schleife
def start_TempLoop():
 global TempLoop_running
 TempLoop_running = True
 threading.Thread(target=Temperature_loop).start()
# Funktion zum Stoppen der Temperatur Schleife
def stop_TempLoop():
 global TempLoop_running
 TempLoop_running = False



# Set general data
client = mqtt.Client()
client.on_message = on_message 
client.on_connect = on_connect
client.connect( "192.x.x.x", 1883, 60)
client.username_pw_set( "xx", "xx" )
client.subscribe( "main/messager", qos=0)


# Loop forever
client.loop_forever()

...zum Beitrag

Was möchtest Du wissen?

Deinen Beitrag erstellen