Wie kann ich zwei MFRC522-RFID-Reader gleichzeitig mit einem Raspberry Pi 3 Model B verwenden?

Hallo zusammen,

ich versuche seit über einem Monat, zwei MFRC522-RFID-Reader gleichzeitig mit meinem Raspberry Pi 3 Model B (Version 1.2) zu betreiben, leider ohne Erfolg.

Mein Ziel ist es, dass beide Reader parallel arbeiten und unabhängig voneinander Tags erkennen und auslesen können. Ich verwende Python mit dem

spidev

-Modul und habe jedem Reader eine eigene SPI-Schnittstelle zugewiesen:

Reader 1: SPI0 (Bus 0, Device 0), RST auf GPIO25
Reader 2: SPI1 (Bus 1, Device 0), RST auf GPIO17

Beide Reader sind korrekt verkabelt. SPI1 ist über Device Tree aktiviert, und ich verwende keine gemeinsamen CS-Pins. Ich habe eine eigene Klasse für MFRC522 geschrieben, um jeweils ein SPI-Device und einen RST-Pin zu verwenden. Hier ist der relevante Python-Code:

python
import spidev
import RPi.GPIO as GPIO
import time


class MFRC522:
    def __init__(self, spi_bus, spi_device, rst_pin):
        self.spi = spidev.SpiDev()
        self.spi.open(spi_bus, spi_device)
        self.spi.max_speed_hz = 1000000
        self.spi.mode = 0
        self.rst = rst_pin


        GPIO.setwarnings(False)
        GPIO.setmode(GPIO.BCM)
        GPIO.setup(self.rst, GPIO.OUT)
        GPIO.output(self.rst, 1)
        self.reset()


    def reset(self):
        GPIO.output(self.rst, 0)
        time.sleep(0.1)
        GPIO.output(self.rst, 1)
        time.sleep(0.1)


    def send(self, addr, val):
        self.spi.xfer2([(addr << 1) & 0x7E, val])


    def read(self, addr):
        val = self.spi.xfer2([((addr << 1) & 0x7E) | 0x80, 0])
        return val[1]


    def scan_for_tag(self):
        self.send(0x01, 0x0C)  # PCD_TRANSCEIVE
        self.send(0x0D, 0x87)  # BitFramingReg


        self.send(0x0C, 0x26)  # Request idle
        time.sleep(0.01)
        return self.read(0x0A) != 0  # FIFOLevelReg


    def get_uid(self):
        self.send(0x0D, 0x87)
        self.spi.xfer2([0x93, 0x20])  # Anticollision
        time.sleep(0.01)
        resp = self.spi.xfer2([0x93, 0x20] + [0]*5)
        uid = resp[2:6]
        return ':'.join([hex(x)[2:].upper().zfill(2) for x in uid])


    def cleanup(self):
        self.spi.close()
        GPIO.cleanup(self.rst)


# Konfiguration der Reader
reader1 = MFRC522(spi_bus=0, spi_device=0, rst_pin=25)  # SPI0
reader2 = MFRC522(spi_bus=1, spi_device=0, rst_pin=17)  # SPI1


try:
    print("Starte RFID-Scanner (STRG+C zum Beenden)")
    while True:
        if reader1.scan_for_tag():
            uid1 = reader1.get_uid()
            print(f"Reader 1 UID: {uid1}")


        if reader2.scan_for_tag():
            uid2 = reader2.get_uid()
            print(f"Reader 2 UID: {uid2}")


        time.sleep(0.5)


except KeyboardInterrupt:
    print("\nBeende...")


finally:
    reader1.cleanup()
    reader2.cleanup()

Das Problem: Keiner der beiden Reader erkennt zuverlässig Tags. Der zweite reagiert manchmal, oft aber gar nicht oder liefert keine UID. Ich habe bereits unterschiedliche Polling-Intervalle, Resets und sogar die Versorgungsspannung überprüft, aber ohne Erfolg.
so habe ich meine MFRC522 Reader angeschlossen:

Bild zum Beitrag

Hat jemand Erfahrung damit oder Ideen, wie ich beide MFRC522 zuverlässig gleichzeitig betreiben kann? Gibt es vielleicht Timing-Probleme, Konflikte zwischen den SPI-Bussen oder brauche ich spezielle Initialisierung?

Ich bin für jede Hilfe dankbar!

chriss1967

26.05.2025, 16:24

Funktioniert denn ein Reader alleine mit deinem Code?

Swisssssi

Beitragsersteller

27.05.2025, 07:23

fast nie , denke das ich einen neuen Code brauchen werde

1 Antwort

Vom Beitragsersteller als hilfreich ausgezeichnet

Kelec

Nutzer, der sehr aktiv auf gutefrage ist

im Thema Code

02.06.2025, 11:38

Häng den IRQ Pin an und lies dessen Level. Sofern ein Tag in der Nähe ist sollte der auf Low gehen. Versuch mal die Datenabfrage nur wenn IRQ Low ist.

Außerdem nimm mal einen Reader weg und machs mit einem mal stabil. Orientiere dich an bestehenden Libraries.

Swisssssi

Beitragsersteller

02.06.2025, 12:14

Danke

Ähnliche Beiträge

Verstehe den Fehler kaum Python?

HI,

und zwar bin ich dabei eine Aufgabe zu machen, doch kommen nicht weiter was mache ich den falsch??

Leider verstehe ich den Ausgebenden Fehler kaum.

Mein Code:

class Figur:
    def __init__(self, name, farbe, durchmesser, kanten):
      
        self.name = name
        self.farbe = farbe
    
        
    def ausgabe(self):
        print("Die Figur", self.name, "hat folgende Eigenschaften:")
        print("Die Figur hat die Farbe:", self.farbe)
        
        
    def Radius_Veraendern(self, veraendern):
      if self.radius < 1:
          self.radius = self.radius + 1
          print("Der neue Radius beträgt", self.radius)
          
          
    def Kante_Veraendern(self, veraendern):
      if self.kantenlaenge < 1:
          self.kantenlaenge = self.kantenlaenge + 6
          print("Die nue KAntenlänge brträgt", self.kantenlaenge)
          
          
    def Laenge_Veraendern(self, veraendern):
        if self.laenge < 1:
           self.laenge = self.laenge + 3
           print("Die neue Linienlänge beträgt:", self.laenge)
           
        
# Die Klasse für Kreis
class Kreis(Figur):
    def __init__(self, name, farbe, radius):
        super().__init__(name, farbe, radius)
        
        self.radius = radius
       
 
    def ausgabe(self):
        super().ausgabe()
        print("Der Radius beträgt:", self.radius)
        
        
#Die Klasse für Viereck
class Viereck(Kreis):
    def __init__(self, name, farbe, kantenlaenge):
        super().__init__(name, farbe, kantenlaenge)
        
        self.kantenlaenge = kantenlaenge
        
    def ausgabe(self):
        super().ausgabe()
        print("Die Kantenlänge beträgt:", self.kantenlaenge)
        
       
# Die Klasse für Linie
class Linie(Kreis):
    def __init__(self, name, farbe, laenge):
        super().__init__(name, farbe, laenge)
        
        self.laenge = laenge
        
    def ausgabe(self):
        super().ausgabe()
        print("Die Linienlänge beträgt:", self.laenge)
        
    
    


#einen Kreis erzeugen
kreis = Kreis("Mein Kreis", "Rot", 5)
kreis.ausgabe()
#verändere den Wert
kreis.Radius_Veraendern(-5)


print("----------------")


#ein Viereck erzeugen
viereck = Viereck ("Mein Viereck", "Blau", 8)
viereck.ausgabe()
#verändere den Wert
viereck.Kante_Veraendern8(-10)


print("----------------")




#eine Linie erzeugen
linie = Linie("Meine Linie", "Grün", 9)
linie.ausgabe()
#verändern den Wert
viereck.Linie_Veraendern(-8)

...zum Beitrag

Turtle-Grafik in Python - letzter Aufruf wird nicht angezeigt?

Hallo Community, eine Frage:

Ich habe versucht, die grafische Simulation einer Ampel zu coden. Die Darstellung soll der Einfachkeit halber mit Turtle funktionieren. Im Grunde klappt alles wunderbar, nur die Grün-Phase wird in der Anzeige "übersprungen". Spannend: Wenn ich manuell über die passenden Methode die Grünphase einstelle, wird sie einwandfrei angezeigt. Nur in der Endlosschleife sehe ich gar nichts bzw. ein kurzes "Flackern".

Hat jemand eine Idee, woran das liegen könnten?

import turtle
import time


class Lampe():
    def __init__(self, farbe, x, y):
        self.__zustand = False
        self.farbe = farbe
        self.turtle = turtle.Turtle()
        self.turtle.hideturtle()
        self.turtle.penup()
        self.turtle.speed(0)
        self.turtle.shape("circle")
        self.turtle.color(farbe)
        self.turtle.goto(x, y)


    def einschalten(self):
        self.__zustand = True
        self.turtle.color(self.farbe)
        self.turtle.stamp()


    def ausschalten(self):
        self.__zustand = False
        self.turtle.clear()


    def zustand(self):
        return self.__zustand


class Ampel():
    def __init__(self):
        self.__rot = Lampe("red", 0, 50)
        self.__gelb = Lampe("yellow", 0, 0)
        self.__green = Lampe("green", 0, -50)
        self.__phase = "rot"
        self.__rot.einschalten()
        
    def phase_rot(self):
        self.__rot.einschalten()
        self.__gelb.ausschalten()
        self.__green.ausschalten()
        self.__phase = "rot"
        
    def phase_gelb(self):
        self.__rot.ausschalten()
        self.__gelb.einschalten()
        self.__green.ausschalten()
        self.__phase = "gelb"
        
    def phase_green(self):
        self.__rot.ausschalten()
        self.__gelb.ausschalten()
        self.__green.einschalten()
        self.__phase = "green"
        
    def phase_rotgelb(self):
        self.__rot.einschalten()
        self.__gelb.einschalten()
        self.__green.ausschalten()
        self.__phase = "rotgelb"


    def umschalten(self):
        if self.__phase == "rot":
            self.phase_rotgelb()
        elif self.__phase == "rotgelb":
            self.phase_green()
        elif self.__phase == "green":
            self.phase_gelb()
        elif self.__phase == "gelb":
            self.phase_rot()
        else:
            print("Something went horribly utterly wrong. Doomsday!")
        time.sleep(2)
        self.umschalten()


if __name__ == "__main__":
    turtle.Screen().bgcolor("black")
    ampel = Ampel()
    ampel.umschalten()

...zum Beitrag

Discord Python Bot Online Member werden nicht erkannt?

Mein Code:

import discord

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

class MyClient(discord.Client):
  async def on_message(self, message)
    if message.content.startswith("*online"):
      members = client.guilds[0].members
      for i in members:
        if i.status == discord.Status.offline:
          members.remove(i)
            
      for i in members:
        print(str(i))

client = MyClient(guild_subscriptions=True, intents=intents)
client.run(token)

Beim print in der Konsole werden nun alle member angezeigt, warum?

...zum Beitrag

Python background service / alle x sekunden was ausführen?

Das Szenario: Ich hab ne API laufen die per post request einen Service starten und stoppen soll. Der Service soll alle paar Sekunden etwas tun.

Code:

from fastapi import FastAPI
from testService import Service
import time

app = FastAPI()

@app.get("/")
def index():
    #hier später Service start / stop callen (und post draus machen)
    return { "message": "hello world"}

service = Service()
service.start()
time.sleep(20)
service.stop()

Und der service:

import sched, time

class Service:
    scheduler = sched.scheduler(time.time, time.sleep)
    running = False
    interval = 5

    def start(self):
        self.running = True
        self.task(None)
        self.scheduler.run()

    def stop(self):
        self.running = False
        if(self.event):
            self.scheduler.cancel(self.event)

    def task(self, nothing):
        if(self.running):
            self.event = self.scheduler.enter(self.interval, 1, self.task, (self,))
            print("test")
            #hier dann der Code, der alle paar Sekunden ausgeführt werden soll

Das Problem: self.scheduler.run() blockt den Main Thread, und die Lösung ist wohl ne Schleife darum, aber das sieht irgendwie nach dem falschen Ansatz aus und ich weiß nicht ob das sich nicht vlt mit den API Endpoints beißt...

Wie mache ich das richtig?

...zum Beitrag

Tic Tac Toe?

Ich möchte ein TTT in phyton programmieren hier ist mein quellcode ich weiß das er nicht fertig ist:
class  Board:
    def __init__(self):
        self.state = [0, 0, 0, 0, 0, 0, 0, 0, 0,]

        def make_turn(self, cell, player):
            self.state[cell] =  player.symbol

    def sign_to_printable(self, sign):
        if sign == 0:
            return " "
        elif sign == 1:
            return "X"
        else:
            return "O"
    def print_board(self):

        print(" " + self.sign_to_printable(self.state[0]) + " | " + self.sign_to_printable(self.state[1]) + " | " + self.sign_to_printable(self.state[2]) + " \n" +
              " " + self.sign_to_printable(self.state[3]) + " | " + self.sign_to_printable(self.state[4]) + " | " + self.sign_to_printable(self.state[5]) + " \n" +
              " " + self.sign_to_printable(self.state[6]) + " | " + self.sign_to_printable(self.state[7]) + " | " + self.sign_to_printable(self.state[8]) + "  \n" +)
 class Player:
     def __init__(self, symbol):
         self.symbol = symbol

         if __name__ == ' __main__':
             Player_a = Player(1)
             Player_b = Player(-1)
             Board = Board()

Jetzt bekomme ich ein paar fehlermeldungen :Expression expected, Unindent does not match any outer indentation level in zeile 20 und Unresolved reference 'Board' in der 28.WAS heißt das und wie kann ich das fixen

...zum Beitrag

Mein Python Code funktioniert nicht?

Guten Abend erst einmal,

ich habe versucht mittels Python ein Mau Mau spiel zu erstellen, aber wenn ich es ausprobieren will, zeigt mir das Programm mitten im code " invalid Syntax " an.

Kann einer von euch mal bitte drüber schauen und mir sagen, was fehlt?

Hier ist der Code (,was mir als Fehler angezeigt wurde habe ich markiert( es ist das deck.shuffel ())).

import random

class Card:

def __init__(self, value, suit):

self.value = value

self.suit = suit

def __repr__(self):

return f"{self.value} of {self.suit}"

class Deck:

suits = ["Hearts", "Diamonds", "Spades", "Clubs"]

values = ["Ace", "2", "3", "4", "5", "6", "7", "8", "9", "10", "Jack", "Queen", "King"]

def __init__(self):

self.cards = [Card(value, suit) for suit in self.suits for value in self.values]

def shuffle(self):

random.shuffle(self.cards)

def deal(self):

return self.cards.pop()

class Player:

def __init__(self, name):

self.name = name

self.hand = []

def draw(self, deck):

self.hand.append(deck.deal())

def play_card(self, card):

self.hand.remove(card)

class AIPlayer(Player):

def choose_card(self, top_card):

for card in self.hand:

if card.value == top_card.value or card.suit == top_card.suit:

return card

return self.hand[0]

def play_game():

deck = Deck()

... deck.shuffle()

...

... player = Player("Player")

... ai = AIPlayer("AI")

...

... for i in range(7):

... player.draw(deck)

... ai.draw(deck)

...

... top_card = deck.deal()

...

... while len(player.hand) > 0 and len(ai.hand) > 0:

... print(f"Top card: {top_card}")

... print(f"{player.name}'s hand: {player.hand}")

...

... chosen_card = player.play_card(player.hand[int(input("Choose a card to play (index): "))])

... if chosen_card.value == top_card.value or chosen_card.suit == top_card.suit:

... top_card = chosen_card

... else:

... player.draw(deck)

... print(f"{player.name} drew a card.")

...

... if len(ai.hand) > 0:

... chosen_card = ai.choose_card(top_card)

... print(f"{ai.name} played {chosen_card}.")

... if chosen_card.value == top_card.value or chosen_card.suit == top_card.suit:

... top_card = chosen_card

... else:

... ai.draw(deck)

... print(f"{ai.name} drew a card.")

...

... if len(player.hand) == 0:

... print(f"{player.name} wins!")

... else:

... print(f"{ai.name} wins!"

>>> [DEBUG ON]

>>> [DEBUG OFF]

...zum Beitrag

Python - Frage zu Klassen Methoden Objekten?

Hallo,

Ich habe eine kleines Problem mit Klassen bzw. dessen Objekten. Ich zeige mein Problem anhand eines kleinen Beispiels:

Initialisierung der Klasse:

class Test:
  def __init__(self, test_objekt):
    self.test-objekt = test_objekt
  
  def test_methode(self)
    print(self.test_objekt)

Die Klasse hat 3 Methoden die alle das test-objekt verwenden möchten.

Aber mir klappt die Übergabe von dem in __init__ initialisiertem test_objekt nicht auf die Methode. Wie muss ich es schreiben dass das self.test_objekt in der test_methode benutzt werden kann?

Aufruf der Klasse ist im Beispiel übertragen auf mein Problem:

Test.test_methode(test_objekt)

...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

Arduino RFID reader mit Timer?

Ich habe folgendes Problem, ich versuche eine maschine in arduino zu bauen, welche die zeit misst wo keine RFID karte auf dem reader liegt. Nun habe ich aber folgendes Problem, wenn ich die karte auflege wird der Timer schon gesartet, dieser soll aber erst gesartet werden, wenn der user die karte vom reader entpfernt. kann mir da jemand helfen.

#include <SPI.h>
#include <MFRC522.h>


#define SS_PIN D4  // SDA Pin (Slave Select)
#define RST_PIN D3 // Reset Pin


MFRC522 mfrc522(SS_PIN, RST_PIN);  // RFID-Instanz


unsigned long startTime;
bool timerActive = false;
bool cardDetected = false;


void setup() {
  Serial.begin(115200);  // Initialisiere die serielle Kommunikation
  SPI.begin();           // Initialisiere den SPI-Bus
  mfrc522.PCD_Init();   // Initialisiere den RFID-Leser


  Serial.println("RFID-Leser bereit. Halten Sie eine Karte an den Leser.");
}


void loop() {
  bool cardPresent = mfrc522.PICC_IsNewCardPresent();
  
  if (cardPresent) {
    if (mfrc522.PICC_ReadCardSerial()) {
      // Karte wird erkannt
      if (timerActive) {
        // Timer stoppen und Zeit ausgeben
        unsigned long elapsedTime = millis() - startTime;
        Serial.print("Zeit gemessen: ");
        Serial.print(elapsedTime);
        Serial.println(" ms");
        timerActive = false;  // Timer zurücksetzen
      }
      cardDetected = true; // Karte wurde erkannt
      mfrc522.PICC_HaltA();  // Halt das Leseverfahren
      mfrc522.PCD_StopCrypto1();
    }
  } else {
    // Wenn keine Karte mehr vorhanden ist
    if (cardDetected && !timerActive) {
      // Timer starten, wenn der Timer nicht aktiv ist
      startTime = millis();
      timerActive = true;
      Serial.println("Timer gestartet.");
    }
    cardDetected = false; // Karte wurde entfernt
  }
}

...zum Beitrag

Mit Funktionen in Python dividieren funktioniert falsch?

Hallo, leider funktioniert der Code, aber "vertauscht" die Zahlen. Wie kann ich das fixen?

from functools import partial
from operator import add, floordiv, mul, sub


def three(op=None): 
    return 3 if not op else op(3)

def seven(op=None): 
    return 7 if not op else op(7)


def plus(val): 
    return partial(add, val)

def minus(val): 
    return partial(sub, val)

def times(val): 
    return partial(mul, val)

def divided(val): 
    return partial(floordiv, val)

print(seven(divided(three())))  # --> 0 

print(three(divided(seven())))  # --> 2

...zum Beitrag

Python function wird zweimal aufgerufen?

Guten Morgen,

Ich habe ein problem mit meinem skript. Ich möchte gerne, dass wenn man einen kliptaster betätigt dieser in einem array gespeichert wird. Leider wird die Zahl des Tasters doppelt im array angezeigt. Er ruft bei mir die function zweimal auf.

import RPi.GPIO as GPIO # Import Raspberry Pi GPIO library
import time
import sys, traceback
 
#https://raspberrypihq.com/use-a-push-button-with-raspberry-pi-gpio/
 
tastenSeq=[]
 
 
def button_callback(channel):
       print("Taster 2: AN")
       GPIO.output(12,True)
       tastenSeq.append(2)
       time.sleep(1.0)
       GPIO.output(12,False)
       print("Taster 2: AUS")
 
 
def button_callback2(channel2):
       print("Taster 5: AN")
       GPIO.output(32,True)
       tastenSeq.append(5)
       time.sleep(1.0)
       GPIO.output(32,False)
       print("Taster 5: AUS")
       print tastenSeq
 
GPIO.setmode(GPIO.BOARD)
GPIO.setup(12,GPIO.OUT)
GPIO.setup(32,GPIO.OUT)
 
GPIO.setwarnings(False) # Ignore warning for now
#GPIO.setmode(GPIO.BOARD) # Use physical pin numbering
 
GPIO.setup(31, GPIO.IN, pull_up_down=GPIO.PUD_DOWN) # Set pin 10 to be an input pin and set initial value to be pulled low (off)
GPIO.add_event_detect(31,GPIO.RISING,button_callback) # Setup event on pin 10 rising edge
 
 
GPIO.setup(15, GPIO.IN, pull_up_down=GPIO.PUD_DOWN) # Set pin 10 to be an input p$
GPIO.add_event_detect(15,GPIO.RISING,callback=button_callback2) # Setup event on p$
 
message = input("Press enter to quit\n\n") # Run until someone presses enter
GPIO.cleanup() # Clean up

...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

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

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

Was möchtest Du wissen?

Deine Frage stellen