Code: Alles auswählen
import subprocess
subprocess.Popen(['python','dummy_script.py'])
Code: Alles auswählen
import time
counter = 1
while counte < 100:
print('Schleife: ' + str(counter))
counter +=1
time.sleep(1)
Danke - Stefan
Code: Alles auswählen
import subprocess
subprocess.Popen(['python','dummy_script.py'])
Code: Alles auswählen
import time
counter = 1
while counte < 100:
print('Schleife: ' + str(counter))
counter +=1
time.sleep(1)
Code: Alles auswählen
def count():
for counter in range(1, 101):
print(f"Schleife: {counter}")
time.sleep(1)
Code: Alles auswählen
import subprocess
subprocess.Popen(['python','QProzess/dummy_script.py'])
x = subprocess.Popen(['python','QProzess/dummy_script.py'])
subprocess.Popen.terminate(x)
Code: Alles auswählen
# !/usr/bin/python
# -*- coding: utf-8 -*-
import paho.mqtt.client as mqtt
TOPIC = "inTopic"
BROKER_ADDRESS = "localhost"
PORT = 1883
QOS = 1
if __name__ == "__main__":
client = mqtt.Client()
client.connect(BROKER_ADDRESS, PORT)
print("Connected to MQTT Broker: " + BROKER_ADDRESS)
DATA = "Sensor lesen"
client.publish(TOPIC, DATA, qos=QOS)
client.loop()
Code: Alles auswählen
# !/usr/bin/python
# -*- coding: utf-8 -*-
import paho.mqtt.client as mqtt
TOPIC = "inTopic"
BROKER_ADDRESS = "localhost"
PORT = 1883
def on_message(client, userdata, message):
msg = str(message.payload.decode("utf-8"))
print("message received: ", msg)
print("message topic: ", message.topic)
#nach 5 Minuten mqqt_pub.py erneut ausführen / subprocess?
def on_connect(client, userdata, flags, rc):
print("Connected to MQTT Broker: " + BROKER_ADDRESS)
client.subscribe(TOPIC)
if __name__ == "__main__":
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(BROKER_ADDRESS, PORT)
client.loop_forever()
Code: Alles auswählen
import time
import paho.mqtt.client as mqtt
TOPIC = "inTopic"
BROKER_ADDRESS = "localhost"
PORT = 1883
DATA = "Sensor lesen"
def send(client):
client.publish(TOPIC, DATA, qos=QOS)
def on_message(client, userdata, message):
msg = str(message.payload.decode("utf-8"))
print("message received: ", msg)
print("message topic: ", message.topic)
#nach 5 Minuten mqqt_pub.py erneut ausführen / subprocess?
def on_connect(client, userdata, flags, rc):
print("Connected to MQTT Broker: " + BROKER_ADDRESS)
client.subscribe(TOPIC)
if __name__ == "__main__":
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect(BROKER_ADDRESS, PORT)
next_send_time = time.time() + 5 * 60
while True:
left_time = time.time() - next_send_time
if left_time <= 0:
send(client)
next_send_time = time.time() + 5 * 60
else:
client.loop_forever(left_time)