NEWS
Драйвер Mqtt + Arduino
-
У меня проводка протянута только к датчикам температуры по квартире и на коллекторах,а так же к герконам на окнах (витая пара FTP). К радиаторам к сожалению нет проводки. Да, читал про резисторы на ethernet шилдах. Спасибо за информацию. Тогда сначала освоюсь с установкой ioBroker, а потом уже буду изучать mqtt. `
У меня к радиаторам есть проводка, пока только датчики температуры стоят ds'ки. Планирую покупать клапана eQ-3, отопление центральное, так что только регулировать на самих радиаторах. Теплых полов нет и не нужны они, единственный будет на балконе, пока не думал как им управлять но скорее всего заводским контроллером к которому пригамырить arduinkу). -
Так вот: Китайцы видимо не понимают разницы в маркировке чип резисторов между 510 и 511 либо не нашлось под рукой 510 и подумали что 511 это одно и тоже ведь 1 на конце добавляет 0 т.е. получается те же 510. Если внимательно посмотреть справочники, то там четко указано, что 510 это 51 Ом, а 511 это уже 510 Ом. `
Только что получил на почте W5100. Тоже стоит резистор 511
-
Подскажите, что-то я запутался между ардуино и брокером… Если я планирую измерять температуру (5-10 мест), давление, освещенность... мне лучше заводить датчики на ардуино и потом стыковать к брокеру, или (если установить брокер на odroid/кубик) завести все датчики на odroid/кубик и в ардуино вообще отпадает необходимость?
-
Подскажите, что-то я запутался между ардуино и брокером… Если я планирую измерять температуру (5-10 мест), давление, освещенность... мне лучше заводить датчики на ардуино и потом стыковать к брокеру, или (если установить брокер на odroid/кубик) завести все датчики на odroid/кубик и в ардуино вообще отпадает необходимость? `
Оба варианта работоспособны…С помощью ардуины можно делать более распределенные системы. Т.е. у меня к примеру одна ардуина отвечает за охрану/пожарку и передает данные на сервер. Вторая ардуина стоит на балконе и отправляет данные о погоде на сервер, включая датчики внутри квартиры. Была еще третья - занималась освещением, но я её "выдернул" под другой проект. И кстати - можно даже несколько плат с ioBroker объединить в пул - для обмена данными и работе на общую визуализацию...
Можно и на саму плату с помощью тех же GPIO повесить все датчики и исполнительные механизмы. Только если зависнет сервер - то пропадет все... У меня если зависнет сервак - то ардуины продолжат обрабатывать данные (хоть и не будут передавать на сервер) и работать по заложенному алгоритму.
-
Спасибо!
Стало меньше мусора в голове
-
Можно ли организовать работу с одной переменной (без IN и OUT) ? У меня контролер ловит свои же сообщения и отрабатывает …. это глюк или все как положено ?
как в iobroker организовать работу когда лампочка в vis отображает значение пришедшее в OUT а упровляющий надо посылать в IN ?
5076_2018_09_21_19_35_19_window.png -
кстати как убрать приставку из топика "mqtt.0." которую обязательно стал добавлять mqqt driver iobroker
-
кстати как убрать приставку из топика "mqtt.0." которую обязательно стал добавлять mqqt driver iobroker `
А зачем? а если у тебя будет два драйвера MQTT? (второй получится mqtt.1.) и в объектах проще искать. -
чтобы меньше в ардуино писать
-
чтобы меньше в ардуино писать `
:shock: А что ты туда пишешь?У меня так
client.publish("myhome/NRF/Vodonagrevatel/btn_Temp_Selector", "0"); client.publish("myhome/NRF/Vodonagrevatel/Status", "0"); client.subscribe("myhome/NRF/#");
-
а сообщения из иоброкера выглядят так
mqtt/0/kv7/kitchen/1/rel1
и mqtt/0 малину портит
-
а сообщения из иоброкера выглядят так
mqtt/0/kv7/kitchen/1/rel1
и mqtt/0 малину портит `
Что значит из брокера? В скриптах? -
по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1
-
по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1 `
А смысл их смотреть? Подписываешся на них и все какая разница что там в протоколе -
по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1
А смысл их смотреть? Подписываешся на них и все какая разница что там в протоколе
Может автор имеет ввиду тяжело парсить что прилетело от сервера?У меня callback примерно такой:
!
//Функция обработки входящих соединений - прием данных по подписке void callback(char* topic, byte* payload, unsigned int length) { Serial.println (""); Serial.println ("-------"); Serial.println ("New callback of MQTT-broker"); //преобразуем тему(topic) и значение (payload) в строку payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); //Исследуем что "прилетело" от сервера по подписке: //Изменение режима работы контроллера if (strTopic == "PLC31_OnLight/mode") { if (strPayload == "standby") PLC_mode=MODE_STANDBY; else if (strPayload == "active") PLC_mode=MODE_ACTIVE; else if (strPayload == "deactivation") PLC_mode=MODE_DEACTIVATION; } //Изменение времени таймаута if (strTopic == "PLC31_OnLight/timeout") { timeout = strPayload.toInt(); } //Управление реле стробоскопа if (strTopic == "common/PLC38_PLC31_stroboRelay") { if (strPayload == "off" || strPayload == "0" || strPayload == "false") digitalWrite(stroboRelay_pin, HIGH); else if (strPayload == "on" || strPayload == "1" || strPayload == "true") digitalWrite(stroboRelay_pin, LOW); } Serial.print (strTopic); Serial.print (" "); Serial.println (strPayload); Serial.println ("-------"); Serial.println (""); } !
-
по протоколу MQTT топики выглядят так mqtt/0/kv7/kitchen/1/rel1
А смысл их смотреть? Подписываешся на них и все какая разница что там в протоколе
Может автор имеет ввиду тяжело парсить что прилетело от сервера?У меня callback примерно такой:
!
//Функция обработки входящих соединений - прием данных по подписке void callback(char* topic, byte* payload, unsigned int length) { Serial.println (""); Serial.println ("-------"); Serial.println ("New callback of MQTT-broker"); //преобразуем тему(topic) и значение (payload) в строку payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); //Исследуем что "прилетело" от сервера по подписке: //Изменение режима работы контроллера if (strTopic == "PLC31_OnLight/mode") { if (strPayload == "standby") PLC_mode=MODE_STANDBY; else if (strPayload == "active") PLC_mode=MODE_ACTIVE; else if (strPayload == "deactivation") PLC_mode=MODE_DEACTIVATION; } //Изменение времени таймаута if (strTopic == "PLC31_OnLight/timeout") { timeout = strPayload.toInt(); } //Управление реле стробоскопа if (strTopic == "common/PLC38_PLC31_stroboRelay") { if (strPayload == "off" || strPayload == "0" || strPayload == "false") digitalWrite(stroboRelay_pin, HIGH); else if (strPayload == "on" || strPayload == "1" || strPayload == "true") digitalWrite(stroboRelay_pin, LOW); } Serial.print (strTopic); Serial.print (" "); Serial.println (strPayload); Serial.println ("-------"); Serial.println (""); } !
`
Ну собственно аналогично://////////////////////////////////////////////////////////////////////////// void callback(char* topic, byte* payload, unsigned int length) { payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); callback_iobroker(strTopic, strPayload); }
void callback_iobroker(String strTopic, String strPayload){ if (strTopic == "myhome/Mother/DomofonOpen") { //Открыть домофон if (strPayload == "0") digitalWrite(6, 0); else if (strPayload == "1") { digitalWrite(7, HIGH); delay(1000); digitalWrite(6, HIGH); delay(1500); digitalWrite(6, LOW); delay(500); digitalWrite(7, LOW); client.publish("myhome/Mother/DomofonOpen", "0"); } } if (strTopic == "myhome/Mother/DomofonUptube") { //Снять турбку домофона if (strPayload == "0") digitalWrite(7, 0); else if (strPayload == "1") digitalWrite(7, 1); } if (strTopic == "myhome/Mother/Change_Electro_counter"){ Serial.print("CHG"); Serial.print(strPayload); delay(10); } if (strTopic == "myhome/Mother/Dimmer_Button") { //Подсветка выключателей dimm = strPayload.toInt(); if (dimm >= 0 && dimm <= 255){ analogWrite(5, dimm); } } }
-
я имею ввиду что до версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений имели вид
"myhome/Mother/DomofonOpen"
и это меня устраивало и с точки зрения чистоты кода, и с точки зрения применяемости полученного конечного устройства (параллельно смотрю мажордомо)
после версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений стали
"mqtt/0/myhome/Mother/DomofonOpen"
и это меня не устраивает а отключить не нашел как
обходные пути я вижу но они меня не устраивают
поэтому вопросы :
-
это глюк при переходе ?
-
есть возможность отключить ?
ну и старые никем не отвеченные :
-
Можно ли организовать работу с одной переменной (без IN и OUT) ?
-
У меня контролер ловит свои же сообщения и отрабатывает …. это глюк или все как положено?
-
как в iobroker организовать работу когда лампочка в vis отображает значение пришедшее в OUT а управляющий надо посылать в IN ?
-
-
я имею ввиду что до версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений имели вид
"myhome/Mother/DomofonOpen"
и это меня устраивало и с точки зрения чистоты кода, и с точки зрения применяемости полученного конечного устройства (параллельно смотрю мажордомо)
после версии драйвера MQTT Adapter 2.15 паблики исходящих сообщений стали
"mqtt/0/myhome/Mother/DomofonOpen"
и это меня не устраивает а отключить не нашел как
обходные пути я вижу но они меня не устраивают
поэтому вопросы :
-
это глюк при переходе ?
-
есть возможность отключить ?
ну и старые никем не отвеченные :
-
Можно ли организовать работу с одной переменной (без IN и OUT) ?
-
У меня контролер ловит свои же сообщения и отрабатывает …. это глюк или все как положено?
-
как в iobroker организовать работу когда лампочка в vis отображает значение пришедшее в OUT а управляющий надо посылать в IN ? `
Выложи код с ардуины, подозреваю что то ты намудрил. Не пойму про IN и OUT, зачем они тебе?
4447_adapterneustart-und-volume_gesetzt.log
-
-
Вот код :
! #include <dht.h>#include <esp8266wifi.h>#include <pubsubclient.h>#define DHTPIN 5
! //#define DHTTYPE DHT11 // DHT 11
! #define DHTTYPE DHT22 // DHT 22 (AM2302)
! //#define DHTTYPE DHT21 // DHT 21 (AM2301)
! float dht_h ; // Reading temperature or humidity takes about 250 milliseconds!
! float dht_t ; // Read temperature as Celsius (the default)
! DHT dht(DHTPIN, DHTTYPE);
! #define Rel1pin 12
! #define Rel2pin 13
! #define But1pin 4
! #define But2pin 6
! // Update these with values suitable for your network.
! const char* ssid = "kv7";
! const char* password = "*****";
! //const char mqtt_server = "broker.mqtt-dashboard.com";
! IPAddress MQTTserver(192, 168, 1, 120);
! String MQTT_CN = "kv7/Kitchen/1";
! IPAddress IPAdrr (192, 168, 1, 201);
! IPAddress IPGW (192, 168, 1, 1);
! IPAddress Mask (255, 255, 255, 0);
! unsigned long TimerSendTH = 0;
! unsigned long TimerSendTHOFF = 2000;
! unsigned long TimerRel1 = 0;
! unsigned long TimerRel1OFF = 5000;
! unsigned long TimerRel2 = 0;
! unsigned long TimerRel2OFF = 6000;
! WiFiClient espClient;
! PubSubClient client(espClient);
! long lastMsg = 0;
! char msg[50];
! int value = 0;
! void setup() {
! pinMode(BUILTIN_LED, OUTPUT); // Initialize the BUILTIN_LED pin as an output
! pinMode(12, OUTPUT);
! pinMode(13, OUTPUT);
! pinMode( 4, INPUT);
! dht.begin();
! Serial.begin(115200);
! WiFi.begin(ssid, password);
! WiFi.config(IPAdrr, IPGW, Mask ); //Comment for DHCP
! setup_wifi();
! client.setServer(MQTTserver, 1883);
! client.setCallback(callback);
! }
! void setup_wifi() {
! delay(10);
! // We start by connecting to a WiFi network
! Serial.println();
! Serial.print("Connecting to ");
! Serial.println(ssid);
! // WiFi.begin(ssid, password);
! while (WiFi.status() != WL_CONNECTED) {
! delay(500);
! Serial.print(".");
! }
! Serial.println("");
! Serial.println("WiFi connected");
! Serial.println("IP address: ");
! Serial.println(WiFi.localIP());
! }
! void callback(char topic, byte payload, unsigned int length) {
! payload[length] = '\0';
! String strTopic = String(topic);
! strTopic.replace(MQTT_CN,"");
! String strPayload = String((char)payload);
! Serial.print("Message arrived [");
! Serial.print(strTopic+" | ");
! Serial.print(strPayload);
! Serial.print("]");
! Serial.println("");
! if (strTopic == "/Rel1") {
! if (strPayload == "0") digitalWrite(Rel1pin, !LOW);
! else if (strPayload == "1") digitalWrite(Rel1pin, !HIGH);
! }
! else if (strTopic == "/Rel2") {
! if (strPayload == "0") digitalWrite(Rel2pin, !LOW);
! else if (strPayload == "1") digitalWrite(Rel2pin, !HIGH);
! }
! }
! boolean reconnect() {
! Serial.print("Attempting MQTT connection…");
! // if (client.connect(("Controller "+MQTT_CN).c_str() ))
! if (client.connect("Controller 1"))
! {
! // Once connected, publish an announcement...
! client.publish(MQTT_CN.c_str() ," online");
! // ... and resubscribe
! Serial.print("Subscribe...ok "+MQTT_CN);
! client.subscribe((MQTT_CN+"/#").c_str() );
! }
! else Serial.print("Fail...");
! return client.connected();
! }
! boolean measurements() {
! Serial.print("measurements... ");
! dht_h = dht.readHumidity();
! dht_t = dht.readTemperature();
! if (isnan(dht_h) || isnan(dht_t) || isnan(dht.readTemperature(true))) return false;
! return true;
! }
! void loop() {
! if (!client.connected()) reconnect();
! client.loop();
! // digitalWrite(12, !digitalRead(4) );
! // digitalWrite(13, !digitalRead(4) );
! // TimerSendTH = 0;
! //TimerSendTHOFF = 2000;
! // TimerRel1 = 0;
! // TimerRel1OFF = 5000;
! // TimerRel2 = 0;
! // TimerRel2OFF = 6000;
! //measurements();
! //snprintf (msg, 75, "%2d", DHT.humidity);
! dtostrf (dht_h,0,2,msg );
! // client.publish((MQTT_CN+ "/humidity").c_str(), msg);
! // Serial.println(dht_h);
! dtostrf ( dht_t,0,2,msg );
! // client.publish((MQTT_CN+"/temperature").c_str(), msg);
! // Serial.println(dht_t);
! client.publish((MQTT_CN+"/Rel1").c_str(),String( !digitalRead(12)).c_str());
! Serial.println((MQTT_CN+"/Rel1"+String( !digitalRead(12))).c_str() );
! delay(500);
! client.publish((MQTT_CN+"/Rel2").c_str(),String( !digitalRead(13)).c_str());
! Serial.println((MQTT_CN+"/Rel2"+String( !digitalRead(13))).c_str() );
! delay(500);
! }</pubsubclient.h></esp8266wifi.h></dht.h> -
Вот точно такая же фигня была :
Раньше такая строка отправлялась от брокера: myhome/Bedroom/Servo
Сейчас: mqtt/0/myhome/Bedroom/Servo
только не помогает ранее найденое лекарство - строка префикса и так пустая