<![CDATA[Forum KNX francophone / English KNX forum - Logiciels libres (linknx, knxweb, pKNyX,...)]]> https://www.knx-fr.com/ Mon, 26 Oct 2026 09:27:46 +0000 MyBB <![CDATA[Zehnder ComfoConnect PRO et Home Assistant]]> https://www.knx-fr.com/showthread.php?tid=16476 Tue, 20 Oct 2026 08:08:58 +0000 NicNac]]> https://www.knx-fr.com/showthread.php?tid=16476
 Zehnder ComfoConnect PRO mais via un modbus.

Chez moi, le module est connecté KNX.

Comment éventuellement passer aussi par un modbus ?]]>
 Zehnder ComfoConnect PRO mais via un modbus.

Chez moi, le module est connecté KNX.

Comment éventuellement passer aussi par un modbus ?]]> <![CDATA[[Projet] Une stack KNX TP1 open source pour Zephyr RTOS + carte KnxBoard]]> https://www.knx-fr.com/showthread.php?tid=16452 Sun, 20 Sep 2026 10:19:40 +0000 condo4]]> https://www.knx-fr.com/showthread.php?tid=16452
Je voulais partager un projet sur lequel je travaille depuis plusieurs années : une implémentation du protocole KNX (TP1, mode S, System B — masque 07B0h) en pure C, principalement pour STM332, mais pas que...
Après plusieurs années et différent essais j'ai choisi de le porter sur Zephyr RTOS.
J'ai aussi fait une carte électronique open hardware qui va avec.

Pourquoi ce projet ?

Il n'existait pas, à ma connaissance, de stack KNX correctement intégrée à un OS temps réel open source comme Zephyr.
Je n'avais trouver que la stack C++ Thelsing, surtout orienté Arduino, et, difficilement portable sur n'importe quel environnement.

L'objectif est de fournir une base solide, testée, et surtout générique — pas liée à un produit ou un capteur en particulier — qui puisse à terme être proposée en amont (mainline) dans Zephyr.

Ce que ça couvre

- La stack protocolaire complète : couches Liaison de données, Réseau, Transport (machine à états Style 3 complète) et Application (21 services APDU), les objets d'interface System B, les Datapoint Types courants, et la persistance mémoire compatible avec le modèle de téléchargement ETS.
- Le driver pour le transceiver onsemi NCN5130 (liaison UART 9 bits).
- Un driver de "loopback" logiciel, pratique pour faire tourner et tester la stack sans bus KNX physique.
- Une suite de tests unitaires (8 suites, exécutables sans matériel).


La carte : KnxBoard

En parallèle, j'ai conçu KnxBoard, une carte STM32G4 + NCN5130 pensée comme une "carte de base" générique (un peu à la manière d'un Arduino) : elle ne fait que parler KNX TP1, et on vient y greffer une "carte plus simple" (daughterboard) selon le produit voulu — j'ai deux exemples fonctionnels : une sonde 1-Wire (DS18B20) et une sonde PT100.

Schémas, PCB et documentation matérielle sont sur GitHub : (Projet Kicad)

J'ai fait des PCBA sur JLCPCB, ce qui revient autour de 30€ la carte par 5 exemplaires, (PCB + Composant + Assamblage)
Je referais un nouveau prototype prochainement, j'ai une V6 dans les tuyaux avec quelque léger changement, mais la V5 fonctionne parfaitement.

https://github.com/condo4/knxboard

Je posterais prochainement les daughterboard et des photos

Où en est-on ?

Un téléchargement partiel ETS fonctionne de bout en bout sur la carte réelle, et toute la stack est couverte par des tests. Mais — et c'est important de le dire clairement : ce n'est pas une stack certifiée KNX, elle n'implémente pas KNX Data Secure, et je ne donne aucune garantie de conformité totale au protocole au-delà de ce qui a été testé sur banc. C'est un point de départ robuste, pas un produit fini.

Et maintenant ?

Le code est en cours de préparation pour une proposition d'intégration à Zephyr. N'hésitez pas à jeter un œil, tester, remonter des retours ou contribuer — toute aide est la bienvenue, que ce soit sur la stack, le hardware, ou les tests de conformité avec de vrais produits KNX du marché.

En attendant les corrections et la finalisation de la PR, le code est déjà dispo sur
https://github.com/condo4/zephyr/tree/de...x-protocol

Merci de votre lecture, et n'hésitez pas si vous avez des questions !]]>
Je voulais partager un projet sur lequel je travaille depuis plusieurs années : une implémentation du protocole KNX (TP1, mode S, System B — masque 07B0h) en pure C, principalement pour STM332, mais pas que...
Après plusieurs années et différent essais j'ai choisi de le porter sur Zephyr RTOS.
J'ai aussi fait une carte électronique open hardware qui va avec.

Pourquoi ce projet ?

Il n'existait pas, à ma connaissance, de stack KNX correctement intégrée à un OS temps réel open source comme Zephyr.
Je n'avais trouver que la stack C++ Thelsing, surtout orienté Arduino, et, difficilement portable sur n'importe quel environnement.

L'objectif est de fournir une base solide, testée, et surtout générique — pas liée à un produit ou un capteur en particulier — qui puisse à terme être proposée en amont (mainline) dans Zephyr.

Ce que ça couvre

- La stack protocolaire complète : couches Liaison de données, Réseau, Transport (machine à états Style 3 complète) et Application (21 services APDU), les objets d'interface System B, les Datapoint Types courants, et la persistance mémoire compatible avec le modèle de téléchargement ETS.
- Le driver pour le transceiver onsemi NCN5130 (liaison UART 9 bits).
- Un driver de "loopback" logiciel, pratique pour faire tourner et tester la stack sans bus KNX physique.
- Une suite de tests unitaires (8 suites, exécutables sans matériel).


La carte : KnxBoard

En parallèle, j'ai conçu KnxBoard, une carte STM32G4 + NCN5130 pensée comme une "carte de base" générique (un peu à la manière d'un Arduino) : elle ne fait que parler KNX TP1, et on vient y greffer une "carte plus simple" (daughterboard) selon le produit voulu — j'ai deux exemples fonctionnels : une sonde 1-Wire (DS18B20) et une sonde PT100.

Schémas, PCB et documentation matérielle sont sur GitHub : (Projet Kicad)

J'ai fait des PCBA sur JLCPCB, ce qui revient autour de 30€ la carte par 5 exemplaires, (PCB + Composant + Assamblage)
Je referais un nouveau prototype prochainement, j'ai une V6 dans les tuyaux avec quelque léger changement, mais la V5 fonctionne parfaitement.

https://github.com/condo4/knxboard

Je posterais prochainement les daughterboard et des photos

Où en est-on ?

Un téléchargement partiel ETS fonctionne de bout en bout sur la carte réelle, et toute la stack est couverte par des tests. Mais — et c'est important de le dire clairement : ce n'est pas une stack certifiée KNX, elle n'implémente pas KNX Data Secure, et je ne donne aucune garantie de conformité totale au protocole au-delà de ce qui a été testé sur banc. C'est un point de départ robuste, pas un produit fini.

Et maintenant ?

Le code est en cours de préparation pour une proposition d'intégration à Zephyr. N'hésitez pas à jeter un œil, tester, remonter des retours ou contribuer — toute aide est la bienvenue, que ce soit sur la stack, le hardware, ou les tests de conformité avec de vrais produits KNX du marché.

En attendant les corrections et la finalisation de la PR, le code est déjà dispo sur
https://github.com/condo4/zephyr/tree/de...x-protocol

Merci de votre lecture, et n'hésitez pas si vous avez des questions !]]> <![CDATA[KNX Stack - C++ Code ESP32 pour l'IDE Arduino]]> https://www.knx-fr.com/showthread.php?tid=16449 Tue, 15 Sep 2026 17:42:23 +0000 Smart Guido 73]]> https://www.knx-fr.com/showthread.php?tid=16449
Je souhaite mettre à votre disposition ce code qui permet de communiquer avec KNX sur un ESP32 sans aucune bibliothèque supplémentaire. Il peut aussi bien envoyer que recevoir les télégrammes les plus courants.

Code :
#include <WiFi.h>
#include <WiFiUdp.h>
#include <WebServer.h>
#include <time.h>


const char* projectName  = "KNX Stack";

const char* ssid         = "WLAN SSID";
const char* password     = "WLAN Passwort";

const char* ntpServer    = "pool.ntp.org";
const char* tzInfo       = "CET-1CEST,M3.5.0,M10.5.0/3";

const char* knxGatewayIp = "IP KNX Gateway";
const uint16_t knxPort   = 3671;
const uint16_t localPort = 3671;

WiFiUDP udp;
WebServer server(80);

uint8_t knxChannelId     = 0;
uint8_t txSeqNum         = 0;
bool isKnxConnected      = false;

unsigned long lastHeartbeat = 0;
const unsigned long HEARTBEAT_INTERVAL = 60000;
const unsigned long ACK_TIMEOUT        = 1000;

#define KNX_LOG_SIZE 10
struct KnxLogEntry {
  char timeStr[24];
  uint16_t ga;
  uint8_t data[16];
  uint8_t len;
};

KnxLogEntry knxLog[KNX_LOG_SIZE];
int knxLogNext = 0;
int knxLogFilled = 0;

void hexDump(const char* label, const uint8_t* buf, int len) {
  Serial.printf("%s [%d Bytes]: ", label, len);
  for (int i = 0; i < len; i++) {
    Serial.printf("%02X ", buf[i]);
  }
  Serial.println();
}

const char* knxStatusToString(uint8_t status) {
  switch (status) {
    case 0x00: return "E_NO_ERROR";
    case 0x01: return "E_HOST_PROTOCOL_TYPE";
    case 0x02: return "E_VERSION_NOT_SUPPORTED";
    case 0x04: return "E_SEQUENCE_NUMBER (Sequenznummer falsch/ausser Sync)";
    case 0x21: return "E_CONNECTION_ID (unbekannte Channel ID)";
    case 0x22: return "E_CONNECTION_TYPE";
    case 0x23: return "E_CONNECTION_OPTION";
    case 0x24: return "E_NO_MORE_CONNECTIONS (Gateway voll)";
    case 0x26: return "E_DATA_CONNECTION";
    case 0x27: return "E_KNX_CONNECTION";
    case 0x29: return "E_TUNNELING_LAYER (nicht unterstuetzt)";
    default:   return "Unbekannter Statuscode";
  }
}

String getFormattedDateTime() {
  struct tm timeinfo;
  if (!getLocalTime(&timeinfo, 100)) {
    return "Zeit nicht synchronisiert";
  }
  char buf[32];
  strftime(buf, sizeof(buf), "%d.%m.%Y %H:%M:%S", &timeinfo);
  return String(buf);
}

uint16_t parseGroupAddress(const String& gaStr) {
  int firstSlash  = gaStr.indexOf('/');
  int secondSlash = gaStr.indexOf('/', firstSlash + 1);
  if (firstSlash == -1 || secondSlash == -1) return 0;

  uint8_t main   = gaStr.substring(0, firstSlash).toInt();
  uint8_t middle = gaStr.substring(firstSlash + 1, secondSlash).toInt();
  uint8_t sub    = gaStr.substring(secondSlash + 1).toInt();

  return ((main & 0x1F) << 11) | ((middle & 0x07) << 8) | (sub & 0xFF);
}

String gaToString(uint16_t ga) {
  uint8_t main   = (ga >> 11) & 0x1F;
  uint8_t middle = (ga >> 8) & 0x07;
  uint8_t sub    = ga & 0xFF;
  return String(main) + "/" + String(middle) + "/" + String(sub);
}

uint16_t floatToDpt9(float val) {
  int sign = (val < 0) ? 1 : 0;
  float v = (sign == 1) ? -val : val;
  int exp = 0;
  int mantissa = (int)(v * 100.0f);
  while (mantissa > 2047) {
    mantissa >>= 1;
    exp++;
  }
  if (sign == 1) {
    mantissa = -mantissa;
    mantissa &= 0x07FF;
  }
  return (sign << 15) | ((exp & 0x0F) << 11) | (mantissa & 0x07FF);
}

float dpt9ToFloat(uint8_t hi, uint8_t lo) {
  uint16_t raw = ((uint16_t)hi << 8) | lo;
  int sign = (raw >> 15) & 0x01;
  int exp  = (raw >> 11) & 0x0F;
  int mantissa11 = raw & 0x07FF;
  int M = mantissa11 - (sign ? 2048 : 0);
  return 0.01f * M * (float)(1 << exp);
}

void floatToDpt14Bytes(float val, uint8_t* out4) {
  uint8_t* p = (uint8_t*)&val;
  out4[0] = p[3];
  out4[1] = p[2];
  out4[2] = p[1];
  out4[3] = p[0];
}

float dpt14ToFloat(uint8_t b0, uint8_t b1, uint8_t b2, uint8_t b3) {
  uint8_t bytes[4] = { b3, b2, b1, b0 };
  float f;
  memcpy(&f, bytes, 4);
  return f;
}

String apciTypeStr(uint8_t apciByte) {
  switch (apciByte & 0xC0) {
    case 0x00: return "Read";
    case 0x40: return "Response";
    case 0x80: return "Write";
    default:   return "?";
  }
}

String interpretKnxData(uint8_t* data, uint8_t len) {
  String prefix = "[" + apciTypeStr(data[0]) + "] ";

  if (len == 1) {
    bool bitVal = data[0] & 0x01;
    return prefix + "DPT1: " + (bitVal ? "EIN (1)" : "AUS (0)");
  }
  else if (len == 2) {
    return prefix + "DPT5: " + String(data[1]) + " (0..255)";
  }
  else if (len == 3) {
    float f = dpt9ToFloat(data[1], data[2]);
    return prefix + "DPT9: " + String(f, 2);
  }
  else if (len == 4) {
    uint8_t h = data[1] & 0x1F, mnt = data[2] & 0x3F, s = data[3] & 0x3F;
    uint8_t day = data[1] & 0x1F, month = data[2] & 0x0F, year = data[3] & 0x7F;
    char buf[80];
    snprintf(buf, sizeof(buf), "DPT10 Zeit : %02d:%02d:%02d  /  DPT11 Datum : %02d.%02d.20%02d",
             h, mnt, s, day, month, year);
    return prefix + String(buf);
  }
  else if (len == 5) {
    float f = dpt14ToFloat(data[1], data[2], data[3], data[4]);
    return prefix + "DPT14: " + String(f, 3);
  }
  else if (len == 15) {
    char txt[15];
    for (int i = 0; i < 14; i++) {
      uint8_t c = data[1 + i];
      txt[i] = (c >= 32 && c < 127) ? (char)c : (c == 0 ? 0 : '.');
    }
    txt[14] = 0;
    return prefix + "DPT16: \"" + String(txt) + "\"";
  }
  return prefix + "Unbekannt (" + String(len) + " Byte)";
}

void addKnxLogEntry(uint16_t ga, uint8_t* rxBuf, uint8_t npduLen) {
  KnxLogEntry &e = knxLog[knxLogNext];
  String t = getFormattedDateTime();
  strncpy(e.timeStr, t.c_str(), sizeof(e.timeStr) - 1);
  e.timeStr[sizeof(e.timeStr) - 1] = 0;
  e.ga = ga;
  uint8_t copyLen = npduLen;
  if (copyLen > sizeof(e.data)) copyLen = sizeof(e.data);
  memcpy(e.data, &rxBuf[20], copyLen);
  e.len = copyLen;

  knxLogNext = (knxLogNext + 1) % KNX_LOG_SIZE;
  if (knxLogFilled < KNX_LOG_SIZE) knxLogFilled++;
}

uint16_t processIncomingPacket(uint8_t* rxBuf, int len) {
  if (len < 6) return 0;
  uint16_t serviceType = (rxBuf[2] << 8) | rxBuf[3];
  hexDump("[KNX RX]", rxBuf, len);

  switch (serviceType) {
    case 0x0421:
      if (len >= 10) {
        Serial.printf("   -> TUNNELING_ACK | Channel : %d | Seq : %d | Status : 0x%02X (%s)\n",
                      rxBuf[7], rxBuf[8], rxBuf[9], knxStatusToString(rxBuf[9]));
      }
      break;

    case 0x0420:
      if (len >= 21) {
        uint8_t rxChannel = rxBuf[7];
        uint8_t rxSeqNum  = rxBuf[8];
        uint16_t ga = ((uint16_t)rxBuf[16] << 8) | rxBuf[17];
        uint8_t npduLen = rxBuf[18];
        Serial.printf("   -> TUNNELING_REQUEST (Bus Telegramm) | Channel : %d | Seq : %d | GA : %s\n",
                      rxChannel, rxSeqNum, gaToString(ga).c_str());
        Serial.println("      " + interpretKnxData(&rxBuf[20], npduLen));

        if (rxChannel == knxChannelId) {
          addKnxLogEntry(ga, rxBuf, npduLen);

          uint8_t ackBuf[10] = {
            0x06, 0x10, 0x04, 0x21, 0x00, 0x0A, 0x04, knxChannelId, rxSeqNum, 0x00
          };
          udp.beginPacket(knxGatewayIp, knxPort);
          udp.write(ackBuf, sizeof(ackBuf));
          udp.endPacket();
          hexDump("[KNX TX] ACK an Bus Telegramm", ackBuf, sizeof(ackBuf));
        }
      }
      break;

    case 0x0208:
      if (len >= 8) {
        Serial.printf("   -> CONNECTIONSTATE_RESPONSE | Status : 0x%02X (%s)\n", rxBuf[7], knxStatusToString(rxBuf[7]));
        if (rxBuf[7] != 0x00) {
          Serial.println("   !!! Heartbeat fehlgeschlagen -> Tunnel als getrennt markiert !!!");
          isKnxConnected = false;
        }
      }
      break;

    case 0x0209:
      if (len >= 8) {
        uint8_t rxChannel = rxBuf[6];
        Serial.printf("   -> DISCONNECT_REQUEST vom Gateway | Channel: %d\n", rxChannel);
        if (rxChannel == knxChannelId) {
          uint8_t discResp[8] = { 0x06, 0x10, 0x02, 0x0A, 0x00, 0x08, knxChannelId, 0x00 };
          udp.beginPacket(knxGatewayIp, knxPort);
          udp.write(discResp, sizeof(discResp));
          udp.endPacket();
          hexDump("[KNX TX] DISCONNECT_RESPONSE", discResp, sizeof(discResp));
          isKnxConnected = false;
        }
      }
      break;

    default:
      Serial.printf("   -> Unbehandelter ServiceType: 0x%04X\n", serviceType);
      break;
  }
  return serviceType;
}

bool connectKnx() {
  Serial.println("[KNX] Sende CONNECT_REQUEST an Gateway...");

  IPAddress myIp = WiFi.localIP();
  Serial.printf("   Lokale IP/Port die wir dem Gateway melden : %s:%d\n", myIp.toString().c_str(), localPort);
  Serial.printf("   Ziel Gateway: %s:%d\n", knxGatewayIp, knxPort);

  uint8_t connReq[] = {
    0x06, 0x10, 0x02, 0x05, 0x00, 0x1A,
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF),
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF),
    0x04, 0x04, 0x02, 0x00
  };
  hexDump("[KNX TX] CONNECT_REQUEST", connReq, sizeof(connReq));

  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(connReq, sizeof(connReq));
  udp.endPacket();

  unsigned long start = millis();
  while (millis() - start < 2000) {
    int size = udp.parsePacket();
    if (size >= 8) {
      uint8_t resp[32];
      int rlen = udp.read(resp, sizeof(resp));
      hexDump("[KNX RX] CONNECT_RESPONSE", resp, rlen);

      if (resp[2] == 0x02 && resp[3] == 0x06) {
        if (resp[7] == 0x00) {
          knxChannelId = resp[6];
          txSeqNum = 0;
          isKnxConnected = true;
          lastHeartbeat = millis();
          Serial.printf("ERFOLGREICH! Channel ID : %d\n", knxChannelId);

          if (rlen >= 16 && resp[8] == 0x08) {
            IPAddress dataIp(resp[10], resp[11], resp[12], resp[13]);
            uint16_t dataPort = (resp[14] << 8) | resp[15];
            Serial.printf("   [Info] Gateway Data-Endpoint laut CONNECT_RESPONSE: %s:%d\n",
                          dataIp.toString().c_str(), dataPort);
          }
          return true;
        } else {
          Serial.printf("FEHLER! Status Code: 0x%02X (%s)\n", resp[7], knxStatusToString(resp[7]));
          return false;
        }
      }
    }
    delay(10);
  }
  Serial.println("TIMEOUT! Keine CONNECT_RESPONSE vom Gateway erhalten.");
  isKnxConnected = false;
  return false;
}

void sendConnectionStateRequest() {
  IPAddress myIp = WiFi.localIP();
  uint8_t req[16] = {
    0x06, 0x10, 0x02, 0x07, 0x00, 0x10,
    knxChannelId, 0x00,
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF)
  };
  hexDump("[KNX TX] CONNECTIONSTATE_REQUEST (Heartbeat)", req, sizeof(req));
  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(req, sizeof(req));
  udp.endPacket();
}

void disconnectKnx() {
  if (!isKnxConnected) return;
  IPAddress myIp = WiFi.localIP();
  uint8_t req[16] = {
    0x06, 0x10, 0x02, 0x09, 0x00, 0x10,
    knxChannelId, 0x00,
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF)
  };
  hexDump("[KNX TX] DISCONNECT_REQUEST", req, sizeof(req));
  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(req, sizeof(req));
  udp.endPacket();
  isKnxConnected = false;
}

void handleKnxRx() {
  int packetSize = udp.parsePacket();
  if (packetSize <= 0) return;
  uint8_t rxBuf[64];
  int len = udp.read(rxBuf, sizeof(rxBuf));
  processIncomingPacket(rxBuf, len);
}

bool sendKnxValue(String groupAddress, String dptType, String rawValue) {
  if (!isKnxConnected) {
    if (!connectKnx()) return false;
  }

  uint16_t ga = parseGroupAddress(groupAddress);
  uint8_t buf[64];
  uint8_t payloadLen = 0;

  buf[0] = 0x06; buf[1] = 0x10;
  buf[2] = 0x04; buf[3] = 0x20;
  buf[4] = 0x00; buf[5] = 0x00;

  buf[6] = 0x04;
  buf[7] = knxChannelId;
  buf[8] = txSeqNum;
  buf[9] = 0x00;

  buf[10] = 0x11;
  buf[11] = 0x00;
  buf[12] = 0xBC;
  buf[13] = 0xE0;
  buf[14] = 0x00; buf[15] = 0x00;
  buf[16] = (uint8_t)(ga >> 8);
  buf[17] = (uint8_t)(ga & 0xFF);

  if (dptType == "DPT1") {
    buf[18] = 0x01;
    buf[19] = 0x00;
    buf[20] = (rawValue.toInt() > 0) ? 0x81 : 0x80;
    payloadLen = 21;
  }
  else if (dptType == "DPT5") {
    buf[18] = 0x02;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)rawValue.toInt();
    payloadLen = 22;
  }
  else if (dptType == "DPT9") {
    uint16_t dpt9Val = floatToDpt9(rawValue.toFloat());
    buf[18] = 0x03;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)(dpt9Val >> 8);
    buf[22] = (uint8_t)(dpt9Val & 0xFF);
    payloadLen = 23;
  }
  else if (dptType == "DPT10") {
    int h = 0, m = 0, s = 0;
    int c1 = rawValue.indexOf(':');
    if (c1 == -1) {
      h = rawValue.toInt();
    } else {
      h = rawValue.substring(0, c1).toInt();
      int c2 = rawValue.indexOf(':', c1 + 1);
      if (c2 == -1) {
        m = rawValue.substring(c1 + 1).toInt();
      } else {
        m = rawValue.substring(c1 + 1, c2).toInt();
        s = rawValue.substring(c2 + 1).toInt();
      }
    }
    buf[18] = 0x04;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)(h & 0x1F);
    buf[22] = (uint8_t)(m & 0x3F);
    buf[23] = (uint8_t)(s & 0x3F);
    payloadLen = 24;
  }
  else if (dptType == "DPT11") {
    int day = 1, month = 1, year = 26;
    int p1 = rawValue.indexOf('.');
    if (p1 != -1) {
      day = rawValue.substring(0, p1).toInt();
      int p2 = rawValue.indexOf('.', p1 + 1);
      if (p2 != -1) {
        month = rawValue.substring(p1 + 1, p2).toInt();
        int y = rawValue.substring(p2 + 1).toInt();
        year = (y >= 2000) ? (y - 2000) : y;
      }
    } else {
      day = rawValue.toInt();
    }
    buf[18] = 0x04;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)(day & 0x1F);
    buf[22] = (uint8_t)(month & 0x0F);
    buf[23] = (uint8_t)(year & 0x7F);
    payloadLen = 24;
  }
  else if (dptType == "DPT14") {
    uint8_t db[4];
    floatToDpt14Bytes(rawValue.toFloat(), db);
    buf[18] = 0x05;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = db[0];
    buf[22] = db[1];
    buf[23] = db[2];
    buf[24] = db[3];
    payloadLen = 25;
  }
  else if (dptType == "DPT16") {
    uint8_t strLen = rawValue.length();
    if (strLen > 14) strLen = 14;

    buf[18] = 15;
    buf[19] = 0x00;
    buf[20] = 0x80;
    for (int i = 0; i < 14; i++) {
      buf[21 + i] = (i < strLen) ? rawValue[i] : 0x00;
    }
    payloadLen = 21 + 14;
  }
  else {
    Serial.println("[KNX TX] FEHLER - Unbekannter DPT Typ!");
    return false;
  }

  buf[5] = payloadLen;

  Serial.printf("[KNX TX] GA: %s (0x%04X) | DPT: %s | Val: %s | Seq: %d\n",
                groupAddress.c_str(), ga, dptType.c_str(), rawValue.c_str(), txSeqNum);
  hexDump("[KNX TX] TUNNELING_REQUEST", buf, payloadLen);

  uint8_t sentSeq = txSeqNum;

  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(buf, payloadLen);
  udp.endPacket();

  txSeqNum++;

  unsigned long waitStart = millis();
  bool ackOk = false;
  while (millis() - waitStart < ACK_TIMEOUT) {
    int packetSize = udp.parsePacket();
    if (packetSize > 0) {
      uint8_t rxBuf[64];
      int len = udp.read(rxBuf, sizeof(rxBuf));
      uint16_t st = processIncomingPacket(rxBuf, len);
      if (st == 0x0421 && len >= 9 && rxBuf[8] == sentSeq) {
        ackOk = (len >= 10 && rxBuf[9] == 0x00);
        break;
      }
    }
    delay(5);
  }

  if (!ackOk) {
    Serial.println("!!! KEIN passendes TUNNELING_ACK erhalten (Timeout nach 1000ms) !!!");
  }

  return ackOk;
}

String escapeJson(String s) {
  String out;
  for (size_t i = 0; i < s.length(); i++) {
    char c = s[i];
    if (c == '"' || c == '\\') out += '\\';
    out += c;
  }
  return out;
}

void handleRoot() {
  String html = "<html><head><meta charset='UTF-8'>";
  html += "<title>" + String(projectName) + "</title>";
  html += "<style>body{font-family:Arial,sans-serif;margin:20px;background:#f4f4f9;color:#333}";
  html += ".card{background:#fff;padding:20px;border-radius:8px;box-shadow:0 2px 5px rgba(0,0,0,0.1);max-width:650px;margin:auto}";
  html += "h1{text-align:center;margin-bottom:2px;}";
  html += "#dtNow{text-align:center;color:#666;margin-top:0;margin-bottom:16px;font-size:14px;}";
  html += "input,select,button{width:100%;padding:10px;margin:10px 0;box-sizing:border-box;border:1px solid #ccc;border-radius:4px;font-size:16px}";
  html += "button{background:#007bff;color:#fff;font-weight:bold;border:none;cursor:pointer}button:hover{background:#0056b3}";
  html += "#statusMsg{margin-top:10px;font-weight:bold;color:#28a745;text-align:center;}";
  html += "table{width:100%;border-collapse:collapse;font-size:13px;margin-top:10px;}";
  html += "th,td{border-bottom:1px solid #eee;padding:6px 4px;text-align:left;}";
  html += "th{background:#f0f0f5;}";
  html += "</style></head><body>";

  html += "<div class='card'>";
  html += "<h1>" + String(projectName) + "</h1>";
  html += "<p id='dtNow'>...</p>";
  html += "<p>KNX Status: <span id='knxStatus'>" + String(isKnxConnected ? "<b style='color:green;'>Verbunden (Channel " + String(knxChannelId) + ")" : "Getrennt") + "";

  html += "<label>Gruppenadresse (z.B. 1/0/0):</label>";
  html += "<input type='text' id='ga' value='1/0/0'>";

  html += "<label>Datenpunkttyp (DPT):</label>";
  html += "<select id='dpt'>";
  html += "<option value='DPT1'>DPT 1 (1 Bit Schalten 0/1)</option>";
  html += "<option value='DPT5'>DPT 5 (1 Byte Wert 0..255)</option>";
  html += "<option value='DPT9'>DPT 9 (2 Byte Float Temp/Wert)</option>";
  html += "<option value='DPT10'>DPT 10 (Zeit, z.B. 14:30:00)</option>";
  html += "<option value='DPT11'>DPT 11 (Datum, z.B. 24.12.26)</option>";
  html += "<option value='DPT14'>DPT 14 (4 Byte Float IEEE754)</option>";
  html += "<option value='DPT16'>DPT 16 (14 Byte Text)</option>";
  html += "</select>";

  html += "<label>Wert / Payload:</label>";
  html += "<input type='text' id='val' value='1' placeholder='z.B. 1, 128, 21.5, 14:30:00, 24.12.26 oder Text'>";

  html += "<button type='button' onclick='sendTelegram()'>KNX Telegramm Senden</button>";
  html += "<button type='button' onclick='reconnectKnx()' style='background:#6c757d;'>KNX Reconnect</button>";
  html += "<div id='statusMsg'></div>";

  html += "<h3>Letzte empfangene Telegramme</h3>";
  html += "<table><thead><tr><th>Zeit</th><th>GA</th><th>Bytes</th><th>Hex</th><th>Wert</th></tr></thead>";
  html += "<tbody id='logBody'>Lade...</td></tr></tbody></table>";

  html += "</div>";

  html += "<script>";
  html += "function sendTelegram(){";
  html += "  var ga = document.getElementById('ga').value;";
  html += "  var dpt = document.getElementById('dpt').value;";
  html += "  var val = document.getElementById('val').value;";
  html += "  document.getElementById('statusMsg').innerText = 'Sende...';";
  html += "  fetch('/send?ga=' + encodeURIComponent(ga) + '&dpt=' + encodeURIComponent(dpt) + '&val=' + encodeURIComponent(val))";
  html += "  .then(response => response.text())";
  html += "  .then(data => { document.getElementById('statusMsg').innerText = data; })";
  html += "  .catch(err => { document.getElementById('statusMsg').innerText = 'Fehler beim Senden!'; });";
  html += "}";
  html += "function reconnectKnx(){";
  html += "  fetch('/reconnect').then(r=>r.text()).then(d=>{ updateStatus(); });";
  html += "}";
  html += "function updateStatus(){";
  html += "  fetch('/status').then(r=>r.json()).then(d=>{";
  html += "    document.getElementById('dtNow').innerText = d.datetime;";
  html += "    document.getElementById('knxStatus').innerHTML = d.connected ? (\"<b style='color:green;'>Verbunden (Channel \" + d.channel + \")</b>\") : \"<b style='color:red;'>Getrennt</b>\";";
  html += "    var rows = '';";
  html += "    d.log.forEach(function(e){ rows += '<tr><td>'+e.time+'</td><td>'+e.ga+'</td><td>'+e.len+'</td><td>'+e.hex+'</td><td>'+e.value+'</td></tr>'; });";
  html += "    document.getElementById('logBody').innerHTML = rows || '<tr><td colspan=5>Noch keine Telegramme empfangen</td></tr>';";
  html += "  }).catch(function(){});";
  html += "}";
  html += "setInterval(updateStatus, 1000);";
  html += "updateStatus();";
  html += "</script>";

  html += "</body></html>";
  server.send(200, "text/html", html);
}

void handleSend() {
  if (server.hasArg("ga") && server.hasArg("dpt") && server.hasArg("val")) {
    String ga = server.arg("ga");
    String dpt = server.arg("dpt");
    String val = server.arg("val");

    bool ok = sendKnxValue(ga, dpt, val);
    server.send(200, "text/plain", ok ? "Telegramm gesendet und per ACK bestaetigt!" : "Gesendet, aber KEIN ACK erhalten, siehe Serial Monitor!");
  } else {
    server.send(400, "text/plain", "Fehlende Parameter!");
  }
}

void handleReconnect() {
  connectKnx();
  server.send(200, "text/plain", "Reconnected!");
}

void handleStatus() {
  String json = "{";
  json += "\"project\":\"" + escapeJson(String(projectName)) + "\",";
  json += "\"datetime\":\"" + escapeJson(getFormattedDateTime()) + "\",";
  json += "\"connected\":" + String(isKnxConnected ? "true" : "false") + ",";
  json += "\"channel\":" + String(knxChannelId) + ",";
  json += "\"log\":[";

  for (int i = 0; i < knxLogFilled; i++) {
    int idx = (knxLogNext - 1 - i + KNX_LOG_SIZE) % KNX_LOG_SIZE;
    KnxLogEntry &e = knxLog[idx];

    String hex = "";
    for (int b = 0; b < e.len; b++) {
      char hb[4];
      snprintf(hb, sizeof(hb), "%02X ", e.data[b]);
      hex += hb;
    }
    hex.trim();

    if (i > 0) json += ",";
    json += "{";
    json += "\"time\":\"" + escapeJson(String(e.timeStr)) + "\",";
    json += "\"ga\":\"" + escapeJson(gaToString(e.ga)) + "\",";
    json += "\"len\":" + String(e.len) + ",";
    json += "\"hex\":\"" + escapeJson(hex) + "\",";
    json += "\"value\":\"" + escapeJson(interpretKnxData(e.data, e.len)) + "\"";
    json += "}";
  }
  json += "]}";
  server.send(200, "application/json", json);
}

void setup() {
  Serial.begin(115200);
  delay(1000);

  Serial.printf("\n===> %s <===\n", projectName);

  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("\nWLAN Verbunden!");
  Serial.print("IP Adresse - "); Serial.println(WiFi.localIP());
  Serial.print("RSSI: "); Serial.println(WiFi.RSSI());

  configTzTime(tzInfo, ntpServer);
  Serial.println("Warte auf Zeitsynchronisation (NTP)...");
  struct tm timeinfo;
  if (getLocalTime(&timeinfo, 5000)) {
    Serial.println("Zeit synchronisiert - " + getFormattedDateTime());
  } else {
    Serial.println("Zeit konnte nicht synchronisiert werden (wird spaeter automatisch nachgeholt).");
  }

  udp.begin(localPort);

  connectKnx();

  server.on("/", handleRoot);
  server.on("/send", handleSend);
  server.on("/reconnect", handleReconnect);
  server.on("/status", handleStatus);
  server.begin();
}

void loop() {
  server.handleClient();
  handleKnxRx();

  if (isKnxConnected && (millis() - lastHeartbeat > HEARTBEAT_INTERVAL)) {
    sendConnectionStateRequest();
    lastHeartbeat = millis();
  }
}
]]>
Je souhaite mettre à votre disposition ce code qui permet de communiquer avec KNX sur un ESP32 sans aucune bibliothèque supplémentaire. Il peut aussi bien envoyer que recevoir les télégrammes les plus courants.

Code :
#include <WiFi.h>
#include <WiFiUdp.h>
#include <WebServer.h>
#include <time.h>


const char* projectName  = "KNX Stack";

const char* ssid         = "WLAN SSID";
const char* password     = "WLAN Passwort";

const char* ntpServer    = "pool.ntp.org";
const char* tzInfo       = "CET-1CEST,M3.5.0,M10.5.0/3";

const char* knxGatewayIp = "IP KNX Gateway";
const uint16_t knxPort   = 3671;
const uint16_t localPort = 3671;

WiFiUDP udp;
WebServer server(80);

uint8_t knxChannelId     = 0;
uint8_t txSeqNum         = 0;
bool isKnxConnected      = false;

unsigned long lastHeartbeat = 0;
const unsigned long HEARTBEAT_INTERVAL = 60000;
const unsigned long ACK_TIMEOUT        = 1000;

#define KNX_LOG_SIZE 10
struct KnxLogEntry {
  char timeStr[24];
  uint16_t ga;
  uint8_t data[16];
  uint8_t len;
};

KnxLogEntry knxLog[KNX_LOG_SIZE];
int knxLogNext = 0;
int knxLogFilled = 0;

void hexDump(const char* label, const uint8_t* buf, int len) {
  Serial.printf("%s [%d Bytes]: ", label, len);
  for (int i = 0; i < len; i++) {
    Serial.printf("%02X ", buf[i]);
  }
  Serial.println();
}

const char* knxStatusToString(uint8_t status) {
  switch (status) {
    case 0x00: return "E_NO_ERROR";
    case 0x01: return "E_HOST_PROTOCOL_TYPE";
    case 0x02: return "E_VERSION_NOT_SUPPORTED";
    case 0x04: return "E_SEQUENCE_NUMBER (Sequenznummer falsch/ausser Sync)";
    case 0x21: return "E_CONNECTION_ID (unbekannte Channel ID)";
    case 0x22: return "E_CONNECTION_TYPE";
    case 0x23: return "E_CONNECTION_OPTION";
    case 0x24: return "E_NO_MORE_CONNECTIONS (Gateway voll)";
    case 0x26: return "E_DATA_CONNECTION";
    case 0x27: return "E_KNX_CONNECTION";
    case 0x29: return "E_TUNNELING_LAYER (nicht unterstuetzt)";
    default:   return "Unbekannter Statuscode";
  }
}

String getFormattedDateTime() {
  struct tm timeinfo;
  if (!getLocalTime(&timeinfo, 100)) {
    return "Zeit nicht synchronisiert";
  }
  char buf[32];
  strftime(buf, sizeof(buf), "%d.%m.%Y %H:%M:%S", &timeinfo);
  return String(buf);
}

uint16_t parseGroupAddress(const String& gaStr) {
  int firstSlash  = gaStr.indexOf('/');
  int secondSlash = gaStr.indexOf('/', firstSlash + 1);
  if (firstSlash == -1 || secondSlash == -1) return 0;

  uint8_t main   = gaStr.substring(0, firstSlash).toInt();
  uint8_t middle = gaStr.substring(firstSlash + 1, secondSlash).toInt();
  uint8_t sub    = gaStr.substring(secondSlash + 1).toInt();

  return ((main & 0x1F) << 11) | ((middle & 0x07) << 8) | (sub & 0xFF);
}

String gaToString(uint16_t ga) {
  uint8_t main   = (ga >> 11) & 0x1F;
  uint8_t middle = (ga >> 8) & 0x07;
  uint8_t sub    = ga & 0xFF;
  return String(main) + "/" + String(middle) + "/" + String(sub);
}

uint16_t floatToDpt9(float val) {
  int sign = (val < 0) ? 1 : 0;
  float v = (sign == 1) ? -val : val;
  int exp = 0;
  int mantissa = (int)(v * 100.0f);
  while (mantissa > 2047) {
    mantissa >>= 1;
    exp++;
  }
  if (sign == 1) {
    mantissa = -mantissa;
    mantissa &= 0x07FF;
  }
  return (sign << 15) | ((exp & 0x0F) << 11) | (mantissa & 0x07FF);
}

float dpt9ToFloat(uint8_t hi, uint8_t lo) {
  uint16_t raw = ((uint16_t)hi << 8) | lo;
  int sign = (raw >> 15) & 0x01;
  int exp  = (raw >> 11) & 0x0F;
  int mantissa11 = raw & 0x07FF;
  int M = mantissa11 - (sign ? 2048 : 0);
  return 0.01f * M * (float)(1 << exp);
}

void floatToDpt14Bytes(float val, uint8_t* out4) {
  uint8_t* p = (uint8_t*)&val;
  out4[0] = p[3];
  out4[1] = p[2];
  out4[2] = p[1];
  out4[3] = p[0];
}

float dpt14ToFloat(uint8_t b0, uint8_t b1, uint8_t b2, uint8_t b3) {
  uint8_t bytes[4] = { b3, b2, b1, b0 };
  float f;
  memcpy(&f, bytes, 4);
  return f;
}

String apciTypeStr(uint8_t apciByte) {
  switch (apciByte & 0xC0) {
    case 0x00: return "Read";
    case 0x40: return "Response";
    case 0x80: return "Write";
    default:   return "?";
  }
}

String interpretKnxData(uint8_t* data, uint8_t len) {
  String prefix = "[" + apciTypeStr(data[0]) + "] ";

  if (len == 1) {
    bool bitVal = data[0] & 0x01;
    return prefix + "DPT1: " + (bitVal ? "EIN (1)" : "AUS (0)");
  }
  else if (len == 2) {
    return prefix + "DPT5: " + String(data[1]) + " (0..255)";
  }
  else if (len == 3) {
    float f = dpt9ToFloat(data[1], data[2]);
    return prefix + "DPT9: " + String(f, 2);
  }
  else if (len == 4) {
    uint8_t h = data[1] & 0x1F, mnt = data[2] & 0x3F, s = data[3] & 0x3F;
    uint8_t day = data[1] & 0x1F, month = data[2] & 0x0F, year = data[3] & 0x7F;
    char buf[80];
    snprintf(buf, sizeof(buf), "DPT10 Zeit : %02d:%02d:%02d  /  DPT11 Datum : %02d.%02d.20%02d",
             h, mnt, s, day, month, year);
    return prefix + String(buf);
  }
  else if (len == 5) {
    float f = dpt14ToFloat(data[1], data[2], data[3], data[4]);
    return prefix + "DPT14: " + String(f, 3);
  }
  else if (len == 15) {
    char txt[15];
    for (int i = 0; i < 14; i++) {
      uint8_t c = data[1 + i];
      txt[i] = (c >= 32 && c < 127) ? (char)c : (c == 0 ? 0 : '.');
    }
    txt[14] = 0;
    return prefix + "DPT16: \"" + String(txt) + "\"";
  }
  return prefix + "Unbekannt (" + String(len) + " Byte)";
}

void addKnxLogEntry(uint16_t ga, uint8_t* rxBuf, uint8_t npduLen) {
  KnxLogEntry &e = knxLog[knxLogNext];
  String t = getFormattedDateTime();
  strncpy(e.timeStr, t.c_str(), sizeof(e.timeStr) - 1);
  e.timeStr[sizeof(e.timeStr) - 1] = 0;
  e.ga = ga;
  uint8_t copyLen = npduLen;
  if (copyLen > sizeof(e.data)) copyLen = sizeof(e.data);
  memcpy(e.data, &rxBuf[20], copyLen);
  e.len = copyLen;

  knxLogNext = (knxLogNext + 1) % KNX_LOG_SIZE;
  if (knxLogFilled < KNX_LOG_SIZE) knxLogFilled++;
}

uint16_t processIncomingPacket(uint8_t* rxBuf, int len) {
  if (len < 6) return 0;
  uint16_t serviceType = (rxBuf[2] << 8) | rxBuf[3];
  hexDump("[KNX RX]", rxBuf, len);

  switch (serviceType) {
    case 0x0421:
      if (len >= 10) {
        Serial.printf("   -> TUNNELING_ACK | Channel : %d | Seq : %d | Status : 0x%02X (%s)\n",
                      rxBuf[7], rxBuf[8], rxBuf[9], knxStatusToString(rxBuf[9]));
      }
      break;

    case 0x0420:
      if (len >= 21) {
        uint8_t rxChannel = rxBuf[7];
        uint8_t rxSeqNum  = rxBuf[8];
        uint16_t ga = ((uint16_t)rxBuf[16] << 8) | rxBuf[17];
        uint8_t npduLen = rxBuf[18];
        Serial.printf("   -> TUNNELING_REQUEST (Bus Telegramm) | Channel : %d | Seq : %d | GA : %s\n",
                      rxChannel, rxSeqNum, gaToString(ga).c_str());
        Serial.println("      " + interpretKnxData(&rxBuf[20], npduLen));

        if (rxChannel == knxChannelId) {
          addKnxLogEntry(ga, rxBuf, npduLen);

          uint8_t ackBuf[10] = {
            0x06, 0x10, 0x04, 0x21, 0x00, 0x0A, 0x04, knxChannelId, rxSeqNum, 0x00
          };
          udp.beginPacket(knxGatewayIp, knxPort);
          udp.write(ackBuf, sizeof(ackBuf));
          udp.endPacket();
          hexDump("[KNX TX] ACK an Bus Telegramm", ackBuf, sizeof(ackBuf));
        }
      }
      break;

    case 0x0208:
      if (len >= 8) {
        Serial.printf("   -> CONNECTIONSTATE_RESPONSE | Status : 0x%02X (%s)\n", rxBuf[7], knxStatusToString(rxBuf[7]));
        if (rxBuf[7] != 0x00) {
          Serial.println("   !!! Heartbeat fehlgeschlagen -> Tunnel als getrennt markiert !!!");
          isKnxConnected = false;
        }
      }
      break;

    case 0x0209:
      if (len >= 8) {
        uint8_t rxChannel = rxBuf[6];
        Serial.printf("   -> DISCONNECT_REQUEST vom Gateway | Channel: %d\n", rxChannel);
        if (rxChannel == knxChannelId) {
          uint8_t discResp[8] = { 0x06, 0x10, 0x02, 0x0A, 0x00, 0x08, knxChannelId, 0x00 };
          udp.beginPacket(knxGatewayIp, knxPort);
          udp.write(discResp, sizeof(discResp));
          udp.endPacket();
          hexDump("[KNX TX] DISCONNECT_RESPONSE", discResp, sizeof(discResp));
          isKnxConnected = false;
        }
      }
      break;

    default:
      Serial.printf("   -> Unbehandelter ServiceType: 0x%04X\n", serviceType);
      break;
  }
  return serviceType;
}

bool connectKnx() {
  Serial.println("[KNX] Sende CONNECT_REQUEST an Gateway...");

  IPAddress myIp = WiFi.localIP();
  Serial.printf("   Lokale IP/Port die wir dem Gateway melden : %s:%d\n", myIp.toString().c_str(), localPort);
  Serial.printf("   Ziel Gateway: %s:%d\n", knxGatewayIp, knxPort);

  uint8_t connReq[] = {
    0x06, 0x10, 0x02, 0x05, 0x00, 0x1A,
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF),
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF),
    0x04, 0x04, 0x02, 0x00
  };
  hexDump("[KNX TX] CONNECT_REQUEST", connReq, sizeof(connReq));

  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(connReq, sizeof(connReq));
  udp.endPacket();

  unsigned long start = millis();
  while (millis() - start < 2000) {
    int size = udp.parsePacket();
    if (size >= 8) {
      uint8_t resp[32];
      int rlen = udp.read(resp, sizeof(resp));
      hexDump("[KNX RX] CONNECT_RESPONSE", resp, rlen);

      if (resp[2] == 0x02 && resp[3] == 0x06) {
        if (resp[7] == 0x00) {
          knxChannelId = resp[6];
          txSeqNum = 0;
          isKnxConnected = true;
          lastHeartbeat = millis();
          Serial.printf("ERFOLGREICH! Channel ID : %d\n", knxChannelId);

          if (rlen >= 16 && resp[8] == 0x08) {
            IPAddress dataIp(resp[10], resp[11], resp[12], resp[13]);
            uint16_t dataPort = (resp[14] << 8) | resp[15];
            Serial.printf("   [Info] Gateway Data-Endpoint laut CONNECT_RESPONSE: %s:%d\n",
                          dataIp.toString().c_str(), dataPort);
          }
          return true;
        } else {
          Serial.printf("FEHLER! Status Code: 0x%02X (%s)\n", resp[7], knxStatusToString(resp[7]));
          return false;
        }
      }
    }
    delay(10);
  }
  Serial.println("TIMEOUT! Keine CONNECT_RESPONSE vom Gateway erhalten.");
  isKnxConnected = false;
  return false;
}

void sendConnectionStateRequest() {
  IPAddress myIp = WiFi.localIP();
  uint8_t req[16] = {
    0x06, 0x10, 0x02, 0x07, 0x00, 0x10,
    knxChannelId, 0x00,
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF)
  };
  hexDump("[KNX TX] CONNECTIONSTATE_REQUEST (Heartbeat)", req, sizeof(req));
  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(req, sizeof(req));
  udp.endPacket();
}

void disconnectKnx() {
  if (!isKnxConnected) return;
  IPAddress myIp = WiFi.localIP();
  uint8_t req[16] = {
    0x06, 0x10, 0x02, 0x09, 0x00, 0x10,
    knxChannelId, 0x00,
    0x08, 0x01, myIp[0], myIp[1], myIp[2], myIp[3], (uint8_t)(localPort >> 8), (uint8_t)(localPort & 0xFF)
  };
  hexDump("[KNX TX] DISCONNECT_REQUEST", req, sizeof(req));
  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(req, sizeof(req));
  udp.endPacket();
  isKnxConnected = false;
}

void handleKnxRx() {
  int packetSize = udp.parsePacket();
  if (packetSize <= 0) return;
  uint8_t rxBuf[64];
  int len = udp.read(rxBuf, sizeof(rxBuf));
  processIncomingPacket(rxBuf, len);
}

bool sendKnxValue(String groupAddress, String dptType, String rawValue) {
  if (!isKnxConnected) {
    if (!connectKnx()) return false;
  }

  uint16_t ga = parseGroupAddress(groupAddress);
  uint8_t buf[64];
  uint8_t payloadLen = 0;

  buf[0] = 0x06; buf[1] = 0x10;
  buf[2] = 0x04; buf[3] = 0x20;
  buf[4] = 0x00; buf[5] = 0x00;

  buf[6] = 0x04;
  buf[7] = knxChannelId;
  buf[8] = txSeqNum;
  buf[9] = 0x00;

  buf[10] = 0x11;
  buf[11] = 0x00;
  buf[12] = 0xBC;
  buf[13] = 0xE0;
  buf[14] = 0x00; buf[15] = 0x00;
  buf[16] = (uint8_t)(ga >> 8);
  buf[17] = (uint8_t)(ga & 0xFF);

  if (dptType == "DPT1") {
    buf[18] = 0x01;
    buf[19] = 0x00;
    buf[20] = (rawValue.toInt() > 0) ? 0x81 : 0x80;
    payloadLen = 21;
  }
  else if (dptType == "DPT5") {
    buf[18] = 0x02;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)rawValue.toInt();
    payloadLen = 22;
  }
  else if (dptType == "DPT9") {
    uint16_t dpt9Val = floatToDpt9(rawValue.toFloat());
    buf[18] = 0x03;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)(dpt9Val >> 8);
    buf[22] = (uint8_t)(dpt9Val & 0xFF);
    payloadLen = 23;
  }
  else if (dptType == "DPT10") {
    int h = 0, m = 0, s = 0;
    int c1 = rawValue.indexOf(':');
    if (c1 == -1) {
      h = rawValue.toInt();
    } else {
      h = rawValue.substring(0, c1).toInt();
      int c2 = rawValue.indexOf(':', c1 + 1);
      if (c2 == -1) {
        m = rawValue.substring(c1 + 1).toInt();
      } else {
        m = rawValue.substring(c1 + 1, c2).toInt();
        s = rawValue.substring(c2 + 1).toInt();
      }
    }
    buf[18] = 0x04;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)(h & 0x1F);
    buf[22] = (uint8_t)(m & 0x3F);
    buf[23] = (uint8_t)(s & 0x3F);
    payloadLen = 24;
  }
  else if (dptType == "DPT11") {
    int day = 1, month = 1, year = 26;
    int p1 = rawValue.indexOf('.');
    if (p1 != -1) {
      day = rawValue.substring(0, p1).toInt();
      int p2 = rawValue.indexOf('.', p1 + 1);
      if (p2 != -1) {
        month = rawValue.substring(p1 + 1, p2).toInt();
        int y = rawValue.substring(p2 + 1).toInt();
        year = (y >= 2000) ? (y - 2000) : y;
      }
    } else {
      day = rawValue.toInt();
    }
    buf[18] = 0x04;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = (uint8_t)(day & 0x1F);
    buf[22] = (uint8_t)(month & 0x0F);
    buf[23] = (uint8_t)(year & 0x7F);
    payloadLen = 24;
  }
  else if (dptType == "DPT14") {
    uint8_t db[4];
    floatToDpt14Bytes(rawValue.toFloat(), db);
    buf[18] = 0x05;
    buf[19] = 0x00;
    buf[20] = 0x80;
    buf[21] = db[0];
    buf[22] = db[1];
    buf[23] = db[2];
    buf[24] = db[3];
    payloadLen = 25;
  }
  else if (dptType == "DPT16") {
    uint8_t strLen = rawValue.length();
    if (strLen > 14) strLen = 14;

    buf[18] = 15;
    buf[19] = 0x00;
    buf[20] = 0x80;
    for (int i = 0; i < 14; i++) {
      buf[21 + i] = (i < strLen) ? rawValue[i] : 0x00;
    }
    payloadLen = 21 + 14;
  }
  else {
    Serial.println("[KNX TX] FEHLER - Unbekannter DPT Typ!");
    return false;
  }

  buf[5] = payloadLen;

  Serial.printf("[KNX TX] GA: %s (0x%04X) | DPT: %s | Val: %s | Seq: %d\n",
                groupAddress.c_str(), ga, dptType.c_str(), rawValue.c_str(), txSeqNum);
  hexDump("[KNX TX] TUNNELING_REQUEST", buf, payloadLen);

  uint8_t sentSeq = txSeqNum;

  udp.beginPacket(knxGatewayIp, knxPort);
  udp.write(buf, payloadLen);
  udp.endPacket();

  txSeqNum++;

  unsigned long waitStart = millis();
  bool ackOk = false;
  while (millis() - waitStart < ACK_TIMEOUT) {
    int packetSize = udp.parsePacket();
    if (packetSize > 0) {
      uint8_t rxBuf[64];
      int len = udp.read(rxBuf, sizeof(rxBuf));
      uint16_t st = processIncomingPacket(rxBuf, len);
      if (st == 0x0421 && len >= 9 && rxBuf[8] == sentSeq) {
        ackOk = (len >= 10 && rxBuf[9] == 0x00);
        break;
      }
    }
    delay(5);
  }

  if (!ackOk) {
    Serial.println("!!! KEIN passendes TUNNELING_ACK erhalten (Timeout nach 1000ms) !!!");
  }

  return ackOk;
}

String escapeJson(String s) {
  String out;
  for (size_t i = 0; i < s.length(); i++) {
    char c = s[i];
    if (c == '"' || c == '\\') out += '\\';
    out += c;
  }
  return out;
}

void handleRoot() {
  String html = "<html><head><meta charset='UTF-8'>";
  html += "<title>" + String(projectName) + "</title>";
  html += "<style>body{font-family:Arial,sans-serif;margin:20px;background:#f4f4f9;color:#333}";
  html += ".card{background:#fff;padding:20px;border-radius:8px;box-shadow:0 2px 5px rgba(0,0,0,0.1);max-width:650px;margin:auto}";
  html += "h1{text-align:center;margin-bottom:2px;}";
  html += "#dtNow{text-align:center;color:#666;margin-top:0;margin-bottom:16px;font-size:14px;}";
  html += "input,select,button{width:100%;padding:10px;margin:10px 0;box-sizing:border-box;border:1px solid #ccc;border-radius:4px;font-size:16px}";
  html += "button{background:#007bff;color:#fff;font-weight:bold;border:none;cursor:pointer}button:hover{background:#0056b3}";
  html += "#statusMsg{margin-top:10px;font-weight:bold;color:#28a745;text-align:center;}";
  html += "table{width:100%;border-collapse:collapse;font-size:13px;margin-top:10px;}";
  html += "th,td{border-bottom:1px solid #eee;padding:6px 4px;text-align:left;}";
  html += "th{background:#f0f0f5;}";
  html += "</style></head><body>";

  html += "<div class='card'>";
  html += "<h1>" + String(projectName) + "</h1>";
  html += "<p id='dtNow'>...</p>";
  html += "<p>KNX Status: <span id='knxStatus'>" + String(isKnxConnected ? "<b style='color:green;'>Verbunden (Channel " + String(knxChannelId) + ")" : "Getrennt") + "";

  html += "<label>Gruppenadresse (z.B. 1/0/0):</label>";
  html += "<input type='text' id='ga' value='1/0/0'>";

  html += "<label>Datenpunkttyp (DPT):</label>";
  html += "<select id='dpt'>";
  html += "<option value='DPT1'>DPT 1 (1 Bit Schalten 0/1)</option>";
  html += "<option value='DPT5'>DPT 5 (1 Byte Wert 0..255)</option>";
  html += "<option value='DPT9'>DPT 9 (2 Byte Float Temp/Wert)</option>";
  html += "<option value='DPT10'>DPT 10 (Zeit, z.B. 14:30:00)</option>";
  html += "<option value='DPT11'>DPT 11 (Datum, z.B. 24.12.26)</option>";
  html += "<option value='DPT14'>DPT 14 (4 Byte Float IEEE754)</option>";
  html += "<option value='DPT16'>DPT 16 (14 Byte Text)</option>";
  html += "</select>";

  html += "<label>Wert / Payload:</label>";
  html += "<input type='text' id='val' value='1' placeholder='z.B. 1, 128, 21.5, 14:30:00, 24.12.26 oder Text'>";

  html += "<button type='button' onclick='sendTelegram()'>KNX Telegramm Senden</button>";
  html += "<button type='button' onclick='reconnectKnx()' style='background:#6c757d;'>KNX Reconnect</button>";
  html += "<div id='statusMsg'></div>";

  html += "<h3>Letzte empfangene Telegramme</h3>";
  html += "<table><thead><tr><th>Zeit</th><th>GA</th><th>Bytes</th><th>Hex</th><th>Wert</th></tr></thead>";
  html += "<tbody id='logBody'>Lade...</td></tr></tbody></table>";

  html += "</div>";

  html += "<script>";
  html += "function sendTelegram(){";
  html += "  var ga = document.getElementById('ga').value;";
  html += "  var dpt = document.getElementById('dpt').value;";
  html += "  var val = document.getElementById('val').value;";
  html += "  document.getElementById('statusMsg').innerText = 'Sende...';";
  html += "  fetch('/send?ga=' + encodeURIComponent(ga) + '&dpt=' + encodeURIComponent(dpt) + '&val=' + encodeURIComponent(val))";
  html += "  .then(response => response.text())";
  html += "  .then(data => { document.getElementById('statusMsg').innerText = data; })";
  html += "  .catch(err => { document.getElementById('statusMsg').innerText = 'Fehler beim Senden!'; });";
  html += "}";
  html += "function reconnectKnx(){";
  html += "  fetch('/reconnect').then(r=>r.text()).then(d=>{ updateStatus(); });";
  html += "}";
  html += "function updateStatus(){";
  html += "  fetch('/status').then(r=>r.json()).then(d=>{";
  html += "    document.getElementById('dtNow').innerText = d.datetime;";
  html += "    document.getElementById('knxStatus').innerHTML = d.connected ? (\"<b style='color:green;'>Verbunden (Channel \" + d.channel + \")</b>\") : \"<b style='color:red;'>Getrennt</b>\";";
  html += "    var rows = '';";
  html += "    d.log.forEach(function(e){ rows += '<tr><td>'+e.time+'</td><td>'+e.ga+'</td><td>'+e.len+'</td><td>'+e.hex+'</td><td>'+e.value+'</td></tr>'; });";
  html += "    document.getElementById('logBody').innerHTML = rows || '<tr><td colspan=5>Noch keine Telegramme empfangen</td></tr>';";
  html += "  }).catch(function(){});";
  html += "}";
  html += "setInterval(updateStatus, 1000);";
  html += "updateStatus();";
  html += "</script>";

  html += "</body></html>";
  server.send(200, "text/html", html);
}

void handleSend() {
  if (server.hasArg("ga") && server.hasArg("dpt") && server.hasArg("val")) {
    String ga = server.arg("ga");
    String dpt = server.arg("dpt");
    String val = server.arg("val");

    bool ok = sendKnxValue(ga, dpt, val);
    server.send(200, "text/plain", ok ? "Telegramm gesendet und per ACK bestaetigt!" : "Gesendet, aber KEIN ACK erhalten, siehe Serial Monitor!");
  } else {
    server.send(400, "text/plain", "Fehlende Parameter!");
  }
}

void handleReconnect() {
  connectKnx();
  server.send(200, "text/plain", "Reconnected!");
}

void handleStatus() {
  String json = "{";
  json += "\"project\":\"" + escapeJson(String(projectName)) + "\",";
  json += "\"datetime\":\"" + escapeJson(getFormattedDateTime()) + "\",";
  json += "\"connected\":" + String(isKnxConnected ? "true" : "false") + ",";
  json += "\"channel\":" + String(knxChannelId) + ",";
  json += "\"log\":[";

  for (int i = 0; i < knxLogFilled; i++) {
    int idx = (knxLogNext - 1 - i + KNX_LOG_SIZE) % KNX_LOG_SIZE;
    KnxLogEntry &e = knxLog[idx];

    String hex = "";
    for (int b = 0; b < e.len; b++) {
      char hb[4];
      snprintf(hb, sizeof(hb), "%02X ", e.data[b]);
      hex += hb;
    }
    hex.trim();

    if (i > 0) json += ",";
    json += "{";
    json += "\"time\":\"" + escapeJson(String(e.timeStr)) + "\",";
    json += "\"ga\":\"" + escapeJson(gaToString(e.ga)) + "\",";
    json += "\"len\":" + String(e.len) + ",";
    json += "\"hex\":\"" + escapeJson(hex) + "\",";
    json += "\"value\":\"" + escapeJson(interpretKnxData(e.data, e.len)) + "\"";
    json += "}";
  }
  json += "]}";
  server.send(200, "application/json", json);
}

void setup() {
  Serial.begin(115200);
  delay(1000);

  Serial.printf("\n===> %s <===\n", projectName);

  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("\nWLAN Verbunden!");
  Serial.print("IP Adresse - "); Serial.println(WiFi.localIP());
  Serial.print("RSSI: "); Serial.println(WiFi.RSSI());

  configTzTime(tzInfo, ntpServer);
  Serial.println("Warte auf Zeitsynchronisation (NTP)...");
  struct tm timeinfo;
  if (getLocalTime(&timeinfo, 5000)) {
    Serial.println("Zeit synchronisiert - " + getFormattedDateTime());
  } else {
    Serial.println("Zeit konnte nicht synchronisiert werden (wird spaeter automatisch nachgeholt).");
  }

  udp.begin(localPort);

  connectKnx();

  server.on("/", handleRoot);
  server.on("/send", handleSend);
  server.on("/reconnect", handleReconnect);
  server.on("/status", handleStatus);
  server.begin();
}

void loop() {
  server.handleClient();
  handleKnxRx();

  if (isKnxConnected && (millis() - lastHeartbeat > HEARTBEAT_INTERVAL)) {
    sendConnectionStateRequest();
    lastHeartbeat = millis();
  }
}
]]> <![CDATA[Script PHP pour connexion par tunnel IP KNX]]> https://www.knx-fr.com/showthread.php?tid=16448 Tue, 15 Sep 2026 17:35:43 +0000 Smart Guido 73]]> https://www.knx-fr.com/showthread.php?tid=16448 Bonjour,

Je mets à disposition ce petit code PHP pour ceux qui souhaitent créer davantage de choses avec PHP et KNX. Il établit une connexion par tunnel IP, envoie des données pour les DPT 1, 5 ou 9, puis se déconnecte.
Cela n'a rien à voir non plus avec mon wrapper, c'est totalement indépendant.


Code PHP :
<?php
header('Content-Type: text/html; charset=utf-8');

class KNXTunnel {
    private string $ip;
    private int $port;
    private $socket = null;
    private int $channelId = 0;
    private int $sequenceNumber = 0;

    public function __construct(string $ip, int $port = 3671) {
        $this->ip = $ip;
        $this->port = $port;
    }

    private function log(string $msg): void {
        echo $msg . "<br>\n";
        if (ob_get_level() > 0) { @ob_flush(); }
        @flush();
    }

    private function getLocalIp(): string {
        $sock = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
        socket_connect($sock, $this->ip, $this->port);
        socket_getsockname($sock, $addr);
        socket_close($sock);
        return $addr;
    }

    private function statusText(int $status): string {
        return match ($status) {
            0x00 => 'E_NO_ERROR',
            0x22 => 'E_CONNECTION_TYPE (Verbindungstyp nicht unterstützt)',
            0x23 => 'E_CONNECTION_OPTION (Option nicht unterstützt)',
            0x24 => 'E_NO_MORE_CONNECTIONS (max. Anzahl Tunnel-Verbindungen erreicht)',
            0x26 => 'E_DATA_CONNECTION',
            0x27 => 'E_KNX_CONNECTION',
            0x29 => 'E_NO_MORE_UNIQUE_CONNECTIONS',
            default => 'unbekannt (0x' . sprintf('%02X', $status) . ')',
        };
    }

    public function connect(): bool {
        $this->socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
        if (!$this->socket) {
            $this->log("❌ Socket konnte nicht erstellt werden : " . socket_strerror(socket_last_error()));
            return false;
        }

        socket_set_option($this->socket, SOL_SOCKET, SO_RCVTIMEO, ['sec' => 3, 'usec' => 0]);

        $myPcIp = $this->getLocalIp();
        $this->log("ℹ️ Lokale IP : {$myPcIp}");

        if (!@socket_bind($this->socket, $myPcIp, 0)) {
            $this->log("❌ Fehler beim Binden an PC IP {$myPcIp} : " . socket_strerror(socket_last_error($this->socket)));
            return false;
        }

        $localPort = 0;
        socket_getsockname($this->socket, $myPcIp, $localPort);
        $ipParts = array_map('intval', explode('.', $myPcIp));

        $hpaiControl = pack('C*', 0x08, 0x01, $ipParts[0], $ipParts[1], $ipParts[2], $ipParts[3]) . pack('n', $localPort);

        $hpaiData = pack('C*', 0x08, 0x01, $ipParts[0], $ipParts[1], $ipParts[2], $ipParts[3]) . pack('n', $localPort);

        $header = "\x06\x10\x02\x05\x00\x1a";

        $cri = "\x04\x04\x02\x00";

        $connectRequest = $header . $hpaiControl . $hpaiData . $cri;

        socket_sendto($this->socket, $connectRequest, strlen($connectRequest), 0, $this->ip, $this->port);
        $this->log("? CONNECT_REQUEST gesendet an {$this->ip}:{$this->port}");

        $buffer = '';
        $from = '';
        $fromPort = 0;
        $bytes = @socket_recvfrom($this->socket, $buffer, 1024, 0, $from, $fromPort);

        if ($bytes === false) {
            $this->log("❌ recvfrom Fehler : " . socket_strerror(socket_last_error($this->socket)));
            return false;
        }

        if ($bytes < 8) {
            $this->log("❌ Zu kurze Antwort empfangen ({$bytes} Bytes).");
            return false;
        }

        $this->log("? Rohdaten empfangen von {$from}:{$fromPort} (" . $bytes . " Bytes): " . bin2hex($buffer));

        $serviceType = (ord($buffer[2]) << 8) | ord($buffer[3]);

        if ($serviceType !== 0x0206) {
            $this->log("❌ Unerwarteter Service Type : 0x" . sprintf('%04X', $serviceType) . " (erwartet : 0x0206 CONNECT_RESPONSE)");
            return false;
        }

        $status = ord($buffer[7]);
        if ($status !== 0x00) {
            $this->log("❌ IP Gateway abbruch, Status : 0x" . sprintf('%02X', $status) . " (" . $this->statusText($status) . ")");
            return false;
        }

        $this->channelId = ord($buffer[6]);
        $this->sequenceNumber = 0;
        $this->log("✅ IP Gateway Tunnel erfolgreich aufgebaut! (Channel ID : {$this->channelId})");
        return true;
    }

    private function parseGroupAddress(string $ga): string {
        $parts = explode('/', $ga);
        if (count($parts) === 3) {
            $main = (int)$parts[0] & 0x1F;
            $middle = (int)$parts[1] & 0x07;
            $sub = (int)$parts[2] & 0xFF;
            $val = ($main << 11) | ($middle << 8) | $sub;
            return pack('n', $val);
        }
        return "\x00\x00";
    }

    public function encodeDPT(string $dptType, $value): string {
        switch (strtoupper($dptType)) {
            case 'DPT1':
                return pack('C', 0x80 | ($value ? 1 : 0));

            case 'DPT5':
                $val = max(0, min(255, (int)$value));
                return pack('CC', 0x80, $val);

            case 'DPT9':
                $v = (float)$value;
                $sign = ($v < 0) ? 0x8000 : 0x0000;
                $v = abs($v);
                $mantissa = (int)round($v * 100);
                $exponent = 0;
                while ($mantissa > 2047) {
                    $mantissa >>= 1;
                    $exponent++;
                }
                if ($sign) $mantissa = -$mantissa;
                $raw = $sign | (($exponent & 0x0F) << 11) | ($mantissa & 0x07FF);
                return pack('C*', 0x80, ($raw >> 8) & 0xFF, $raw & 0xFF);

            default:
                throw new Exception("DPT Typ '{$dptType}' nicht unterstützt.");
        }
    }

    public function send(string $groupAddress, string $dptType, $value): bool {
        if ($this->channelId === 0) {
            $this->log("❌ send() ohne aktiven Tunnel aufgerufen, zuerst connect() erfolgreich ausführen.");
            return false;
        }

        $gaBytes = $this->parseGroupAddress($groupAddress);
        $payload = $this->encodeDPT($dptType, $value);
        $payloadLen = strlen($payload);

        $cemi = "\x11\x00\xbc\xe0\x00\x00" . $gaBytes . pack('C', $payloadLen) . "\x00" . $payload;
        $totalLen = 6 + 4 + strlen($cemi);

        $header = "\x06\x10\x04\x20" . pack('n', $totalLen);
        $connectionHeader = pack('CC', 0x04, $this->channelId) . pack('CC', $this->sequenceNumber, 0x00);

        $packet = $header . $connectionHeader . $cemi;

        socket_sendto($this->socket, $packet, strlen($packet), 0, $this->ip, $this->port);
        $this->log("? Telegramm an <b>{$groupAddress}</b> gesendet! (Seq: {$this->sequenceNumber})");

        $ack = $this->receiveACK();
        $this->sequenceNumber = ($this->sequenceNumber + 1) % 256;

        return $ack;
    }

    private function receiveACK(): bool {
        $buffer = '';
        $from = '';
        $port = 0;
        $bytes = @socket_recvfrom($this->socket, $buffer, 1024, 0, $from, $port);

        if ($bytes === false) {
            $this->log("❌ Kein ACK erhalten (Timeout) : " . socket_strerror(socket_last_error($this->socket)));
            return false;
        }

        if ($bytes >= 10 && ord($buffer[2]) === 0x04 && ord($buffer[3]) === 0x21) {
            $status = ord($buffer[9]);
            if ($status === 0x00) {
                $this->log("? ACK vom IP Gateway erhalten.");
                return true;
            }
            $this->log("⚠️ ACK erhalten, aber mit Fehlerstatus: 0x" . sprintf('%02X', $status));
            return false;
        }

        $this->log("⚠️ Unerwartete Antwort statt ACK erhalten : " . bin2hex($buffer));
        return false;
    }

    public function disconnect(): void {
        if ($this->channelId !== 0 && $this->socket) {
            $disconnectRequest = "\x06\x10\x02\x09\x00\x10" . pack('CC', $this->channelId, 0x00) . "\x08\x01\x00\x00\x00\x00\x00\x00";
            @socket_sendto($this->socket, $disconnectRequest, strlen($disconnectRequest), 0, $this->ip, $this->port);
            $this->log("? IP Gateway Tunnel Verbindung (Channel {$this->channelId}) ordnungsgemäß getrennt.");
            $this->channelId = 0;
        }
        if ($this->socket) {
            @socket_close($this->socket);
            $this->socket = null;
        }
    }
}

$Ip = '192.168.178.42';
$knx = new KNXTunnel($Ip);

try {
    if ($knx->connect()) {
        $knx->send('1/0/0', 'DPT1', true);
    }
} finally {
    $knx->disconnect();
} 
]]> Bonjour,

Je mets à disposition ce petit code PHP pour ceux qui souhaitent créer davantage de choses avec PHP et KNX. Il établit une connexion par tunnel IP, envoie des données pour les DPT 1, 5 ou 9, puis se déconnecte.
Cela n'a rien à voir non plus avec mon wrapper, c'est totalement indépendant.


Code PHP :
<?php
header('Content-Type: text/html; charset=utf-8');

class KNXTunnel {
    private string $ip;
    private int $port;
    private $socket = null;
    private int $channelId = 0;
    private int $sequenceNumber = 0;

    public function __construct(string $ip, int $port = 3671) {
        $this->ip = $ip;
        $this->port = $port;
    }

    private function log(string $msg): void {
        echo $msg . "<br>\n";
        if (ob_get_level() > 0) { @ob_flush(); }
        @flush();
    }

    private function getLocalIp(): string {
        $sock = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
        socket_connect($sock, $this->ip, $this->port);
        socket_getsockname($sock, $addr);
        socket_close($sock);
        return $addr;
    }

    private function statusText(int $status): string {
        return match ($status) {
            0x00 => 'E_NO_ERROR',
            0x22 => 'E_CONNECTION_TYPE (Verbindungstyp nicht unterstützt)',
            0x23 => 'E_CONNECTION_OPTION (Option nicht unterstützt)',
            0x24 => 'E_NO_MORE_CONNECTIONS (max. Anzahl Tunnel-Verbindungen erreicht)',
            0x26 => 'E_DATA_CONNECTION',
            0x27 => 'E_KNX_CONNECTION',
            0x29 => 'E_NO_MORE_UNIQUE_CONNECTIONS',
            default => 'unbekannt (0x' . sprintf('%02X', $status) . ')',
        };
    }

    public function connect(): bool {
        $this->socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
        if (!$this->socket) {
            $this->log("❌ Socket konnte nicht erstellt werden : " . socket_strerror(socket_last_error()));
            return false;
        }

        socket_set_option($this->socket, SOL_SOCKET, SO_RCVTIMEO, ['sec' => 3, 'usec' => 0]);

        $myPcIp = $this->getLocalIp();
        $this->log("ℹ️ Lokale IP : {$myPcIp}");

        if (!@socket_bind($this->socket, $myPcIp, 0)) {
            $this->log("❌ Fehler beim Binden an PC IP {$myPcIp} : " . socket_strerror(socket_last_error($this->socket)));
            return false;
        }

        $localPort = 0;
        socket_getsockname($this->socket, $myPcIp, $localPort);
        $ipParts = array_map('intval', explode('.', $myPcIp));

        $hpaiControl = pack('C*', 0x08, 0x01, $ipParts[0], $ipParts[1], $ipParts[2], $ipParts[3]) . pack('n', $localPort);

        $hpaiData = pack('C*', 0x08, 0x01, $ipParts[0], $ipParts[1], $ipParts[2], $ipParts[3]) . pack('n', $localPort);

        $header = "\x06\x10\x02\x05\x00\x1a";

        $cri = "\x04\x04\x02\x00";

        $connectRequest = $header . $hpaiControl . $hpaiData . $cri;

        socket_sendto($this->socket, $connectRequest, strlen($connectRequest), 0, $this->ip, $this->port);
        $this->log("? CONNECT_REQUEST gesendet an {$this->ip}:{$this->port}");

        $buffer = '';
        $from = '';
        $fromPort = 0;
        $bytes = @socket_recvfrom($this->socket, $buffer, 1024, 0, $from, $fromPort);

        if ($bytes === false) {
            $this->log("❌ recvfrom Fehler : " . socket_strerror(socket_last_error($this->socket)));
            return false;
        }

        if ($bytes < 8) {
            $this->log("❌ Zu kurze Antwort empfangen ({$bytes} Bytes).");
            return false;
        }

        $this->log("? Rohdaten empfangen von {$from}:{$fromPort} (" . $bytes . " Bytes): " . bin2hex($buffer));

        $serviceType = (ord($buffer[2]) << 8) | ord($buffer[3]);

        if ($serviceType !== 0x0206) {
            $this->log("❌ Unerwarteter Service Type : 0x" . sprintf('%04X', $serviceType) . " (erwartet : 0x0206 CONNECT_RESPONSE)");
            return false;
        }

        $status = ord($buffer[7]);
        if ($status !== 0x00) {
            $this->log("❌ IP Gateway abbruch, Status : 0x" . sprintf('%02X', $status) . " (" . $this->statusText($status) . ")");
            return false;
        }

        $this->channelId = ord($buffer[6]);
        $this->sequenceNumber = 0;
        $this->log("✅ IP Gateway Tunnel erfolgreich aufgebaut! (Channel ID : {$this->channelId})");
        return true;
    }

    private function parseGroupAddress(string $ga): string {
        $parts = explode('/', $ga);
        if (count($parts) === 3) {
            $main = (int)$parts[0] & 0x1F;
            $middle = (int)$parts[1] & 0x07;
            $sub = (int)$parts[2] & 0xFF;
            $val = ($main << 11) | ($middle << 8) | $sub;
            return pack('n', $val);
        }
        return "\x00\x00";
    }

    public function encodeDPT(string $dptType, $value): string {
        switch (strtoupper($dptType)) {
            case 'DPT1':
                return pack('C', 0x80 | ($value ? 1 : 0));

            case 'DPT5':
                $val = max(0, min(255, (int)$value));
                return pack('CC', 0x80, $val);

            case 'DPT9':
                $v = (float)$value;
                $sign = ($v < 0) ? 0x8000 : 0x0000;
                $v = abs($v);
                $mantissa = (int)round($v * 100);
                $exponent = 0;
                while ($mantissa > 2047) {
                    $mantissa >>= 1;
                    $exponent++;
                }
                if ($sign) $mantissa = -$mantissa;
                $raw = $sign | (($exponent & 0x0F) << 11) | ($mantissa & 0x07FF);
                return pack('C*', 0x80, ($raw >> 8) & 0xFF, $raw & 0xFF);

            default:
                throw new Exception("DPT Typ '{$dptType}' nicht unterstützt.");
        }
    }

    public function send(string $groupAddress, string $dptType, $value): bool {
        if ($this->channelId === 0) {
            $this->log("❌ send() ohne aktiven Tunnel aufgerufen, zuerst connect() erfolgreich ausführen.");
            return false;
        }

        $gaBytes = $this->parseGroupAddress($groupAddress);
        $payload = $this->encodeDPT($dptType, $value);
        $payloadLen = strlen($payload);

        $cemi = "\x11\x00\xbc\xe0\x00\x00" . $gaBytes . pack('C', $payloadLen) . "\x00" . $payload;
        $totalLen = 6 + 4 + strlen($cemi);

        $header = "\x06\x10\x04\x20" . pack('n', $totalLen);
        $connectionHeader = pack('CC', 0x04, $this->channelId) . pack('CC', $this->sequenceNumber, 0x00);

        $packet = $header . $connectionHeader . $cemi;

        socket_sendto($this->socket, $packet, strlen($packet), 0, $this->ip, $this->port);
        $this->log("? Telegramm an <b>{$groupAddress}</b> gesendet! (Seq: {$this->sequenceNumber})");

        $ack = $this->receiveACK();
        $this->sequenceNumber = ($this->sequenceNumber + 1) % 256;

        return $ack;
    }

    private function receiveACK(): bool {
        $buffer = '';
        $from = '';
        $port = 0;
        $bytes = @socket_recvfrom($this->socket, $buffer, 1024, 0, $from, $port);

        if ($bytes === false) {
            $this->log("❌ Kein ACK erhalten (Timeout) : " . socket_strerror(socket_last_error($this->socket)));
            return false;
        }

        if ($bytes >= 10 && ord($buffer[2]) === 0x04 && ord($buffer[3]) === 0x21) {
            $status = ord($buffer[9]);
            if ($status === 0x00) {
                $this->log("? ACK vom IP Gateway erhalten.");
                return true;
            }
            $this->log("⚠️ ACK erhalten, aber mit Fehlerstatus: 0x" . sprintf('%02X', $status));
            return false;
        }

        $this->log("⚠️ Unerwartete Antwort statt ACK erhalten : " . bin2hex($buffer));
        return false;
    }

    public function disconnect(): void {
        if ($this->channelId !== 0 && $this->socket) {
            $disconnectRequest = "\x06\x10\x02\x09\x00\x10" . pack('CC', $this->channelId, 0x00) . "\x08\x01\x00\x00\x00\x00\x00\x00";
            @socket_sendto($this->socket, $disconnectRequest, strlen($disconnectRequest), 0, $this->ip, $this->port);
            $this->log("? IP Gateway Tunnel Verbindung (Channel {$this->channelId}) ordnungsgemäß getrennt.");
            $this->channelId = 0;
        }
        if ($this->socket) {
            @socket_close($this->socket);
            $this->socket = null;
        }
    }
}

$Ip = '192.168.178.42';
$knx = new KNXTunnel($Ip);

try {
    if ($knx->connect()) {
        $knx->send('1/0/0', 'DPT1', true);
    }
} finally {
    $knx->disconnect();
} 
]]> <![CDATA[Se former au SEO quand on vient du monde KNX, y'a du monde ?]]> https://www.knx-fr.com/showthread.php?tid=15882 Wed, 29 Jul 2026 03:51:05 +0000 Aleex]]> https://www.knx-fr.com/showthread.php?tid=15882
Il y a des gens ici qui sont passé par là? Parce que la domotique KNX c'est quand même une niche assez pointue, j'imagine que se former au SEO quand on est sur une thématique aussi technique c'est pas pareil que pour un blog de cuisine ou de voyage. Les volumes de recherche sont probablement ridicules, les mots-clés très specifiques... j'sais pas si les formations SEO classiques qu'on trouve un peu partout en ligne couvrent vraiment ce genre de cas. Quelqu'un ici a bossé sa visibilité sur son propre site autour du KNX ? Vous êtes passé par une formation, des ressources gratuites, un forum spécialisé SEO ? Curieux de savoir comment vous avez géré ça concrètement.]]>
Il y a des gens ici qui sont passé par là? Parce que la domotique KNX c'est quand même une niche assez pointue, j'imagine que se former au SEO quand on est sur une thématique aussi technique c'est pas pareil que pour un blog de cuisine ou de voyage. Les volumes de recherche sont probablement ridicules, les mots-clés très specifiques... j'sais pas si les formations SEO classiques qu'on trouve un peu partout en ligne couvrent vraiment ce genre de cas. Quelqu'un ici a bossé sa visibilité sur son propre site autour du KNX ? Vous êtes passé par une formation, des ressources gratuites, un forum spécialisé SEO ? Curieux de savoir comment vous avez géré ça concrètement.]]> <![CDATA[KNX Reast API]]> https://www.knx-fr.com/showthread.php?tid=13186 Mon, 30 Mar 2026 10:34:53 +0000 Smart Guido 73]]> https://www.knx-fr.com/showthread.php?tid=13186
j’ai développé une API REST en ASP.NET qui permet de se connecter à un système KNX (via USB, IP ou KNX IP Secure).
Cette API propose de nombreuses fonctionnalités, notamment :
  • WriteBool
  • WriteByte
  • WriteDPT
  • ReadValue
  • le chargement des adresses de groupe à partir d’un fichier XML
  • ainsi que d’autres commandes utiles pour la communication KNX 


En outre, tous les endpoints de l’API sont affichés directement sur le serveur avec des explications détaillées, ce qui facilite grandement l’utilisation et l’intégration.
Vous trouverez ci-dessous quelques-unes des principales fonctionnalités et endpoints :

https://localhost:7061/swagger/index.html
https://localhost:7061/api/knx/connectusb
https://localhost:7061/api/knx/connect?i...1&nat=true
https://localhost:7061/api/knx/connectse...sword=1234
https://localhost:7061/api/knx/dispose
https://localhost:7061/api/knx/readvalue...1=1&dpt2=1
https://localhost:7061/api/knx/writebool...value=true
https://localhost:7061/api/knx/writebyte...&value=100
https://localhost:7061/api/knx/writevalu...1=9&dpt2=1
https://localhost:7061/api/knx/convertto...1=9&dpt2=1
https://localhost:7061/api/knx/convertto...1=9&dpt2=1
https://localhost:7061/api/knx/loaddptli...a\\dpt.xml
https://localhost:7061/api/knx/telegrams
https://localhost:7061/api/knx/check?gro...ess=1/2/10

lien de téléchargement:
https://www.knx-board.org/download.php?f...apiv19.zip]]>
j’ai développé une API REST en ASP.NET qui permet de se connecter à un système KNX (via USB, IP ou KNX IP Secure).
Cette API propose de nombreuses fonctionnalités, notamment :
  • WriteBool
  • WriteByte
  • WriteDPT
  • ReadValue
  • le chargement des adresses de groupe à partir d’un fichier XML
  • ainsi que d’autres commandes utiles pour la communication KNX 


En outre, tous les endpoints de l’API sont affichés directement sur le serveur avec des explications détaillées, ce qui facilite grandement l’utilisation et l’intégration.
Vous trouverez ci-dessous quelques-unes des principales fonctionnalités et endpoints :

https://localhost:7061/swagger/index.html
https://localhost:7061/api/knx/connectusb
https://localhost:7061/api/knx/connect?i...1&nat=true
https://localhost:7061/api/knx/connectse...sword=1234
https://localhost:7061/api/knx/dispose
https://localhost:7061/api/knx/readvalue...1=1&dpt2=1
https://localhost:7061/api/knx/writebool...value=true
https://localhost:7061/api/knx/writebyte...&value=100
https://localhost:7061/api/knx/writevalu...1=9&dpt2=1
https://localhost:7061/api/knx/convertto...1=9&dpt2=1
https://localhost:7061/api/knx/convertto...1=9&dpt2=1
https://localhost:7061/api/knx/loaddptli...a\\dpt.xml
https://localhost:7061/api/knx/telegrams
https://localhost:7061/api/knx/check?gro...ess=1/2/10

lien de téléchargement:
https://www.knx-board.org/download.php?f...apiv19.zip]]> <![CDATA[Création d'une passerelle onduleur huawei sun2000 -> KNX IP]]> https://www.knx-fr.com/showthread.php?tid=9182 Thu, 06 Feb 2025 18:18:08 +0000 tof70270]]> https://www.knx-fr.com/showthread.php?tid=9182 Je suis en train d'essayer de créer une passerelle sun2000 pour échanger les donner avec le KNX via mon Raspberry 4. J'ai réussi à créer la passerelle KNX ainsi que d'installer et de connecter l'application fusion solar. Mon problème est de savoir quel node utiliser dans node-red pour faire la liaison entre les 2.
Merci pour votre aide.]]> Je suis en train d'essayer de créer une passerelle sun2000 pour échanger les donner avec le KNX via mon Raspberry 4. J'ai réussi à créer la passerelle KNX ainsi que d'installer et de connecter l'application fusion solar. Mon problème est de savoir quel node utiliser dans node-red pour faire la liaison entre les 2.
Merci pour votre aide.]]> <![CDATA[Partagez vos meilleurs outils, applications et liens KNX – La collection ultime !]]> https://www.knx-fr.com/showthread.php?tid=8868 Sun, 26 Jan 2025 14:45:08 +0000 Smart Guido 73]]> https://www.knx-fr.com/showthread.php?tid=8868
Je souhaite mettre à disposition quelques outils qui pourraient être utiles à certains d'entre vous, que ce soit pour des tests de fonctionnalités, la création de graphiques pour les panneaux tactiles MDT, ou encore pour créer un message BBCode hors ligne sur le forum, ce qui peut faciliter le travail.

1. Programme : KNX Tableau
KNX Tableau est un outil simple qui ouvre une fenêtre sur le bureau et propose 16 fonctions de commutation. Dans le fichier XML (settings.xml), il est possible de configurer les adresses IP, les noms de groupes, les adresses de groupe ainsi que les informations de commutation et de statut.
Lien de téléchargement :
KNX Tableau

2. Programme : KNX Acteur
KNX Acteur fonctionne essentiellement de la même manière que KNX Tableau, mais sous la forme d'un actionneur de commutation.

[Image: knxaktor.png]

Lien de téléchargement :
KNX Acteur

3. Programme : SVGtoBMP
SVGtoBMP est un outil simple qui convertit des fichiers SVG en fichiers graphiques BMP, à la fois en version monochrome et en couleur, et dans cinq résolutions différentes. Inversement, il peut également convertir des fichiers BMP en SVG.

[Image: svg.png]

Lien de téléchargement :
SVGtoBMP

4. Programme : BBCodeEditor
J'ai écrit cet outil pour simplifier la création de messages BBCode hors ligne sur le forum. Récemment, je l'utilise moi-même très fréquemment, car il facilite considérablement la gestion.

[Image: BBCode.png]

Lien de téléchargement :
BBCodeEditor

Je serais heureux si vous partagiez également des outils utiles sur le sujet KNX ici, cela pourrait certainement intéresser certains d'entre vous. Il est toujours avantageux de rassembler des outils intéressants et de les rendre plus accessibles afin de ne pas passer des heures à chercher des applications utiles sur Internet.

Veuillez bien vouloir partager vos outils préférés directement ici dans ce fil, afin qu'il soit plus facile de les retrouver.

D'ici là, amusez-vous bien avec les nombreux outils à venir sur le thème KNX !]]>
Je souhaite mettre à disposition quelques outils qui pourraient être utiles à certains d'entre vous, que ce soit pour des tests de fonctionnalités, la création de graphiques pour les panneaux tactiles MDT, ou encore pour créer un message BBCode hors ligne sur le forum, ce qui peut faciliter le travail.

1. Programme : KNX Tableau
KNX Tableau est un outil simple qui ouvre une fenêtre sur le bureau et propose 16 fonctions de commutation. Dans le fichier XML (settings.xml), il est possible de configurer les adresses IP, les noms de groupes, les adresses de groupe ainsi que les informations de commutation et de statut.
Lien de téléchargement :
KNX Tableau

2. Programme : KNX Acteur
KNX Acteur fonctionne essentiellement de la même manière que KNX Tableau, mais sous la forme d'un actionneur de commutation.

[Image: knxaktor.png]

Lien de téléchargement :
KNX Acteur

3. Programme : SVGtoBMP
SVGtoBMP est un outil simple qui convertit des fichiers SVG en fichiers graphiques BMP, à la fois en version monochrome et en couleur, et dans cinq résolutions différentes. Inversement, il peut également convertir des fichiers BMP en SVG.

[Image: svg.png]

Lien de téléchargement :
SVGtoBMP

4. Programme : BBCodeEditor
J'ai écrit cet outil pour simplifier la création de messages BBCode hors ligne sur le forum. Récemment, je l'utilise moi-même très fréquemment, car il facilite considérablement la gestion.

[Image: BBCode.png]

Lien de téléchargement :
BBCodeEditor

Je serais heureux si vous partagiez également des outils utiles sur le sujet KNX ici, cela pourrait certainement intéresser certains d'entre vous. Il est toujours avantageux de rassembler des outils intéressants et de les rendre plus accessibles afin de ne pas passer des heures à chercher des applications utiles sur Internet.

Veuillez bien vouloir partager vos outils préférés directement ici dans ce fil, afin qu'il soit plus facile de les retrouver.

D'ici là, amusez-vous bien avec les nombreux outils à venir sur le thème KNX !]]> <![CDATA[Falcon SDK 6 et Python]]> https://www.knx-fr.com/showthread.php?tid=8682 Tue, 19 Nov 2024 23:14:08 +0000 Smart Guido 73]]> https://www.knx-fr.com/showthread.php?tid=8682
J'ai maintenant également utilisé le wrapper C# pour Python et il fonctionne également comme avec WinDev et Delphi.

Avant d'utiliser, la DLL signée du Falcon SDK doit être enregistrée sur l'ordinateur afin que Python puisse y accéder :
1. Copiez le dossier « Falcon SDK 6 Signé » dans votre dossier « Documents ».
2. C'est tout.


1. Installation de PythonNet :
  • Assurez-vous d'avoir Python (version 3.7–3.11) et un framework .NET compatible installés.
  • Installez PythonNet avec la commande :  pip install pythonnet
  • En cas de problèmes, des outils de développement comme Visual Studio Build Tools peuvent être nécessaires.
2. Version recommandée :
  • PythonNet fonctionne mieux avec Python 3.7 à 3.11.
3. Utilisation :
  • Après l'installation, utilisez le module clr pour charger et utiliser des assemblies .NET dans Python.
Les commandes sont identiques à celles de WinDev, mais la gestion des Assemblies .NET dans Delphi est un peu différente. Je vais maintenant reprendre quelques exemples de mon code source pour illustrer les commandes disponibles :

Utilisation des assemblies .NET dans Python avec PythonNet :
import clr
clr.AddReference(r'C:\Users\Username\Documents\Falcon SDK 6 Signiert\KNXlib.dll')

from KNXlib import KnxController
knxcontroller = KnxController()

Connectez-vous au gateway USB :
knxcontroller.ConnectUSB()

Connectez-vous à la passerelle IP :
knxcontroller.Connect("192.168.178.42", 3671, False)

Connectez-vous à la passerelle IP sécurisée :
knxcontroller.ConnectSecure("192.168.178.150", 3671, False, "1.1.243","test.knxkeys", "admin123!")

Chargement du fichier XML :
knxcontroller.LoadDptList("knxxml.xml")
Envoyer DPT1 :
knxcontroller.WriteBool("1/0/0" , True)

Envoyer DPT9.1 :
knxcontroller.WriteValueToDPT(Groupaddress, value as string, DPTupper value, DPTlower value)
knxcontroller.WriteValueToDPT("11/7/4", "20.5", 9, 1)

A lire :
knxcontroller.ReadValueAsync("11/7/4")

Envoi DPT5.1 :
knxcontroller.WriteValueToDPT("6/0/9", "90", 5, 1)

Envoi DPT5.4 :
knxcontroller.WriteValueToDPT("6/0/9", "240", 5, 4)

Lire DPT9.1 :
knxcontroller.ReadValue("11/7/4", 9, 1)

Envoyer la date actuelle :
knxcontroller.WriteDate("11/5/0")

Envoyer l'heure actuelle :
knxcontroller.WriteTime("11/5/1")

Envoyer la date actuelle en tant que DPT16 :
knxcontroller.WriteTimeAsText("11/6/1")


Voici le lien de téléchargement :
https://www.knx-board.org/download.php?f...rapper.zip]]>
J'ai maintenant également utilisé le wrapper C# pour Python et il fonctionne également comme avec WinDev et Delphi.

Avant d'utiliser, la DLL signée du Falcon SDK doit être enregistrée sur l'ordinateur afin que Python puisse y accéder :
1. Copiez le dossier « Falcon SDK 6 Signé » dans votre dossier « Documents ».
2. C'est tout.


1. Installation de PythonNet :
  • Assurez-vous d'avoir Python (version 3.7–3.11) et un framework .NET compatible installés.
  • Installez PythonNet avec la commande :  pip install pythonnet
  • En cas de problèmes, des outils de développement comme Visual Studio Build Tools peuvent être nécessaires.
2. Version recommandée :
  • PythonNet fonctionne mieux avec Python 3.7 à 3.11.
3. Utilisation :
  • Après l'installation, utilisez le module clr pour charger et utiliser des assemblies .NET dans Python.
Les commandes sont identiques à celles de WinDev, mais la gestion des Assemblies .NET dans Delphi est un peu différente. Je vais maintenant reprendre quelques exemples de mon code source pour illustrer les commandes disponibles :

Utilisation des assemblies .NET dans Python avec PythonNet :
import clr
clr.AddReference(r'C:\Users\Username\Documents\Falcon SDK 6 Signiert\KNXlib.dll')

from KNXlib import KnxController
knxcontroller = KnxController()

Connectez-vous au gateway USB :
knxcontroller.ConnectUSB()

Connectez-vous à la passerelle IP :
knxcontroller.Connect("192.168.178.42", 3671, False)

Connectez-vous à la passerelle IP sécurisée :
knxcontroller.ConnectSecure("192.168.178.150", 3671, False, "1.1.243","test.knxkeys", "admin123!")

Chargement du fichier XML :
knxcontroller.LoadDptList("knxxml.xml")
Envoyer DPT1 :
knxcontroller.WriteBool("1/0/0" , True)

Envoyer DPT9.1 :
knxcontroller.WriteValueToDPT(Groupaddress, value as string, DPTupper value, DPTlower value)
knxcontroller.WriteValueToDPT("11/7/4", "20.5", 9, 1)

A lire :
knxcontroller.ReadValueAsync("11/7/4")

Envoi DPT5.1 :
knxcontroller.WriteValueToDPT("6/0/9", "90", 5, 1)

Envoi DPT5.4 :
knxcontroller.WriteValueToDPT("6/0/9", "240", 5, 4)

Lire DPT9.1 :
knxcontroller.ReadValue("11/7/4", 9, 1)

Envoyer la date actuelle :
knxcontroller.WriteDate("11/5/0")

Envoyer l'heure actuelle :
knxcontroller.WriteTime("11/5/1")

Envoyer la date actuelle en tant que DPT16 :
knxcontroller.WriteTimeAsText("11/6/1")


Voici le lien de téléchargement :
https://www.knx-board.org/download.php?f...rapper.zip]]> <![CDATA[WinDev et le SDK Falcon 6]]> https://www.knx-fr.com/showthread.php?tid=8655 Tue, 05 Nov 2024 21:37:27 +0000 Smart Guido 73]]> https://www.knx-fr.com/showthread.php?tid=8655
Je suis nouveau sur le forum et on m'a demandé si je pouvais aider quelqu'un avec Windev. À ce moment-là, je ne connaissais pas encore ce logiciel, alors je l'ai testé et c'est ainsi que je suis tombé sur ce forum.
J'y ai vu qu'il existait un fil de discussion concernant KNX dans Windev, mais uniquement en lien avec le Falcon SDK 5 et ses fonctionnalités limitées. Le Falcon SDK 6 n'était pas abordé.


Ainsi, j'ai démarré mon premier projet avec Windev et j'ai écrit un wrapper C# pour le Falcon SDK 6.
Ce wrapper utilise les commandes les plus courantes et permet de réaliser un grand nombre de fonctions.

Les fonctionnalités incluent par exemple :

    - Établir une connexion USB
    - Connexion IP, y compris avec des Secure Gateways
    - Envoi de valeurs dans différents DPTS (y compris DPT10, DPT11 et date sous DPT16)
    - Interrogation de valeurs au format Raw ainsi qu'au format DPT
    - Lecture des données reçues, permettant de réagir aux télégrammes entrants
    - Recherche de IP Gateways
    - Recherche de IP Secure Gateways
    - Sauvegarde des 100 derniers télégrammes
    - Chargement de la liste d'adresses de groupe depuis le DPT (export de l'ETS)

Le fichier à télécharger contient un exemple de code que j'ai écrit et testé avec la version gratuite de WinDev 28 Express. Le Falcon SDK 6 est également inclus dans le fichier.
L'exemple de code est un simple moniteur de bus qui, lorsque la liste d'adresses de groupe exportée depuis ETS est ajoutée, affiche également les types DPT (types de points de données) ainsi que les identificateurs textuels correspondants des adresses de groupe.

Avant d'utiliser, il est nécessaire d'enregistrer la DLL signée du Falcon SDK :
1. Copiez le dossier "Falcon SDK 6 Signé" dans vos documents.
2. Ouvrez l'invite de commande (CMD) en tant qu'administrateur.
3. Allez dans le dossier C:\Windows\Microsoft.NET\Framework\v4.0.30319.
4. Enregistrez la DLL avec la commande suivante : regasm "C:\Users\Utilisateur\Documents\Falcon SDK 6 Signé\KNXlib.dll" /tlb:KNXlib.tlb /codebase
5. Ensuite, allez dans le dossier C:\Windows\Microsoft.NET\Framework64\v4.0.30319.
6. Enregistrez à nouveau la DLL avec la même commande : regasm "C:\Users\Utilisateur\Documents\Falcon SDK 6 Signé\KNXlib.dll" /tlb:KNXlib.tlb /codebase
7. Si un message d'erreur indique que l'enregistrement a été bloqué, il peut être nécessaire de désactiver la fonction "Accès protégé aux dossiers".
8. Vous pouvez vérifier l'enregistrement réussi dans le Registre :
   Appuyez sur [Windows]+R et tapez regedit pour ouvrir l'éditeur de registre.
   Vérifiez les chemins suivants :
   Ordinateur\HKEY_CLASSES_ROOT\CLSID{E45D1244-ABCD-4E1D-8D9F-9992B7F017A2} 
   Ordinateur\HKEY_CLASSES_ROOT\WOW6432Node\CLSID{E45D1244-ABCD-4E1D-8D9F-9992B7F017A2}


Exemples de code :

Établir une connexion USB :
knxCon is KNXlib.KnxController
knxCon <- new KNXlib.KnxController()
knxCon.ConnectUSB()

Connectez-vous à la passerelle IP :
knxCon is KNXlib.KnxController
knxCon <- new KNXlib.KnxController()
knxIp is string = "192.168.178.42"
knxCon.Connect(knxIp, 3671, False)

Connectez-vous à la passerelle IP sécurisée :
knxCon is KNXlib.KnxController
knxCon <- new KNXlib.KnxController()
knxIp is string = "192.168.178.42"
knxCon.ConnectSecure(knxIp, 3671, False, "1.1.243", " file.knxkeys", "password")

Envoyer DPT1 :
knxCon.WriteBool("1/0/0" , True)

Envoyer DPT9.1 :
knxCon.WriteValueToDPT(Groupaddress, value as string, DPTupper value, DPTlower value)
knxCon.WriteValueToDPT("11/7/4", "20.5", 9, 1)

A lire :
value is string  = knxCon.ReadValueAsync("11/7/4")

Envoi DPT5.1 :
knxCon.WriteValueToDPT("6/0/9", "90", 5, 1)

Envoi DPT5.4 :
knxCon.WriteValueToDPT("6/0/9", "240", 5, 4)

Lire DPT9.1 :
tempvalue is string = knxCon.ReadValue("11/7/4", 9, 1)

Envoyer la date actuelle :
knxCon.WriteDate("11/5/0")

Envoyer l'heure actuelle :
knxCon.WriteTime("11/5/1")

Envoyer la date actuelle en tant que DPT16 :
knxCon.WriteTimeAsText("11/6/1")

La routine affiche les télégrammes actuellement reçus et démarre une action pour un télégramme spécifique :
IF knxCon.receiveValue.Count > lastcountinfo THEN
    
    IF knxCon.receiveValue.Count >= 100 THEN
        knxCon.receiveValue.Clear()  
        lastcountinfo = 0
        
    ELSE
        
        FOR i = lastcountinfo TO knxCon.receiveValue.Count - 1
            x1 is string = knxCon.GetReceiveDataValueAt(i, "date")
            x2 is string = knxCon.GetReceiveDataValueAt(i, "time")
            x3 is string = knxCon.GetReceiveDataValueAt(i, "paddress")
            x4 is string = knxCon.GetReceiveDataValueAt(i, "gaddress")
            x5 is string = knxCon.GetReceiveDataValueAt(i, "prio")
            x6 is string = knxCon.GetReceiveDataValueAt(i, "issecure")
            x7 is string = knxCon.GetReceiveDataValueAt(i, "hopcount")
            x8 is string = knxCon.GetReceiveDataValueAt(i, "eventtype")
            x9 is string = knxCon.GetReceiveDataValueAt(i, "value")        
                
                IF x4 = "10/0/3" AND x9 = 0 THEN
                    STC_NoName1.Text = "Hit the value !"        
                    knxCon.WriteByte("6/0/9", 10)             
                END
                
            LIST_NoName5.Add(x1 + " - " + x2 + " - " + x3 + " - " + x4 + " - " + x5 + " - " + x6 + " - " + x7 + " - " + x8 + " - " + x9)
        END
        
        lastcountinfo = knxCon.receiveValue.Count
        
        IF LIST_NoName5.Count <> 0 THEN
            ListPosition(LIST_NoName5, LIST_NoName5.Count)
        END
    END
END

Chargement du fichier d'adresses de groupe XML :
knxCon.LoadDptList("knxdptlist.xml")


J'espère que cela vous aidera et que vous vous en sortirez jusqu'à présent. Je n'ai pu le tester que tant que la version démo me le permettait.

Lien de téléchargement :
https://www.knx-board.org/download.php?f...rapper.zip

Bonne chance]]>
Je suis nouveau sur le forum et on m'a demandé si je pouvais aider quelqu'un avec Windev. À ce moment-là, je ne connaissais pas encore ce logiciel, alors je l'ai testé et c'est ainsi que je suis tombé sur ce forum.
J'y ai vu qu'il existait un fil de discussion concernant KNX dans Windev, mais uniquement en lien avec le Falcon SDK 5 et ses fonctionnalités limitées. Le Falcon SDK 6 n'était pas abordé.


Ainsi, j'ai démarré mon premier projet avec Windev et j'ai écrit un wrapper C# pour le Falcon SDK 6.
Ce wrapper utilise les commandes les plus courantes et permet de réaliser un grand nombre de fonctions.

Les fonctionnalités incluent par exemple :

    - Établir une connexion USB
    - Connexion IP, y compris avec des Secure Gateways
    - Envoi de valeurs dans différents DPTS (y compris DPT10, DPT11 et date sous DPT16)
    - Interrogation de valeurs au format Raw ainsi qu'au format DPT
    - Lecture des données reçues, permettant de réagir aux télégrammes entrants
    - Recherche de IP Gateways
    - Recherche de IP Secure Gateways
    - Sauvegarde des 100 derniers télégrammes
    - Chargement de la liste d'adresses de groupe depuis le DPT (export de l'ETS)

Le fichier à télécharger contient un exemple de code que j'ai écrit et testé avec la version gratuite de WinDev 28 Express. Le Falcon SDK 6 est également inclus dans le fichier.
L'exemple de code est un simple moniteur de bus qui, lorsque la liste d'adresses de groupe exportée depuis ETS est ajoutée, affiche également les types DPT (types de points de données) ainsi que les identificateurs textuels correspondants des adresses de groupe.

Avant d'utiliser, il est nécessaire d'enregistrer la DLL signée du Falcon SDK :
1. Copiez le dossier "Falcon SDK 6 Signé" dans vos documents.
2. Ouvrez l'invite de commande (CMD) en tant qu'administrateur.
3. Allez dans le dossier C:\Windows\Microsoft.NET\Framework\v4.0.30319.
4. Enregistrez la DLL avec la commande suivante : regasm "C:\Users\Utilisateur\Documents\Falcon SDK 6 Signé\KNXlib.dll" /tlb:KNXlib.tlb /codebase
5. Ensuite, allez dans le dossier C:\Windows\Microsoft.NET\Framework64\v4.0.30319.
6. Enregistrez à nouveau la DLL avec la même commande : regasm "C:\Users\Utilisateur\Documents\Falcon SDK 6 Signé\KNXlib.dll" /tlb:KNXlib.tlb /codebase
7. Si un message d'erreur indique que l'enregistrement a été bloqué, il peut être nécessaire de désactiver la fonction "Accès protégé aux dossiers".
8. Vous pouvez vérifier l'enregistrement réussi dans le Registre :
   Appuyez sur [Windows]+R et tapez regedit pour ouvrir l'éditeur de registre.
   Vérifiez les chemins suivants :
   Ordinateur\HKEY_CLASSES_ROOT\CLSID{E45D1244-ABCD-4E1D-8D9F-9992B7F017A2} 
   Ordinateur\HKEY_CLASSES_ROOT\WOW6432Node\CLSID{E45D1244-ABCD-4E1D-8D9F-9992B7F017A2}


Exemples de code :

Établir une connexion USB :
knxCon is KNXlib.KnxController
knxCon <- new KNXlib.KnxController()
knxCon.ConnectUSB()

Connectez-vous à la passerelle IP :
knxCon is KNXlib.KnxController
knxCon <- new KNXlib.KnxController()
knxIp is string = "192.168.178.42"
knxCon.Connect(knxIp, 3671, False)

Connectez-vous à la passerelle IP sécurisée :
knxCon is KNXlib.KnxController
knxCon <- new KNXlib.KnxController()
knxIp is string = "192.168.178.42"
knxCon.ConnectSecure(knxIp, 3671, False, "1.1.243", " file.knxkeys", "password")

Envoyer DPT1 :
knxCon.WriteBool("1/0/0" , True)

Envoyer DPT9.1 :
knxCon.WriteValueToDPT(Groupaddress, value as string, DPTupper value, DPTlower value)
knxCon.WriteValueToDPT("11/7/4", "20.5", 9, 1)

A lire :
value is string  = knxCon.ReadValueAsync("11/7/4")

Envoi DPT5.1 :
knxCon.WriteValueToDPT("6/0/9", "90", 5, 1)

Envoi DPT5.4 :
knxCon.WriteValueToDPT("6/0/9", "240", 5, 4)

Lire DPT9.1 :
tempvalue is string = knxCon.ReadValue("11/7/4", 9, 1)

Envoyer la date actuelle :
knxCon.WriteDate("11/5/0")

Envoyer l'heure actuelle :
knxCon.WriteTime("11/5/1")

Envoyer la date actuelle en tant que DPT16 :
knxCon.WriteTimeAsText("11/6/1")

La routine affiche les télégrammes actuellement reçus et démarre une action pour un télégramme spécifique :
IF knxCon.receiveValue.Count > lastcountinfo THEN
    
    IF knxCon.receiveValue.Count >= 100 THEN
        knxCon.receiveValue.Clear()  
        lastcountinfo = 0
        
    ELSE
        
        FOR i = lastcountinfo TO knxCon.receiveValue.Count - 1
            x1 is string = knxCon.GetReceiveDataValueAt(i, "date")
            x2 is string = knxCon.GetReceiveDataValueAt(i, "time")
            x3 is string = knxCon.GetReceiveDataValueAt(i, "paddress")
            x4 is string = knxCon.GetReceiveDataValueAt(i, "gaddress")
            x5 is string = knxCon.GetReceiveDataValueAt(i, "prio")
            x6 is string = knxCon.GetReceiveDataValueAt(i, "issecure")
            x7 is string = knxCon.GetReceiveDataValueAt(i, "hopcount")
            x8 is string = knxCon.GetReceiveDataValueAt(i, "eventtype")
            x9 is string = knxCon.GetReceiveDataValueAt(i, "value")        
                
                IF x4 = "10/0/3" AND x9 = 0 THEN
                    STC_NoName1.Text = "Hit the value !"        
                    knxCon.WriteByte("6/0/9", 10)             
                END
                
            LIST_NoName5.Add(x1 + " - " + x2 + " - " + x3 + " - " + x4 + " - " + x5 + " - " + x6 + " - " + x7 + " - " + x8 + " - " + x9)
        END
        
        lastcountinfo = knxCon.receiveValue.Count
        
        IF LIST_NoName5.Count <> 0 THEN
            ListPosition(LIST_NoName5, LIST_NoName5.Count)
        END
    END
END

Chargement du fichier d'adresses de groupe XML :
knxCon.LoadDptList("knxdptlist.xml")


J'espère que cela vous aidera et que vous vous en sortirez jusqu'à présent. Je n'ai pu le tester que tant que la version démo me le permettait.

Lien de téléchargement :
https://www.knx-board.org/download.php?f...rapper.zip

Bonne chance]]> <![CDATA[DOMOVEA TJA450 hs bascule vers JEEDOM]]> https://www.knx-fr.com/showthread.php?tid=8642 Fri, 25 Oct 2024 13:51:43 +0000 stephan]]> https://www.knx-fr.com/showthread.php?tid=8642
Suite a une galère avec mon TJA450 qui viens de me lâcher, j'ai installé JEEDOM 4 + plugin KNK sur un Raspebby 4.
Install sans souci et ma passerelle SIEMENS dialogue bien avec jeedom (quand j'allume une lumière depuis l'interrupteur j'ai une remonté sur le bus jeedom).

Toute ma maison est sous ETS5 et est fonctionnelle sauf que je n'ai plus les programmations des volet roulants ouverture et fermeture a certaine heure.

Je n'arrive pas voir comment recréé mes Groupe d'adresse et les actionneurs sur JEEDOM et comme un pépin n'arrive jamais seul, nous partons en congé dimanche et pas envie que la maison soit fermé pendant notre absence.

L'un d'entre aurait il un tuto ou un exemple pour que j'arrive a cree rapidement l'ouverture et fermeture des volets sur jeedom

MErci a tous pour votre aide

 Stephane]]>
Suite a une galère avec mon TJA450 qui viens de me lâcher, j'ai installé JEEDOM 4 + plugin KNK sur un Raspebby 4.
Install sans souci et ma passerelle SIEMENS dialogue bien avec jeedom (quand j'allume une lumière depuis l'interrupteur j'ai une remonté sur le bus jeedom).

Toute ma maison est sous ETS5 et est fonctionnelle sauf que je n'ai plus les programmations des volet roulants ouverture et fermeture a certaine heure.

Je n'arrive pas voir comment recréé mes Groupe d'adresse et les actionneurs sur JEEDOM et comme un pépin n'arrive jamais seul, nous partons en congé dimanche et pas envie que la maison soit fermé pendant notre absence.

L'un d'entre aurait il un tuto ou un exemple pour que j'arrive a cree rapidement l'ouverture et fermeture des volets sur jeedom

MErci a tous pour votre aide

 Stephane]]> <![CDATA[[NR] Section Node-RED]]> https://www.knx-fr.com/showthread.php?tid=8601 Thu, 19 Sep 2024 09:57:58 +0000 filou59]]> https://www.knx-fr.com/showthread.php?tid=8601
On associe souvent Node-RED a Home Assistant, mais ce sont 2 choses différentes.

Pensez-vous qu'il faille mettre en place une section dédié a Node-RED ?
Ou est-ce que l'on classe les sujets Node-RED dans HA ?]]>
On associe souvent Node-RED a Home Assistant, mais ce sont 2 choses différentes.

Pensez-vous qu'il faille mettre en place une section dédié a Node-RED ?
Ou est-ce que l'on classe les sujets Node-RED dans HA ?]]> <![CDATA[Cherche Aide pour un petit Script]]> https://www.knx-fr.com/showthread.php?tid=8582 Thu, 12 Sep 2024 07:55:05 +0000 filou59]]> https://www.knx-fr.com/showthread.php?tid=8582
Comme j'ai commencé a l'expliqué ici je suis en train de traduire des produits du projet OpenKNX fait par des allemand.

On a donc 2 type de chose a traduire, un fichier XML, puis des fichiers texte qui contiennent l'aide interactive dans ETS.

Dans le fichier XML on par exemple ceci : 
<Enumeration Text="Präsenzmelder" Value="2" Id="M-00FA_A-A012-32-0000_PT-ModuleSelector_EN-2" />
<ParameterSeparator Id="M-00FA_A-A012-32-0000_PS-212" Text="In der gesamten Applikation wird vom Präsenzmelder gesprochen. Ob sich die Applikation als Präsenz- oder als Bewegungsmelder verhält, wird von der verwendeten Hardware (Präsenz-Sensor) bestimmt." />[/code]

Pour le moment j'ai fais du Recherche et Remplace dans Notepad++ pour valider le concept et pour voir si ca fonctionne ensuite dans ETS, comme je ne regénère pas une nouvelle version d'application il faut ruser un peu, mais bon ca marche et le problème est pas là.

Je souhaiterais automatiser la traduction, faire une petite application ou un script qui fasse le boulot : 
L'idée serait de rechercher toute les occurence d'une chaine de caractère avec les guillemets et de la remplacer par une autre
Le script devrait parcourir un fichier CSV qui contiendrait le dico de conversion :
Exemple :
Code :
original,change to
"Präsenzmelder","Détecteur de présence"
"Ja","Oui"

Pourquoi je précise avec les guillemets, car un même mot peu etre utilisé dans plusieurs context, seul ou dans une phrase ou dans un groupe de mot :
Exemple ici :
"In der gesamten Applikation wird vom Präsenzmelder gesprochen. Ob sich die Applikation als Präsenz- oder als Bewegungsmelder verhält, wird von der verwendeten Hardware (Präsenz-Sensor) bestimmt."
si on remplace d'abord Präsenzmelder et que l'on recherche ensuite l'occurence de la phrase complete elle ne sera plus trouvé et on ne pourra pas la traduire par ca :
"Dans toute l'application, on parle de détecteur de présence. C'est le matériel utilisé (capteur de présence) qui détermine si l'application se comporte comme un détecteur de présence ou comme un détecteur de mouvement"

J'ai trouvé un script python qui fonctionne mais sans les guillemets, je pense pas que ce soit bien compliqué pour qq maitrisant la prog, donc si qq a une solution, ce serait sympa
Code :
import lxml.html   # check https://pypi.org/project/lxml/
from csv import reader
from os.path import exists
import glob


def update_xml(path: str) -> None:
    with open('./convertions.csv', 'r') as convertions, open(path, 'r') as annotation:  # noqa: E501
        tree = lxml.html.fromstring(annotation.read())
        csv_reader = reader(convertions)

        for idx, row in enumerate(csv_reader, start=1):
            if idx == 1:
                continue

            original, change_to = row

            tags = tree.xpath(f".//name[text()='{original}']")

            for tag in tags:
                tag.text = change_to

                print(f'Changed class {original} to {change_to} in {path}')

    with open(path, 'wb') as annotation:
        new_content = lxml.html.tostring(tree)

        if new_content.strip():
            annotation.write(new_content)

    print(f'Processing on {path} done')


if __name__ == '__main__':
    for xml_file in glob.glob('*.xml'):
        if exists(xml_file):
            update_xml(path=xml_file)
]]>
Comme j'ai commencé a l'expliqué ici je suis en train de traduire des produits du projet OpenKNX fait par des allemand.

On a donc 2 type de chose a traduire, un fichier XML, puis des fichiers texte qui contiennent l'aide interactive dans ETS.

Dans le fichier XML on par exemple ceci : 
<Enumeration Text="Präsenzmelder" Value="2" Id="M-00FA_A-A012-32-0000_PT-ModuleSelector_EN-2" />
<ParameterSeparator Id="M-00FA_A-A012-32-0000_PS-212" Text="In der gesamten Applikation wird vom Präsenzmelder gesprochen. Ob sich die Applikation als Präsenz- oder als Bewegungsmelder verhält, wird von der verwendeten Hardware (Präsenz-Sensor) bestimmt." />[/code]

Pour le moment j'ai fais du Recherche et Remplace dans Notepad++ pour valider le concept et pour voir si ca fonctionne ensuite dans ETS, comme je ne regénère pas une nouvelle version d'application il faut ruser un peu, mais bon ca marche et le problème est pas là.

Je souhaiterais automatiser la traduction, faire une petite application ou un script qui fasse le boulot : 
L'idée serait de rechercher toute les occurence d'une chaine de caractère avec les guillemets et de la remplacer par une autre
Le script devrait parcourir un fichier CSV qui contiendrait le dico de conversion :
Exemple :
Code :
original,change to
"Präsenzmelder","Détecteur de présence"
"Ja","Oui"

Pourquoi je précise avec les guillemets, car un même mot peu etre utilisé dans plusieurs context, seul ou dans une phrase ou dans un groupe de mot :
Exemple ici :
"In der gesamten Applikation wird vom Präsenzmelder gesprochen. Ob sich die Applikation als Präsenz- oder als Bewegungsmelder verhält, wird von der verwendeten Hardware (Präsenz-Sensor) bestimmt."
si on remplace d'abord Präsenzmelder et que l'on recherche ensuite l'occurence de la phrase complete elle ne sera plus trouvé et on ne pourra pas la traduire par ca :
"Dans toute l'application, on parle de détecteur de présence. C'est le matériel utilisé (capteur de présence) qui détermine si l'application se comporte comme un détecteur de présence ou comme un détecteur de mouvement"

J'ai trouvé un script python qui fonctionne mais sans les guillemets, je pense pas que ce soit bien compliqué pour qq maitrisant la prog, donc si qq a une solution, ce serait sympa
Code :
import lxml.html   # check https://pypi.org/project/lxml/
from csv import reader
from os.path import exists
import glob


def update_xml(path: str) -> None:
    with open('./convertions.csv', 'r') as convertions, open(path, 'r') as annotation:  # noqa: E501
        tree = lxml.html.fromstring(annotation.read())
        csv_reader = reader(convertions)

        for idx, row in enumerate(csv_reader, start=1):
            if idx == 1:
                continue

            original, change_to = row

            tags = tree.xpath(f".//name[text()='{original}']")

            for tag in tags:
                tag.text = change_to

                print(f'Changed class {original} to {change_to} in {path}')

    with open(path, 'wb') as annotation:
        new_content = lxml.html.tostring(tree)

        if new_content.strip():
            annotation.write(new_content)

    print(f'Processing on {path} done')


if __name__ == '__main__':
    for xml_file in glob.glob('*.xml'):
        if exists(xml_file):
            update_xml(path=xml_file)
]]> <![CDATA[[pKNyX] Nouveautés]]> https://www.knx-fr.com/showthread.php?tid=8549 Sat, 03 Aug 2024 08:23:41 +0000 fma38]]> https://www.knx-fr.com/showthread.php?tid=8549
Voilà une paire d'année que j'ai quelques services basés sur mon framework pKNyX, qui tournent H24 sans aucun souci.

Mais pKNyX a été initialement développé en Python2, et aujourd'hui, cette version de Python est abandonnée sur la plupart des distros linux.

Du coup, je viens de le migrer pour Python3 !

https://framagit.org/fma38/pKNyX

(il faut que je génère un nouveau tag stable, j'ai fait des corrections depuis le tag 1.1.0).

L'idée derrière pKNyX a toujours été de créer des devices virtuels. J'ai par exemple une passerelle pour ma VMC double flux Helios, qui tourne sur mon ancien routeur, lequel sert plus qu'à ça depuis que j'ai la fibre. C'est un peu ballo ! Du coup, je me suis lancé dans la migration pour Micropython, afin de pouvoir faire tourner cette passerelle sur une carte à microcontrôleur genre RPi Pico W, ou à base d'ESP32.

La seconde étape a donc été de migrer les threads vers les coroutines (asyncio) :

https://framagit.org/fma38/pKNyX/-/tree/...type=heads

Enfin, j'ai créé une nouvelle version, nommée, upKNyX, spécifiquement conçue pour tourner sous Micropython. Le dépôt n'est pas encore public, mais sachez que ça marche déjà nickel sur le portage linux de Micropython !

Hier soir, j'ai fait un déploiement rapide sur une RPi Pico W, et je tombe sur un premier souci qui est l'occupation mémoire ; il va falloir que j'optimise les choses, et sans doute que je taille dans le gras pour alléger le truc. J'espère pouvoir garder l'esprit, qui est de pouvoir déployer des choses de manière super simple.

L'autre souci, c'est que pour le moment, les trames Multicast n'ont pas l'air de passer... Je ferai un test sur ESP32, pour voir si ça ne vient pas du chip wifi de la Pico W.

Voili-voilou. Je ne sais pas si ça intéressera beaucoup de monde, mais de mon côté, ça va bien me servir. N'hésitez pas à commenter/suggérer !]]>
Voilà une paire d'année que j'ai quelques services basés sur mon framework pKNyX, qui tournent H24 sans aucun souci.

Mais pKNyX a été initialement développé en Python2, et aujourd'hui, cette version de Python est abandonnée sur la plupart des distros linux.

Du coup, je viens de le migrer pour Python3 !

https://framagit.org/fma38/pKNyX

(il faut que je génère un nouveau tag stable, j'ai fait des corrections depuis le tag 1.1.0).

L'idée derrière pKNyX a toujours été de créer des devices virtuels. J'ai par exemple une passerelle pour ma VMC double flux Helios, qui tourne sur mon ancien routeur, lequel sert plus qu'à ça depuis que j'ai la fibre. C'est un peu ballo ! Du coup, je me suis lancé dans la migration pour Micropython, afin de pouvoir faire tourner cette passerelle sur une carte à microcontrôleur genre RPi Pico W, ou à base d'ESP32.

La seconde étape a donc été de migrer les threads vers les coroutines (asyncio) :

https://framagit.org/fma38/pKNyX/-/tree/...type=heads

Enfin, j'ai créé une nouvelle version, nommée, upKNyX, spécifiquement conçue pour tourner sous Micropython. Le dépôt n'est pas encore public, mais sachez que ça marche déjà nickel sur le portage linux de Micropython !

Hier soir, j'ai fait un déploiement rapide sur une RPi Pico W, et je tombe sur un premier souci qui est l'occupation mémoire ; il va falloir que j'optimise les choses, et sans doute que je taille dans le gras pour alléger le truc. J'espère pouvoir garder l'esprit, qui est de pouvoir déployer des choses de manière super simple.

L'autre souci, c'est que pour le moment, les trames Multicast n'ont pas l'air de passer... Je ferai un test sur ESP32, pour voir si ça ne vient pas du chip wifi de la Pico W.

Voili-voilou. Je ne sais pas si ça intéressera beaucoup de monde, mais de mon côté, ça va bien me servir. N'hésitez pas à commenter/suggérer !]]> <![CDATA[Frigate NVR]]> https://www.knx-fr.com/showthread.php?tid=8519 Thu, 09 May 2024 21:55:03 +0000 filou59]]> https://www.knx-fr.com/showthread.php?tid=8519 Frigate c'est quoi : C'est un NVR open source 

NVR : Network Video Recorder, Un truc qui permet d'enregistrer les video de vos caméra en gros  Big Grin Big Grin 

Voici la présentation tiré de leur site :

Citation :Surveillez vos caméras de sécurité avec une IA traitée localement

Frigate est un NVR open source construit autour de la détection d'objets IA en temps réel. Tout le traitement est effectué localement sur votre propre matériel et les flux de vos caméras ne quittent jamais votre domicile.

Home Assistant: 
Frigate s'intègre facilement a HA.
Peut importe la méthode, je vous conseille d'installer Frigate de maniere séparé a Home Assistant. Ca peut être sur la meme machine mais dans une VM ou un container a part.

Materiel Recommandé :
Vous trouverez le materiel recommandé : https://docs.frigate.video/frigate/hardware
Pour un bien Frigate necessite du materiel capable de faire la travail d'analyse video, pour eviter que ca passe par le CPU il existe des petites cartes qui permettent de faire ce travail. 
Frigate appel ca : Detectors.
Les plus connu sont probablement les Google Coral, qui existe en plusieurs version : USB/NVMe/M.2...
Mais il y a aussi du materiel récent qui embarque des détecteurd compatible sur des architecture Intel/AMD...

Avant de vous jeter sur l'achat d'un module, réfléchissez bien a comment vous allez faire tourner Frigate, cherchez des tuto a la recherche de toutes les astuces.

Il faut aussi penser DDur, il y a des série qui sont plus approprié a ce type d'usage qui sollicité en permanence les ddur.

Comment on fait tourner ca : 
On peut le faire tourner de plusieurs façon :
  1. Sur une machine dédié
  2. Sur une VM (Dans Proxmox par exemple)
  3. Dans un container LXC (plusieurs manière aussi de faire je pense là aussi)
  4. ...
Installation de Frigate :

Frigrate tourne normalement sous Docker.


1. Sur une Machine Dédié : 
Il n'y a qu'a suivre le site
Cette méthode est probablement la plus simple. 

Par contre ca vaut le coup de se donner un peu de peine de regarder un peu coté virtualisation je pense, car la virtualisation apporte pas mal d'atout en therme de backup par exemple. 


2.Sur proxmox : 
Frigate recommande un container LXC plutôt qu'une VM, par contre c'est pas la partie la plus facile. Enfin oui et non, quand on recolte les bonnes info a droite et gauche ca le fait.

Pour une install sur une VM, le passage d'une clé Coral a la VM nécessite quand même quelque manip. C'est pas forcément le plus simple.
On trouve des tuto sur le NET, mais attention, en fonction de votre plateforme Intel/AMD il faudra adapter certaine étape.

Option 1 : Sur une VM
Creer une VM Debian ou ubuntu
Installer Docker
Installer Frigate
* Si on utilise un Detecteur Type Google Coral, il faudra faire du Passthrough de périphérique PCIe/USB

Option 2 : Dans CT LXC via Script tteck
tteck propose un script d'installation de Frigate pour un Container LXC, il me semble qu'il n'utilise pas docker.

Citation :Frigate LXC
Frigate is an open source NVR built around real-time AI object detection. All processing is performed locally on your own hardware, and your camera feeds never leave your home.
To create a new Proxmox VE Frigate LXC, run the command below in the Proxmox VE Shell.
Copy
Code :
bash -c "$(wget -qLO - https://github.com/tteck/Proxmox/raw/main/ct/frigate.sh)"

⚡ Default Settings: 1GB RAM - 20GB Storage - 4vCPU ⚡
Frigate Interface: IP:5000
go2rtc Interface: IP:1984

Option 3 : Dans CT LXC via Docker
Créer un CT LXC Debian 12
Configuration du Passthrough : Il faut configurer le CT pour que l'on passe la clé USB* ou NVMe au CT
Installer Docker
Installer Frigate

*Le passage de clé USB au container peu paraitre déroutant, car la clé change de nom quand elle n'a pas encore été utilisé et ensuite quand les drivers sont chargé (une histoire comme ca). Du coup ca complique les choses quand on veut dire a proxmox qu'il faut passer la Clé Toto quand elle s'appellait Titi 2s avant.  Big Grin
Mais pas panique il y des solutions.



Quelques Liens utiles :

Bon avant de vous donner plus de détail : voici qq lien qui peuvent être utile : 
Raynox : VM + Clé Coral USB
https://www.youtube.com/watch?v=jEgKU5U4kGw

apalrd : LXC + Podman  (alternative a Docker) + Coral PCIe
https://www.apalrd.net/posts/2023/ultimate_frigate/
https://www.youtube.com/watch?v=sCkswrK0...0&index=12

Raspberry Pi Cloud (Video En allemand, mais avec les sous titre ... )
Install tteck 
https://www.youtube.com/watch?v=OHnLHljs_jo

De mon coté j'ai 3 Clé Coral : USB/PCIe Dual TPU (De mémoire)/M2. Histoire d'avoir le choix du matériel.
Je n'ai pas de config hyper récente, mais je n'ai pas non plus chercher a savoir 

En cours de rédaction.]]> Frigate c'est quoi : C'est un NVR open source 

NVR : Network Video Recorder, Un truc qui permet d'enregistrer les video de vos caméra en gros  Big Grin Big Grin 

Voici la présentation tiré de leur site :

Citation :Surveillez vos caméras de sécurité avec une IA traitée localement

Frigate est un NVR open source construit autour de la détection d'objets IA en temps réel. Tout le traitement est effectué localement sur votre propre matériel et les flux de vos caméras ne quittent jamais votre domicile.

Home Assistant: 
Frigate s'intègre facilement a HA.
Peut importe la méthode, je vous conseille d'installer Frigate de maniere séparé a Home Assistant. Ca peut être sur la meme machine mais dans une VM ou un container a part.

Materiel Recommandé :
Vous trouverez le materiel recommandé : https://docs.frigate.video/frigate/hardware
Pour un bien Frigate necessite du materiel capable de faire la travail d'analyse video, pour eviter que ca passe par le CPU il existe des petites cartes qui permettent de faire ce travail. 
Frigate appel ca : Detectors.
Les plus connu sont probablement les Google Coral, qui existe en plusieurs version : USB/NVMe/M.2...
Mais il y a aussi du materiel récent qui embarque des détecteurd compatible sur des architecture Intel/AMD...

Avant de vous jeter sur l'achat d'un module, réfléchissez bien a comment vous allez faire tourner Frigate, cherchez des tuto a la recherche de toutes les astuces.

Il faut aussi penser DDur, il y a des série qui sont plus approprié a ce type d'usage qui sollicité en permanence les ddur.

Comment on fait tourner ca : 
On peut le faire tourner de plusieurs façon :
  1. Sur une machine dédié
  2. Sur une VM (Dans Proxmox par exemple)
  3. Dans un container LXC (plusieurs manière aussi de faire je pense là aussi)
  4. ...
Installation de Frigate :

Frigrate tourne normalement sous Docker.


1. Sur une Machine Dédié : 
Il n'y a qu'a suivre le site
Cette méthode est probablement la plus simple. 

Par contre ca vaut le coup de se donner un peu de peine de regarder un peu coté virtualisation je pense, car la virtualisation apporte pas mal d'atout en therme de backup par exemple. 


2.Sur proxmox : 
Frigate recommande un container LXC plutôt qu'une VM, par contre c'est pas la partie la plus facile. Enfin oui et non, quand on recolte les bonnes info a droite et gauche ca le fait.

Pour une install sur une VM, le passage d'une clé Coral a la VM nécessite quand même quelque manip. C'est pas forcément le plus simple.
On trouve des tuto sur le NET, mais attention, en fonction de votre plateforme Intel/AMD il faudra adapter certaine étape.

Option 1 : Sur une VM
Creer une VM Debian ou ubuntu
Installer Docker
Installer Frigate
* Si on utilise un Detecteur Type Google Coral, il faudra faire du Passthrough de périphérique PCIe/USB

Option 2 : Dans CT LXC via Script tteck
tteck propose un script d'installation de Frigate pour un Container LXC, il me semble qu'il n'utilise pas docker.

Citation :Frigate LXC
Frigate is an open source NVR built around real-time AI object detection. All processing is performed locally on your own hardware, and your camera feeds never leave your home.
To create a new Proxmox VE Frigate LXC, run the command below in the Proxmox VE Shell.
Copy
Code :
bash -c "$(wget -qLO - https://github.com/tteck/Proxmox/raw/main/ct/frigate.sh)"

⚡ Default Settings: 1GB RAM - 20GB Storage - 4vCPU ⚡
Frigate Interface: IP:5000
go2rtc Interface: IP:1984

Option 3 : Dans CT LXC via Docker
Créer un CT LXC Debian 12
Configuration du Passthrough : Il faut configurer le CT pour que l'on passe la clé USB* ou NVMe au CT
Installer Docker
Installer Frigate

*Le passage de clé USB au container peu paraitre déroutant, car la clé change de nom quand elle n'a pas encore été utilisé et ensuite quand les drivers sont chargé (une histoire comme ca). Du coup ca complique les choses quand on veut dire a proxmox qu'il faut passer la Clé Toto quand elle s'appellait Titi 2s avant.  Big Grin
Mais pas panique il y des solutions.



Quelques Liens utiles :

Bon avant de vous donner plus de détail : voici qq lien qui peuvent être utile : 
Raynox : VM + Clé Coral USB
https://www.youtube.com/watch?v=jEgKU5U4kGw

apalrd : LXC + Podman  (alternative a Docker) + Coral PCIe
https://www.apalrd.net/posts/2023/ultimate_frigate/
https://www.youtube.com/watch?v=sCkswrK0...0&index=12

Raspberry Pi Cloud (Video En allemand, mais avec les sous titre ... )
Install tteck 
https://www.youtube.com/watch?v=OHnLHljs_jo

De mon coté j'ai 3 Clé Coral : USB/PCIe Dual TPU (De mémoire)/M2. Histoire d'avoir le choix du matériel.
Je n'ai pas de config hyper récente, mais je n'ai pas non plus chercher a savoir 

En cours de rédaction.]]>