Forward received message to nodered
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
import os
|
import os
|
||||||
import threading
|
import threading
|
||||||
|
|
||||||
|
import requests
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
from flask import Flask
|
from flask import Flask
|
||||||
|
|
||||||
@@ -29,7 +30,11 @@ message_controller = MessageController(app, auth_data, "https://192.168.15.120:8
|
|||||||
|
|
||||||
|
|
||||||
def handle_message_received(topic:str, payload:str):
|
def handle_message_received(topic:str, payload:str):
|
||||||
pass
|
try :
|
||||||
|
url = "https://127.0.0.1:1880/message/receive"
|
||||||
|
requests.post(url, json=payload, verify=False)
|
||||||
|
except Exception as e:
|
||||||
|
print(e)
|
||||||
|
|
||||||
def start_mqtt(data : AuthData):
|
def start_mqtt(data : AuthData):
|
||||||
client_id = data.get_client_id()
|
client_id = data.get_client_id()
|
||||||
|
|||||||
Reference in New Issue
Block a user