dani/django-ram
1
0
Fork 0
mirror of https://github.com/daniviga/django-ram.git synced 2025-08-04 13:17:50 +02:00
Code Issues Packages Projects Releases Wiki Activity

First mqtt e2e stub

Browse Source
This commit is contained in:
Daniele Viganò
2021-12-18 01:06:04 +01:00
parent 04d87ed25c
commit e35f6951a1
3 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
dcc/driver/.connector.py.swp
View File

Binary file not shown.

9
dcc/driver/connector.py
View File

@@ -1,8 +1,17 @@
import paho.mqtt.client as mqtt
class Connector: class Connector:
MQTT_HOST = "127.0.0.1"
MQTT_PORT = 1883
@classmethod @classmethod
def __mqtt_pub(self, message): def __mqtt_pub(self, message):
# to be encoded # to be encoded
client = mqtt.Client()
client.connect(self.MQTT_HOST, self.MQTT_PORT)
client.publish("dcc/commands", payload=message)
client.disconnect()
print(message) print(message)
return True return True

9
deamons/serial.py
View File

@@ -16,13 +16,14 @@ async def mqtt_broker(ser):
async with client.unfiltered_messages() as messages: async with client.unfiltered_messages() as messages:
async for message in messages: async for message in messages:
print(message.payload.decode()) print(message.payload.decode())
ser.write(message.payload) # ser.write(message.payload)
def main(): def main():
client = mqtt.Client() client = mqtt.Client()
ser = serial.Serial('/dev/pts/7') # ser = serial.Serial('/dev/pts/7')
ser.baudrate = 9600 # ser.baudrate = 9600
ser = None # remove me
while True: while True:
try: try:
client.connect(MQTT_HOST, MQTT_PORT) client.connect(MQTT_HOST, MQTT_PORT)
@@ -34,7 +35,7 @@ def main():
logging.info('Broker subscribed') logging.info('Broker subscribed')
client.disconnect() client.disconnect()
asyncio.run(mqtt_broker(ser)) asyncio.run(mqtt_broker(ser))
ser.close() # ser.close()
if __name__ == "__main__": if __name__ == "__main__":