--- title: "Shelly EM MQTT" description: "Jednofázový elektromer Shelly EM pripojený k TapHome cez MQTT. Meranie spotreby energie (kWh) na kanál, monitoring napätia a ovládanie stykačového relé." url: "https://taphome.com/sk/compatibility/shelly-em-mqtt/" language: sk lastmod: 2026-10-08 generator: hugo ai: topics: ["mqtt","electric-meter","wifi","energy-metering","contactor-control","ct-clamp"] questions: ["Ako integrovať Shelly EM s TapHome cez MQTT?","Čo meria šablóna Shelly EM MQTT v TapHome?","Ako nájsť Device ID zariadenia Shelly EM pre MQTT?","Dá sa ovládať stykačové relé Shelly EM z TapHome cez MQTT?","Prečo Shelly EM nehlási údaje o energii cez MQTT?","Podporuje šablóna Shelly EM MQTT okamžitý odčet výkonu?"] --- # Shelly EM MQTT Komunikácia: Packet Parser → MQTT - [Produktová stránka Shelly EM](https://www.shelly.com/en/products/shop/shelly-em) > Adresa v sieti > > Pri MQTT brokeri vstavanom v TapHome zadajte v TapHome ako adresu brokera `127.0.0.1`. V zariadení zadajte IP adresu TapHome Core a jednotke Core dajte rezerváciu IP v routeri. > > [Príprava siete](https://taphome.com/sk/docs/setup/network-preparation/) ## Návod na integráciu Shelly EM je jednofázový elektromer s dvoma nezávislými meracími kanálmi a 2A reléovým výstupom na ovládanie stykača. Každý kanál sa pripája k externému prúdovému transformátoru (CT svorke) -- dostupnému v 50A a 120A variantoch -- čo umožňuje neinvazívne sledovanie dvoch samostatných obvodov súčasne. Táto šablóna sa pripája k zariadeniu cez MQTT broker v lokálnej sieti. Cloudové pripojenie nie je potrebné. Šablóna vytvára tri zariadenia: dva elektromery (jeden na CT kanál) sledujúce kumulatívnu spotrebu energie a spínač pre stykačové relé. ## Konfigurácia ### Device ID Shelly EM používa Device ID vo formáte `shellyem-XXXXXX`, kde `XXXXXX` je posledných 6 znakov MAC adresy v hexadecimálnom formáte (napr. `shellyem-B929CC`). Pri importe šablóny zadajte len hexadecimálnu časť (napr. `B929CC`) do parametra **Device ID**. Device ID nájdete: - Vo webovom rozhraní Shelly: **Settings** > **Device Info** - Cez API: `GET http:///settings` -- pole `mqtt.id` > [!TIP] > Toto zariadenie podporuje **mDNS discovery**. Namiesto IP adresy môžete pri konfigurácii MQTT brokera použiť hostname `shellyem-{MAC}.local`. Nahraďte `{MAC}` rovnakou hexadecimálnou časťou ako v Device ID (napr. `shellyem-B929CC.local`). Použitie hostname predchádza problémom s konektivitou pri zmene IP adresy zariadenia. ### Nastavenie MQTT Pred importom šabl��ny aktivujte MQTT na zariadení Shelly EM: 1. Otvorte webové rozhranie Shelly na `http://` 2. Prejdite do **Internet & Security** > **Advanced — Developer Settings** 3. Zaškrtnite **Enable action execution via MQTT** 4. Do poľa **Server** zadajte adresu MQTT brokera vo formáte `broker-ip:1883` 5. Stlačte **SAVE** > [!WARNING] > Na zariadeniach Shelly Gen1 aktivácia MQTT **deaktivuje Shelly Cloud**. Obe funkcie nemôžu bežať súčasne. ### Nastavenie šablóny Po importe šablóny v TapHome: 1. Nastavte **MQTT Broker IP** na adresu vášho MQTT brokera 2. Nastavte **MQTT Broker Port** (predvolene `1883`) 3. Nastavte **Device ID** na hexadecimálnu časť Device ID zariadenia Shelly EM (napr. `B929CC`) Modul odoberá topic `shellies/#` a listener skripty na každom zariadení filtrujú správy podľa nakonfigurovaného Device ID. ## Možnosti zariadenia ### Meranie energie (na kanál) Každý kanál je v TapHome vystavený ako nezávislé zariadenie Elektromer. Listener skript odoberá dva MQTT topicy na kanál: | Topic | Jednotka | Popis | |-------|----------|-------| | `emeter/{i}/energy` | watt-minúty | Kumulatívna energia od posledného reštartu -- delená 60 000 pre prepočet na kWh | | `emeter/{i}/total` | Wh | Trvalá celková spotrebovaná energia -- prežije reštarty | Šablóna ukladá obe hodnoty: `Ed` (energia z topicu watt-minút, prepočítaná na kWh) a `To` (celková spotreba vo Wh z perzistentného topicu). > [!TIP] > Topic `energy` sa pri reštarte zariadenia vynuluje. Pre trvalé sledovanie energie šablóna číta aj topic `total`, ktorý prežije reštarty. Každý kanál tiež vystavuje servisný atribút **Napätie**, ktorý číta efektívne sieťové napätie z MQTT topicu `emeter/{i}/voltage`. > [!NOTE] > Skripty `readtotalconsumption` a `readdemand` sú zakomentované šablónové boilerplate -- všetky údaje o energii prichádzajú cez MQTT listener. To znamená, že šablóna **neposkytuje** okamžité odčítanie výkonu (W). Sleduje sa len kumulatívna energia (kWh) a celková spotreba (Wh). Okamžitý činný výkon je dostupný cez MQTT topic `emeter/{i}/power`, ale táto šablóna ho neodoberá. ### Stykačové relé Reléový výstup je v TapHome vystavený ako spínač. Relé je dimenzované na **2A / 230 VAC** -- je určené len na ovládanie stykača, nie na priame spínanie záťaže. - **Čítanie:** odoberá topic `shellies/shellyem-{id}/relay/0` -- payload `on` = zapnuté, `off` = vypnuté - **Zápis:** publikuje `on` alebo `off` do `shellies/shellyem-{id}/relay/0/command` > [!WARNING] > Relé je dimenzované len na 2A. Na záťaže prekračujúce tento limit vždy použite externý stykač. Priame pripojenie výkonových záťaží poškodí relé. ## Riešenie problémov ### Žiadne údaje o energii 1. Overte, že MQTT je aktivované vo webovom rozhraní Shelly (Internet & Security > Advanced — Developer Settings) 2. Skontrolujte, že adresa a port MQTT brokera sú správne v nastaveniach zariadenia Shelly aj modulu TapHome 3. Skontrolujte, že vlastná premenná **Device ID** presne zodpovedá Device ID zariadenia Shelly (napr. `B929CC`) 4. Pomocou MQTT klienta (napr. MQTT Explorer) odoberajte topic `shellies/#` a overte, že zariadenie publikuje topicy `emeter/0/energy` a `emeter/1/energy` ### Údaje len z jedného kanálu 1. Overte, že CT svorka je pripojená do správneho 3,5mm jacku (kanál 0 alebo kanál 1) 2. Skontrolujte, že meraným vodičom preteká prúd -- CT svorka musí obopínať jeden vodič, nie celý kábel 3. Samostatne odoberajte topicy `shellies/shellyem-{id}/emeter/0/#` a `shellies/shellyem-{id}/emeter/1/#` a overte, že oba kanály publikujú údaje ### Relé nereaguje 1. Skontrolujte, že Shelly EM je napájané a pripojené k MQTT brokeru 2. Manuálne publikujte `on` alebo `off` do `shellies/shellyem-{id}/relay/0/command` cez MQTT klienta a otestujte funkciu relé nezávisle od TapHome 3. Overte správne zapojenie reléového výstupu (skontrolujte označenie svoriek na zariadení) > [!WARNING] > Zariadenia Shelly Gen1 **nepodporujú** MQTT cez TLS. Komunikácia medzi zariadením a MQTT brokerom je nešifrovaná (plain MQTT, port 1883). Uistite sa, že MQTT broker je v dôveryhodnej lokálnej sieti. ## Ako nainštalovať v TapHome ### Predpoklady - Zariadenie Shelly pripojené k Wi-Fi (2,4 GHz), napr. cez aplikáciu Shelly alebo vlastný prístupový bod zariadenia - MQTT broker bežiaci vo vašej lokálnej sieti (napr. Mosquitto, Home Assistant alebo vstavaný broker TapHome) - TapHome CCU v rovnakej sieti ako broker > [!WARNING] > Na zariadeniach **Gen1** povolenie MQTT **vypne Shelly Cloud**. Oboje nemôže bežať súčasne. Na zariadeniach Gen2/Plus toto obmedzenie neplatí. ### Krok 1 — Povoľte MQTT na zariadení Shelly #### Zariadenia Gen1 (Shelly 1, 1PM, 2.5, EM, 3EM, Plug S, RGBW2, Dimmer, TRV…) 1. Otvorte webové rozhranie Shelly: `http:///` 2. Prejdite na **Internet & Security** → **Advanced — MQTT** 3. Povoľte **MQTT** 4. Nastavte **MQTT Server**: `:` (napr. `192.168.1.10:1883`) 5. Voliteľne nastavte **MQTT User** a **MQTT Password**, ak váš broker vyžaduje autentifikáciu 6. Kliknite na **Save** — zariadenie sa reštartuje a pripojí k brokeru #### Zariadenia Gen2 / Plus (Shelly Plus 1, Plus 1PM, Plus 2PM, Plus Plug S, Plus H&T, Pro 3EM…) 1. Otvorte webové rozhranie Shelly: `http:///` 2. Prejdite na **Settings** → **MQTT** 3. Povoľte **MQTT** 4. Nastavte **Server**: `:` (napr. `192.168.1.10:1883`) 5. **Client ID** je predvyplnené ID zariadenia (napr. `shellyplus1pm-AABBCCDDEE`) — ponechajte tak, pokiaľ nemáte konkrétny dôvod na zmenu 6. Kliknite na **Save** a reštartujte zariadenie Pri vstavanom brokeri TapHome je `` IP adresa TapHome Core. Dajte jednotke Core rezerváciu IP v routeri, inak zariadenie stratí broker, keď router adresu zmení → [Príprava siete](https://taphome.com/sk/docs/setup/network-preparation/). > [!TIP] > Na overenie funkčnosti MQTT použite MQTT klienta (napr. MQTT Explorer) a prihláste sa na odber `shellies/#` (Gen1) alebo `/#` (Gen2). Mali by ste vidieť stavové správy zo zariadenia. ### Krok 2 — Zistite Device ID / MQTT Client ID Niektoré šablóny vyžadujú parameter **Device ID** alebo **MQTT Client ID**. Ide o jedinečný identifikátor používaný v MQTT topicoch. - **Gen1:** nachádza sa na štítku ako MAC adresa (napr. `AABBCCDDEE`). Device ID = `shelly-`, napr. `shelly1pm-AABBCCDDEE` - **Gen2/Plus:** nachádza sa vo webovom rozhraní Shelly v časti **Settings** → **Device Info** → **Device ID**, alebo na štítku zariadenia ### Krok 3 — Konfigurácia v TapHome 1. V TapHome pridajte nový modul **Packet Parser (MQTT)** 2. **IP Address:** pre vstavaný broker TapHome `127.0.0.1` (jednotka sa pripája sama k sebe, adresa sa nikdy nezmení); pre externý broker jeho IP adresa (napr. `192.168.1.10`) 3. **Port:** `1883` (predvolený; pre TLS použite `8883`) 4. **Device ID / MQTT Client ID:** zadajte hodnotu z kroku 2 (ak to šablóna vyžaduje) 5. Importujte šablónu — TapHome sa automaticky prihlási na odber topicov zariadenia ## Dostupné zariadenia 3 Tieto zariadenia sa po importe zobrazia v TapHome. Shelly EM MQTT Modul Vlastné premenné `deviceID` (string) MQTT Device ID zariadenia Shelly EM — formát je 'shellyem-DEVICEID', kde DEVICEID je posledných 6 hex znakov MAC adresy (napr. B929CC) Open http://shellyIpAddress → Settings → Device Info → copy Device ID Elektromer - Kanál 1 Elektromer Len na čítanie Spotreba energie na CT svorke kanálu 1 -- kumulatívna energia (kWh) a celková spotreba (Wh) numeric Jednotka: kWh Servisné atribúty | | | |---------|---------------------------------------------------------------------| | Napätie | Efektívne napätie na kanáli 1 čítané z MQTT topicu emeter/0/voltage | Čítanie celkovej spotreby ```taphome # Simple HTTP Request: # VAR response := SENDHTTPREQUEST("/example/getValue"); # IF response.IsSuccess # VAR content := response.Content; # VAR responseHeaders := response.Headers; # RETURN(PARSEXML(content, "//element1/value1")); # ELSE # ADDERROR(response.StatusCode + " (" + response.ReasonPhrase + ")"); # RETURN(NaN); # END # # Set Http request method, body and headers # VAR response := SENDHTTPREQUEST("/example/getValue", "GET", "some data", "header1:value1", "header2:value2", ...); # OR # VAR request := HTTPREQUEST("/example/getValue", "POST", "some data"); # request.headers := { "header1:value1", "header2:value2", ...}; # request.method := "GET"; # request.data := null; # VAR response := SENDHTTPREQUEST(request); # # # Send TCP, UDP data: # VAR data1 := BYTECOLLECTION("0a bb ea df 01"); # SENDDATA(data1); # VAR data2 := "{\"name\":\"John\", \"age\":32}"; # SENDDATA(data2); # VAR data3 := TOBYTES("{\"name\":\"John\", \"age\":32}", "iso-8859-1"); # SENDDATA(data3); # Process received TCP or UDP data and set device values in the Listener script # # # Download data from FTP: # FTPDOWNLOAD("filePath"); ``` Čítanie odberu ```taphome # Simple HTTP Request: # VAR response := SENDHTTPREQUEST("/example/getValue"); # IF response.IsSuccess # VAR content := response.Content; # VAR responseHeaders := response.Headers; # RETURN(PARSEXML(content, "//element1/value1")); # ELSE # ADDERROR(response.StatusCode + " (" + response.ReasonPhrase + ")"); # RETURN(NaN); # END # # Set Http request method, body and headers # VAR response := SENDHTTPREQUEST("/example/getValue", "GET", "some data", "header1:value1", "header2:value2", ...); # OR # VAR request := HTTPREQUEST("/example/getValue", "POST", "some data"); # request.headers := { "header1:value1", "header2:value2", ...}; # request.method := "GET"; # request.data := null; # VAR response := SENDHTTPREQUEST(request); # # # Send TCP, UDP data: # VAR data1 := BYTECOLLECTION("0a bb ea df 01"); # SENDDATA(data1); # VAR data2 := "{\"name\":\"John\", \"age\":32}"; # SENDDATA(data2); # VAR data3 := TOBYTES("{\"name\":\"John\", \"age\":32}", "iso-8859-1"); # SENDDATA(data3); # Process received TCP or UDP data and set device values in the Listener script # # # Download data from FTP: # FTPDOWNLOAD("filePath"); ``` Listener ```taphome VAR whatEd := "shellies/shellyem-"+deviceID+"/emeter/0/energy"; VAR whatTo := "shellies/shellyem-"+deviceID+"/emeter/0/total"; IF (whatEd = RECEIVEDMSG.TOPIC) Ed := todouble(TOSTRING(RECEIVEDMSG.PAYLOAD))/60000; END IF (whatTo = RECEIVEDMSG.TOPIC) To := todouble(TOSTRING(RECEIVEDMSG.PAYLOAD)); END ``` Servisné atribúty Voltage \[V] ```taphome if parsejson(response, "Topic") = "shellies/shellyem-"+deviceID+"/emeter/0/voltage" return(todouble(parsejson(response, "Payload"))); end ``` Elektromer - Kanál 2 Elektromer Len na čítanie Spotreba energie na CT svorke kanálu 2 -- kumulatívna energia (kWh) a celková spotreba (Wh) numeric Jednotka: kWh Servisné atribúty | | | |---------|---------------------------------------------------------------------| | Napätie | Efektívne napätie na kanáli 2 čítané z MQTT topicu emeter/1/voltage | Čítanie celkovej spotreby ```taphome # Simple HTTP Request: # VAR response := SENDHTTPREQUEST("/example/getValue"); # IF response.IsSuccess # VAR content := response.Content; # VAR responseHeaders := response.Headers; # RETURN(PARSEXML(content, "//element1/value1")); # ELSE # ADDERROR(response.StatusCode + " (" + response.ReasonPhrase + ")"); # RETURN(NaN); # END # # Set Http request method, body and headers # VAR response := SENDHTTPREQUEST("/example/getValue", "GET", "some data", "header1:value1", "header2:value2", ...); # OR # VAR request := HTTPREQUEST("/example/getValue", "POST", "some data"); # request.headers := { "header1:value1", "header2:value2", ...}; # request.method := "GET"; # request.data := null; # VAR response := SENDHTTPREQUEST(request); # # # Send TCP, UDP data: # VAR data1 := BYTECOLLECTION("0a bb ea df 01"); # SENDDATA(data1); # VAR data2 := "{\"name\":\"John\", \"age\":32}"; # SENDDATA(data2); # VAR data3 := TOBYTES("{\"name\":\"John\", \"age\":32}", "iso-8859-1"); # SENDDATA(data3); # Process received TCP or UDP data and set device values in the Listener script # # # Download data from FTP: # FTPDOWNLOAD("filePath"); ``` Čítanie odberu ```taphome # Simple HTTP Request: # VAR response := SENDHTTPREQUEST("/example/getValue"); # IF response.IsSuccess # VAR content := response.Content; # VAR responseHeaders := response.Headers; # RETURN(PARSEXML(content, "//element1/value1")); # ELSE # ADDERROR(response.StatusCode + " (" + response.ReasonPhrase + ")"); # RETURN(NaN); # END # # Set Http request method, body and headers # VAR response := SENDHTTPREQUEST("/example/getValue", "GET", "some data", "header1:value1", "header2:value2", ...); # OR # VAR request := HTTPREQUEST("/example/getValue", "POST", "some data"); # request.headers := { "header1:value1", "header2:value2", ...}; # request.method := "GET"; # request.data := null; # VAR response := SENDHTTPREQUEST(request); # # # Send TCP, UDP data: # VAR data1 := BYTECOLLECTION("0a bb ea df 01"); # SENDDATA(data1); # VAR data2 := "{\"name\":\"John\", \"age\":32}"; # SENDDATA(data2); # VAR data3 := TOBYTES("{\"name\":\"John\", \"age\":32}", "iso-8859-1"); # SENDDATA(data3); # Process received TCP or UDP data and set device values in the Listener script # # # Download data from FTP: # FTPDOWNLOAD("filePath"); ``` Listener ```taphome VAR whatEd := "shellies/shellyem-"+deviceID+"/emeter/1/energy"; VAR whatTo := "shellies/shellyem-"+deviceID+"/emeter/1/total"; IF (whatEd = RECEIVEDMSG.TOPIC) Ed := todouble(TOSTRING(RECEIVEDMSG.PAYLOAD))/60000; END IF (whatTo = RECEIVEDMSG.TOPIC) To := todouble(TOSTRING(RECEIVEDMSG.PAYLOAD)); END ``` Servisné atribúty voltage \[V] ```taphome if parsejson(response, "Topic") = "shellies/shellyem-"+deviceID+"/emeter/1/voltage" return(parsejson(response, "Payload")); end ``` Stykačové relé Prepínač Čítanie aj zápis 2A reléový výstup na ovládanie stykača -- číta stav relay/0 a publikuje príkazy on/off boolean Hodnoty / Stavy: ON · OFF Čítanie stavu prepínača ```taphome # Simple HTTP Request: # VAR response := SENDHTTPREQUEST("/example/getValue"); # IF response.IsSuccess # VAR content := response.Content; # VAR responseHeaders := response.Headers; # RETURN(PARSEXML(content, "//element1/value1")); # ELSE # ADDERROR(response.StatusCode + " (" + response.ReasonPhrase + ")"); # RETURN(NaN); # END # # Set Http request method, body and headers # VAR response := SENDHTTPREQUEST("/example/getValue", "GET", "some data", "header1:value1", "header2:value2", ...); # OR # VAR request := HTTPREQUEST("/example/getValue", "POST", "some data"); # request.headers := { "header1:value1", "header2:value2", ...}; # request.method := "GET"; # request.data := null; # VAR response := SENDHTTPREQUEST(request); # # # Send TCP, UDP data: # VAR data1 := BYTECOLLECTION("0a bb ea df 01"); # SENDDATA(data1); # VAR data2 := "{\"name\":\"John\", \"age\":32}"; # SENDDATA(data2); # VAR data3 := TOBYTES("{\"name\":\"John\", \"age\":32}", "iso-8859-1"); # SENDDATA(data3); # Process received TCP or UDP data and set device values in the Listener script # # # Download data from FTP: # FTPDOWNLOAD("filePath"); ``` Zápis stavu prepínača ```taphome MQTTPUBLISH("shellies/shellyem-" + deviceID + "/relay/0/command",if(St = 1, "on","off")); # Simple HTTP Request: # VAR response := SENDHTTPREQUEST("/example/set/value=" + St); # IF response.IsSuccess = false # ADDERROR(response.StatusCode); # END # # Set Http request method, body and headers # VAR response := SENDHTTPREQUEST("/example/setValue", "GET", "value=" + St, "header1:value1", "header2:value2", ...);\r # Or VAR request := HTTPREQUEST("/example/setValue"); # request.Method := "PUT"; # VAR response := SENDHTTPREQUEST(request); #r # # Send TCP, UDP data: # VAR data1 := "{\"name\":\"John\", \"age\":" + St + "}"; # SENDDATA(data1); # VAR data2 := TOBYTES("{\"name\":\"John\", \"age\":" + St + "}", "iso-8859-1"); # SENDDATA(data2); # You can process received TCP or UDP data in the Listener script # # # Upload data to FTP: # FTPUPLOAD("filePath", "somedata=" + St, "write"); # use "append" mode to append data to existing file ``` Listener ```taphome VAR whatSt := "shellies/shellyem-"+deviceID+"/relay/0"; IF (whatSt = RECEIVEDMSG.TOPIC) IF (TOSTRING(RECEIVEDMSG.PAYLOAD) = "on") St := 1; ELSE St := 0; END END ``` **Pripojenie:** Packet Parser → MQTT • Hostname: `shellyem-{MAC}.local` Možné vylepšenia (5) - Active Power — Instantaneous active power in W per channel. Available via MQTT but template listener scripts do not subscribe to it — readdemand is commented-out boilerplate. - Reactive Power — Instantaneous reactive power in VAR per channel. Available via MQTT topic. - Total Energy Returned — Total energy returned to grid in Wh per channel. Useful for solar/bidirectional setups. - Connection Status — LWT topic — true on connect, false on disconnect. Could detect device offline state. - Reset Energy Data — Payload 'reset\_data' resets all accumulated energy counters on both channels. ## Parametre importu Tieto hodnoty zadáte pri importe XML. | Pýta sa v aplikácii | Predvolené | |-----------------------|--------------------| | Mqtt Broker IP adresa | `192.168.0.1` | | Mqtt Broker port | `1883` | | Device ID | Zadáte pri importe | ## Zdroje - Shelly Gen1 API Reference [shelly-api-docs.shelly.cloud](https://shelly-api-docs.shelly.cloud/gen1/) 2026-03-12 - Home Assistant Shelly Integration [www.home-assistant.io](https://www.home-assistant.io/integrations/shelly/) 2026-03-12 - Shelly EM — API Endpoints & MQTT Topics [shelly-api-docs.shelly.cloud](https://shelly-api-docs.shelly.cloud/gen1/#shelly-em) 2026-03-29 - Shelly EM — Product Specifications [robomaterial.com](https://robomaterial.com/product/shelly-em-single-phase-energy-meter-with-contactor-control/) 2026-03-29 ## Súvisiaca dokumentácia - [MQTT Integration](https://taphome.com/sk/compatibility/mqtt-guide/) - [Packet Parser (HTTP, TCP, UDP, FTP, MQTT)](https://taphome.com/sk/docs/integration/packet-parser/) - [Funkcie Packet parsera](https://taphome.com/sk/docs/script/packet-parser/) - [Parsovacie funkcie](https://taphome.com/sk/docs/script/parsing-functions/) - [MQTT broker](https://taphome.com/sk/docs/integration/packet-parser/mqtt-broker/) - [Listener skripty](https://taphome.com/sk/docs/script/listener-scripts/)