Mqtt dash ошибка соединения

С установкой думаю не возникнет ни каких проблем. После инсталляции запускаем программу. В верху экрана щелкаем по кнопке +

Данные — логин, password, номер порта для настройки берем с панели управления брокера

Немного о настройках — Идентификатор ставится автоматически. Размер плиток выбираем по желанию, потом можно поменять. После ввода настроек сохраняемся нажав на значок дискеты в верхней части экрана. Приложение позволяет устанавливать связь с разными серверами. То есть при сбое связи одного сервера Вы можете переключиться на другой и «умный дом» продолжит выполнять свои функции.

Входим в созданное нами соединение и подключаем клиента к серверу. Если не получаем ни каких уведомлений то соединение установлено. Если получаем уведомления необходимо возвратиться назад в настройки соединения. Самая распространенная ошибка — при копировании параметров в настройках прописываются лишние знаки пробела и соединение не устанавливается. Зайдя в соединения щелкаем по «+» получаем вот такое меню.

Рассмотрим кратко пункты меню:

Текст Имя может быть любым, в том числе и на русском. Ниже название топика, так как в данном случае мы только получаем данные публикацию не включаем. Поля «Префикс» и «Постфикс» служат для ввода дополнительной информации. Показывая мгновенные потребления тока при помощи «Постфикса» показывает единицу измерения — а (ампер). После введения информация не забываем сохраниться. Если надо вывести много параметров то для простоты создания виджетов их можно клонировать, для этого нажать пальцем на виджете и подержать. Появится меню: выбираем копировать.

Переключатель/кнопка Используется для включения выключения различного оборудования, например освещения.

Выбираем нужную картинку для отображения на экране и нужный цвет. Также можно изменять цвет выводимого текста.

Обращаю внимание — подпункты «Вкл» и «Выкл» должны прописываться точно так как на сервере. Если сервере прописано включение «1», а в приложение вы прописали «ON» работать не будет

Диапазон/прогресс Работает как поле «Текст», но кроме этого выводит графический диапазон значения. Выглядит примерно так — виджет в самом низу показывает напряжение

С остальными пунктами меню тоже особых проблем нет, пробуйте. Апетит приходит во время еды. Вопросы лучше задавать через форму связи на моем сайте

As an extension of this question and based on the answers, I am using websockets to connect to MQTT broker using dash_mqtt taking this app script as a reference. But I am not able to send or receive data with the configuration in the below app.py.

import dash_mqtt
import dash
from dash.dependencies import Input, Output, State
import dash_html_components as html
import dash_core_components as dcc
import flask
import json
import paho.mqtt.client as mqtt



TEST_SERVER = '172.17.0.2'
TEST_SERVER_PORT = 1883
TEST_SERVER_PATH = 'mqtt'
MESSAGE_OUT_TOPIC = 'testtopic'
MESSAGE_IN_TOPIC = 'testtopic'

external_stylesheets = ['https://codepen.io/chriddyp/pen/bWLwgP.css']

server = flask.Flask(__name__)
app = dash.Dash(__name__, external_stylesheets=external_stylesheets)
app.config.suppress_callback_exceptions = True



app.layout = html.Div([
    dash_mqtt.DashMqtt(
        id='mqtt',
        broker_url=TEST_SERVER,
        broker_port = TEST_SERVER_PORT,
        broker_path = TEST_SERVER_PATH,
        topics=[MESSAGE_IN_TOPIC]
    ),
    html.H1('MQTT echo'),
    html.P('MQTT echo server to ' + TEST_SERVER + ' on port ' + str(TEST_SERVER_PORT)),
    dcc.Input(
        id='message_to_send',
        placeholder='message to send',
        debounce = True),
    html.Button('Send',id='send'),
    html.Div(id='return_message')
])


@app.callback(
        Output('mqtt', 'message'),
        Input('send', 'n_clicks'),
        State('message_to_send', 'value')
    )
def display_output(n_clicks, message_payload):
    if n_clicks:
        return {
            'topic': MESSAGE_OUT_TOPIC,
            'payload' : message_payload
        }
    return dash.no_update

if __name__ == '__main__':
    app.run_server(host='0.0.0.0',port=8050,debug=True) 

In brief,

1. I am trying to connect to eclipse mqtt broker which is running
   in a docker container associated with the IP address
   172.17.0.2 listening to the port 1883.
2. Dash app is running in another docker container with the port 8050.

All the basic configuration to the mosquitto.config file is done so that it listens and responds to external communications. Also, this app runs successfully without errors in the log but cannot communicate with the MQTT broker.

What configuration changes should I have to make to connect to the broker?

Thank you

Edit: The browser console saysWebSocket connection to 'ws://172.17.0.2:1883/mqtt' failed:

mosquitto.conf

# Config file for mosquitto

# =================================================================
# Listeners
# =================================================================

# listener port-number [ip address/host name/unix socket path]
listener 1883

# =================================================================
# Persistence
# =================================================================

persistence True

# =================================================================
# Security
# =================================================================

# Defaults to false, unless there are no listeners defined in the configuration
# file, in which case it is set to true, but connections are only allowed from
# the local machine.
allow_anonymous True

#include <EEPROM.h>

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

#include <Wire.h>

const char ssid[] = «xxxxxxx»; //Insert your SSID

const char pass [] = «xxxxxxxxx»; /Insert Your password

const char* mqtt_server = «mqtt.thingspeak.com»;

const char* mqttUserName = «xxxxxxxxxxx»; // Thingspeak username.

const char* mqttPass = «xxxxxxxxxxxxxxxx»; // Change to your MQTT API Key from Account > MyProfile.

const char* ChannelID = «xxxxxx»; // Thingspeak Channel ID

const char* APIKey = «xxxxxxxxxxxxxxxx»; // Thingspeak Channel Read API Key

String Temp_String;

WiFiClient espClient;

PubSubClient client(espClient);

const byte ledPin = 0; // Pin with LED on Adafruit Huzzah

void callback(char* topic, byte* payload, unsigned int length) {

Serial.print(«Data received: «);

Serial.print(«Temperature «);

for (int i = 0; i < length; i++) {

char receivedChar = (char)payload[i];

Temp_String += (char)payload[i];

}

float TS_Temp = Temp_String.toFloat();

Serial.print(TS_Temp);

TS_Temp = 0;

Temp_String = «»;

Serial.println();

}

void reconnect() {

// Loop until we’re reconnected

while (!client.connected()) {

Serial.print(«Attempting MQTT connection…»);

// Attempt to connect

if (client.connect(«ESP8266», mqttUserName, mqttPass)) {

Serial.println(«connected»);

// …

client.subscribe(«channels/INSERT YOUR CHANNEL ID HERE/subscribe/fields/field1/INSERT YOUR API READ KEY HERE»);

} else {

Serial.print(«failed, rc=»);

Serial.print(client.state());

Serial.println(» try again in 5 seconds»);

// Wait 5 seconds before retrying

delay(5000);

}

}

}

void setup()

{

Serial.begin(115200);

delay(250);

client.setServer(mqtt_server, 1883);

client.setCallback(callback);

WiFi.disconnect();

delay(100);

WiFi.mode(WIFI_STA);

WiFi.begin(ssid, pass);

while (WiFi.status() != WL_CONNECTED) {

Serial.print(«.»);

delay(500);

}

Serial.print(«OK»);

Serial.println();

}

void loop()

{

if (!client.connected()) {

reconnect();

}

client.loop();

}

#include <EEPROM.h>

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

#include <Wire.h>

const char ssid[] = «xxxxxxx»; //Insert your SSID

const char pass [] = «xxxxxxxxx»; /Insert Your password

const char* mqtt_server = «mqtt.thingspeak.com»;

const char* mqttUserName = «xxxxxxxxxxx»; // Thingspeak username.

const char* mqttPass = «xxxxxxxxxxxxxxxx»; // Change to your MQTT API Key from Account > MyProfile.

const char* ChannelID = «xxxxxx»; // Thingspeak Channel ID

const char* APIKey = «xxxxxxxxxxxxxxxx»; // Thingspeak Channel Read API Key

String Temp_String;

WiFiClient espClient;

PubSubClient client(espClient);

const byte ledPin = 0; // Pin with LED on Adafruit Huzzah

void callback(char* topic, byte* payload, unsigned int length) {

Serial.print(«Data received: «);

Serial.print(«Temperature «);

for (int i = 0; i < length; i++) {

char receivedChar = (char)payload[i];

Temp_String += (char)payload[i];

}

float TS_Temp = Temp_String.toFloat();

Serial.print(TS_Temp);

TS_Temp = 0;

Temp_String = «»;

Serial.println();

}

void reconnect() {

// Loop until we’re reconnected

while (!client.connected()) {

Serial.print(«Attempting MQTT connection…»);

// Attempt to connect

if (client.connect(«ESP8266», mqttUserName, mqttPass)) {

Serial.println(«connected»);

// …

client.subscribe(«channels/INSERT YOUR CHANNEL ID HERE/subscribe/fields/field1/INSERT YOUR API READ KEY HERE»);

} else {

Serial.print(«failed, rc=»);

Serial.print(client.state());

Serial.println(» try again in 5 seconds»);

// Wait 5 seconds before retrying

delay(5000);

}

}

}

void setup()

{

Serial.begin(115200);

delay(250);

client.setServer(mqtt_server, 1883);

client.setCallback(callback);

WiFi.disconnect();

delay(100);

WiFi.mode(WIFI_STA);

WiFi.begin(ssid, pass);

while (WiFi.status() != WL_CONNECTED) {

Serial.print(«.»);

delay(500);

}

Serial.print(«OK»);

Serial.println();

}

void loop()

{

if (!client.connected()) {

reconnect();

}

client.loop();

}

import dash_mqtt
import dash
from dash.dependencies import Input, Output, State
import dash_html_components as html
import dash_core_components as dcc
import flask
import json
import paho.mqtt.client as mqtt



TEST_SERVER = '172.17.0.2'
TEST_SERVER_PORT = 1883
TEST_SERVER_PATH = 'mqtt'
MESSAGE_OUT_TOPIC = 'testtopic'
MESSAGE_IN_TOPIC = 'testtopic'

external_stylesheets = ['https://codepen.io/chriddyp/pen/bWLwgP.css']

server = flask.Flask(__name__)
app = dash.Dash(__name__, external_stylesheets=external_stylesheets)
app.config.suppress_callback_exceptions = True



app.layout = html.Div([
    dash_mqtt.DashMqtt(
        id='mqtt',
        broker_url=TEST_SERVER,
        broker_port = TEST_SERVER_PORT,
        broker_path = TEST_SERVER_PATH,
        topics=[MESSAGE_IN_TOPIC]
    ),
    html.H1('MQTT echo'),
    html.P('MQTT echo server to ' + TEST_SERVER + ' on port ' + str(TEST_SERVER_PORT)),
    dcc.Input(
        id='message_to_send',
        placeholder='message to send',
        debounce = True),
    html.Button('Send',id='send'),
    html.Div(id='return_message')
])


@app.callback(
        Output('mqtt', 'message'),
        Input('send', 'n_clicks'),
        State('message_to_send', 'value')
    )
def display_output(n_clicks, message_payload):
    if n_clicks:
        return {
            'topic': MESSAGE_OUT_TOPIC,
            'payload' : message_payload
        }
    return dash.no_update

if __name__ == '__main__':
    app.run_server(host='0.0.0.0',port=8050,debug=True) 

# Config file for mosquitto

# =================================================================
# Listeners
# =================================================================

# listener port-number [ip address/host name/unix socket path]
listener 1883

# =================================================================
# Persistence
# =================================================================

persistence True

# =================================================================
# Security
# =================================================================

# Defaults to false, unless there are no listeners defined in the configuration
# file, in which case it is set to true, but connections are only allowed from
# the local machine.
allow_anonymous True

1 ответ

listener 1884
protocol websockets