{"id":7166,"date":"2024-07-28T07:41:01","date_gmt":"2024-07-28T07:41:01","guid":{"rendered":"http:\/\/172.30.70.55\/?p=7166"},"modified":"2024-08-23T21:08:40","modified_gmt":"2024-08-23T21:08:40","slug":"apc-pdu-snmp-to-mqtt","status":"publish","type":"post","link":"https:\/\/phixd.us\/?p=7166","title":{"rendered":"APC PDU – SNMP to MQTT"},"content":{"rendered":"\n

Guide for SNMP and MQTT Integration Script<\/strong><\/h2>\n\n\n\n

This is a script I developed to retrieve status information from my APC PDU. While there may be other solutions available, I chose to create my own and integrate it with MQTT discovery so it could seamlessly integrate with Home Assistant. This setup has worked reliably for me for months. I’m always open to suggestions for improvement and hope you find it useful.<\/p>\n\n\n\n

<\/div>\n\n\n\n

Prerequisites<\/strong><\/h3>\n\n\n\n
    \n
  1. Python Environment<\/strong>: Ensure you have Python installed on your system.<\/li>\n\n\n\n
  2. Python Packages<\/strong>: Install the required packages using…<\/li>\n<\/ol>\n\n\n\n
    <\/div>\n\n\n\n
    <\/path><\/path><\/svg><\/span>
    pip<\/span> <\/span>install<\/span> <\/span>paho<\/span>-<\/span>mqtt<\/span>==<\/span>1.6<\/span>.<\/span>1<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
    <\/div>\n\n\n\n
      \n
    1. SNMP Enabled Device<\/strong>: You need a device with SNMP enabled.<\/li>\n\n\n\n
    2. MQTT Broker<\/strong>: Ensure you have access to an MQTT broker.<\/li>\n<\/ol>\n\n\n\n
      <\/div>\n\n\n\n
      Docker Option<\/strong><\/h4>\n\n\n\n
      <\/div>\n\n\n\n
      1. Create the Python Script<\/strong><\/h4>\n\n\n\n
      Save your Python script as apc2mqtt.py<\/code> in the your preferred directory in this example \/opt\/scripts.<\/p>\n\n\n\n
      <\/div>\n\n\n\n
      2. Create a Dockerfile<\/strong><\/h4>\n\n\n\n
      Create a Dockerfile<\/code> in the same directory where your apc2mqtt.py<\/code> script is located:<\/p>\n\n\n\n
      <\/path><\/path><\/svg><\/span>
      DockerfileCopy<\/span> <\/span>code<\/span># <\/span>Use<\/span> <\/span>the<\/span> <\/span>official<\/span> <\/span>Python<\/span> <\/span>image<\/span> <\/span>as<\/span> <\/span>a<\/span> <\/span>base<\/span><\/span>\nFROM<\/span> <\/span>python<\/span>:<\/span>3.9<\/span>-<\/span>slim<\/span><\/span>\n<\/span>\n# <\/span>Set<\/span> <\/span>the<\/span> <\/span>working<\/span> <\/span>directory<\/span><\/span>\nWORKDIR<\/span> \/<\/span>opt<\/span>\/<\/span>scripts<\/span><\/span>\n<\/span>\n# <\/span>Copy<\/span> <\/span>the<\/span> <\/span>requirements<\/span> <\/span>file<\/span><\/span>\nCOPY<\/span> <\/span>requirements<\/span>.<\/span>txt<\/span> .<\/span><\/span>\n<\/span>\n# <\/span>Install<\/span> <\/span>the<\/span> <\/span>required<\/span> <\/span>Python<\/span> <\/span>packages<\/span><\/span>\nRUN<\/span> <\/span>pip<\/span> <\/span>install<\/span> --<\/span>no<\/span>-<\/span>cache<\/span>-<\/span>dir<\/span> -<\/span>r<\/span> <\/span>requirements<\/span>.<\/span>txt<\/span><\/span>\n<\/span>\n# <\/span>Copy<\/span> <\/span>the<\/span> <\/span>Python<\/span> <\/span>script<\/span><\/span>\nCOPY<\/span> <\/span>apc2mqtt<\/span>.<\/span>py<\/span> .<\/span><\/span>\n<\/span>\n# <\/span>Command<\/span> <\/span>to<\/span> <\/span>run<\/span> <\/span>the<\/span> <\/span>script<\/span><\/span>\nCMD<\/span> [<\/span>"python"<\/span>, <\/span>"apc2mqtt.py"<\/span>]<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
      <\/div>\n\n\n\n
      3. Create a Requirements File<\/h4>\n\n\n\n
      Create a requirements.txt<\/code> file in the same directory to specify the dependencies:<\/p>\n\n\n\n
      <\/div>\n\n\n\n
      <\/path><\/path><\/svg><\/span>
      paho<\/span>-<\/span>mqtt<\/span>==<\/span>1.6<\/span>.<\/span>1<\/span><\/span>\npysnmp<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
      <\/div>\n\n\n\n
      4. Create a Docker Compose File<\/h4>\n\n\n\n
      Create a docker-compose.yml<\/code> file in the same directory:<\/p>\n\n\n\n
      <\/div>\n\n\n\n
      <\/path><\/path><\/svg><\/span>
      codeversion<\/span>: <\/span>"3"<\/span><\/span>\nservices<\/span>:<\/span><\/span>\n  <\/span>apc2mqtt<\/span>-<\/span>servers<\/span>:<\/span><\/span>\n    <\/span>build<\/span>:<\/span><\/span>\n      <\/span>context<\/span>: .<\/span><\/span>\n      <\/span>dockerfile<\/span>: <\/span>Dockerfile<\/span><\/span>\n    <\/span>volumes<\/span>:<\/span><\/span>\n      - \/<\/span>opt<\/span>\/<\/span>scripts<\/span>:\/<\/span>opt<\/span>\/<\/span>scripts<\/span><\/span>\n    <\/span>command<\/span>: <\/span>python<\/span> \/<\/span>opt<\/span>\/<\/span>scripts<\/span>\/<\/span>apc2mqtt<\/span>.<\/span>py<\/span><\/span>\n    <\/span>restart<\/span>: <\/span>always<\/span><\/span>\n    <\/span>networks<\/span>:<\/span><\/span>\n      - <\/span>apc2mqtt<\/span>-<\/span>net<\/span><\/span>\n<\/span>\nnetworks<\/span>:<\/span><\/span>\n  <\/span>apc2mqtt<\/span>-<\/span>net<\/span>:<\/span><\/span>\n    <\/span>driver<\/span>: <\/span>bridge<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
      <\/div>\n\n\n\n
      5. Build and Run the Docker Container<\/strong><\/h4>\n\n\n\n
      Navigate to the directory containing your Dockerfile<\/code> and docker-compose.yml<\/code> and run the following commands:<\/p>\n\n\n\n
        \n
      1. Build the Docker image:<\/strong><\/li>\n<\/ol>\n\n\n\n
        <\/div>\n\n\n\n
        <\/path><\/path><\/svg><\/span>
        docker<\/span>-<\/span>compose<\/span> <\/span>build<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
        <\/div>\n\n\n\n
          \n
        1. Run the Docker container:<\/strong><\/li>\n<\/ol>\n\n\n\n
          <\/div>\n\n\n\n
          <\/path><\/path><\/svg><\/span>
          docker<\/span>-<\/span>compose<\/span> <\/span>up<\/span> -<\/span>d<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
          <\/div>\n\n\n\n
          <\/div>\n\n\n\n
          Configuration<\/strong><\/h3>\n\n\n\n
            \n
          1. SNMP Configuration:<\/strong>\n
              \n
            • snmp_ip_address<\/code>: The IP address of the SNMP-enabled device.<\/li>\n\n\n\n
            • community_string<\/code>: The SNMP community string (usually ‘public’).<\/li>\n<\/ul>\n<\/li>\n\n\n\n
            • MQTT Configuration:<\/strong>\n
                \n
              • mqtt_broker<\/code>: The IP address of your MQTT broker.<\/li>\n\n\n\n
              • mqtt_port<\/code>: The port your MQTT broker is listening on (default is 1883).<\/li>\n\n\n\n
              • mqtt_user<\/code>: MQTT username.<\/li>\n\n\n\n
              • mqtt_password<\/code>: MQTT password.<\/li>\n\n\n\n
              • device_id<\/code>: A unique identifier for your device (e.g., ‘servers’).<\/li>\n\n\n\n
              • debug_mode<\/code>: Set to True<\/code> for verbose debug logging.<\/li>\n<\/ul>\n<\/li>\n\n\n\n
              • Polling Interval:<\/strong>\n
                  \n
                • sleep_duration<\/code>: Time in seconds between each status poll and publish cycle.<\/li>\n<\/ul>\n<\/li>\n<\/ol>\n\n\n\n
                  <\/div>\n\n\n\n
                  Integrating with Home Assistant<\/strong><\/p>\n\n\n\n
                  \n
                  \n
                  This integrates with Home Assistant using MQTT discovery. When the script runs, it publishes discovery messages to the MQTT broker. Home Assistant listens for these messages and automatically configures the corresponding entitier. <\/p>\n\n\n\n
                  <\/div>\n\n\n\n
                  Handling Multiple PDUs<\/strong><\/h3>\n\n\n\n
                  If you have multiple PDUs, you can change the device_id<\/code> in the script configuration to ensure each PDU has a unique identifier. This allows Home Assistant to handle multiple instances without conflicts.<\/p>\n\n\n\n
                  <\/div>\n\n\n\n
                  <\/path><\/path><\/svg><\/span>
                  device_id<\/span> = <\/span>'it_equitment'<\/span><\/span><\/code><\/pre><\/div>\n\n\n\n
                  <\/div>\n\n\n\n
                  Supported PDUs<\/strong><\/h3>\n\n\n\n
                  This script has only been tested with an APC PDU model AP7900. However, it should be straightforward to update the SNMP OIDs in the script to support other models or brands of PDUs.<\/p>\n\n\n\n
                  <\/div>\n<\/div>\n<\/div>\n\n\n\n
                  <\/div>\n\n\n\n
                  Script:<\/strong><\/p>\n\n\n\n
                  <\/circle><\/circle><\/circle><\/g><\/svg><\/span><\/path><\/path><\/svg><\/span>
                  from<\/span> <\/span>pysnmp<\/span>.<\/span>hlapi<\/span> <\/span>import<\/span> <\/span>getCmd<\/span>, <\/span>setCmd<\/span>, <\/span>SnmpEngine<\/span>, <\/span>CommunityData<\/span>, <\/span>UdpTransportTarget<\/span>, <\/span>ContextData<\/span>, <\/span>ObjectType<\/span>, <\/span>ObjectIdentity<\/span>, <\/span>Integer32<\/span><\/span>\nimport<\/span> <\/span>paho<\/span>.<\/span>mqtt<\/span>.<\/span>client<\/span> <\/span>as<\/span> <\/span>mqtt<\/span><\/span>\nimport<\/span> <\/span>paho<\/span>.<\/span>mqtt<\/span>.<\/span>publish<\/span> <\/span>as<\/span> <\/span>publish<\/span><\/span>\nimport<\/span> <\/span>json<\/span><\/span>\nimport<\/span> <\/span>time<\/span><\/span>\n<\/span>\n# <\/span>Configuration<\/span><\/span>\nsnmp_ip_address<\/span> = <\/span>'192.168.1.1'<\/span><\/span>\ncommunity_string<\/span> = <\/span>'public'<\/span><\/span>\nmqtt_broker<\/span> = <\/span>'192.168.1.2'<\/span><\/span>\nmqtt_port<\/span> = 1883<\/span><\/span>\nmqtt_user<\/span> = <\/span>'user'<\/span><\/span>\nmqtt_password<\/span> = <\/span>'password'<\/span><\/span>\ndevice_id<\/span> = <\/span>'it_equitment'<\/span><\/span>\ndebug_mode<\/span> = <\/span>False<\/span><\/span>\n<\/span>\nglobal_port_names<\/span> = {}<\/span><\/span>\n<\/span>\nsleep_duration<\/span> = 25<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>debug_print<\/span>(<\/span>message<\/span>):<\/span><\/span>\n    <\/span>if<\/span> <\/span>debug_mode<\/span>:<\/span><\/span>\n        <\/span>print<\/span>(<\/span>message<\/span>)<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>fetch_snmp_data<\/span>(<\/span>oid<\/span>):<\/span><\/span>\n    <\/span>errorIndication<\/span>, <\/span>errorStatus<\/span>, <\/span>errorIndex<\/span>, <\/span>varBinds<\/span> = <\/span>next<\/span>(<\/span><\/span>\n        <\/span>getCmd<\/span>(<\/span>SnmpEngine<\/span>(),<\/span><\/span>\n               <\/span>CommunityData<\/span>(<\/span>community_string<\/span>, <\/span>mpModel<\/span>=0),<\/span><\/span>\n               <\/span>UdpTransportTarget<\/span>((<\/span>snmp_ip_address<\/span>, 161)),<\/span><\/span>\n               <\/span>ContextData<\/span>(),<\/span><\/span>\n               <\/span>ObjectType<\/span>(<\/span>ObjectIdentity<\/span>(<\/span>oid<\/span>)))<\/span><\/span>\n    )<\/span><\/span>\n    <\/span>if<\/span> <\/span>errorIndication<\/span>:<\/span><\/span>\n        <\/span>debug_print<\/span>(<\/span>f<\/span>"SNMP Fetch Error: {errorIndication}"<\/span>)<\/span><\/span>\n        <\/span>return<\/span> <\/span>None<\/span><\/span>\n    <\/span>elif<\/span> <\/span>errorStatus<\/span>:<\/span><\/span>\n        <\/span>debug_print<\/span>(<\/span>f<\/span>"SNMP Fetch Error Status: {errorStatus.prettyPrint()}"<\/span>)<\/span><\/span>\n        <\/span>return<\/span> <\/span>None<\/span><\/span>\n    <\/span>else<\/span>:<\/span><\/span>\n        <\/span>for<\/span> <\/span>varBind<\/span> <\/span>in<\/span> <\/span>varBinds<\/span>:<\/span><\/span>\n            <\/span>return<\/span> <\/span>varBind<\/span>[1].<\/span>prettyPrint<\/span>()<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>control_port<\/span>(<\/span>snmp_ip_address<\/span>, <\/span>port_num<\/span>, <\/span>state<\/span>, <\/span>client<\/span>):<\/span><\/span>\n    <\/span>oid_base<\/span> = <\/span>'.1.3.6.1.4.1.318.1.1.12.3.3.1.1.4'<\/span><\/span>\n    <\/span>full_oid<\/span> = <\/span>f<\/span>"{oid_base}.{port_num}"<\/span>  <\/span><\/span>\n    <\/span>state_value<\/span> = 1 <\/span>if<\/span> <\/span>state<\/span> == 1 <\/span>else<\/span> 2<\/span><\/span>\n    <\/span><\/span>\n    # <\/span>Log<\/span> <\/span>the<\/span> <\/span>action<\/span> <\/span>being<\/span> <\/span>attempted<\/span><\/span>\n    <\/span>debug_message<\/span> = <\/span>f<\/span>"Preparing to send SNMP set command for port {port_num} to {'on' if state == 1 else 'off'} (value: {state_value}). OID: {full_oid}"<\/span><\/span>\n    <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>debug_message<\/span>)<\/span><\/span>\n    <\/span><\/span>\n    <\/span>try<\/span>:<\/span><\/span>\n        <\/span>errorIndication<\/span>, <\/span>errorStatus<\/span>, <\/span>errorIndex<\/span>, <\/span>varBinds<\/span> = <\/span>next<\/span>(<\/span><\/span>\n            <\/span>setCmd<\/span>(<\/span>SnmpEngine<\/span>(),<\/span><\/span>\n                   <\/span>CommunityData<\/span>(<\/span>'private'<\/span>, <\/span>mpModel<\/span>=0),<\/span><\/span>\n                   <\/span>UdpTransportTarget<\/span>((<\/span>snmp_ip_address<\/span>, 161)),<\/span><\/span>\n                   <\/span>ContextData<\/span>(),<\/span><\/span>\n                   <\/span>ObjectType<\/span>(<\/span>ObjectIdentity<\/span>(<\/span>full_oid<\/span>), <\/span>Integer32<\/span>(<\/span>state_value<\/span>)))<\/span><\/span>\n        )<\/span><\/span>\n        <\/span><\/span>\n        <\/span>if<\/span> <\/span>errorIndication<\/span>:<\/span><\/span>\n            <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"SNMP Error: {errorIndication} for port {port_num}"<\/span>)<\/span><\/span>\n            <\/span>return<\/span><\/span>\n        <\/span>elif<\/span> <\/span>errorStatus<\/span>:<\/span><\/span>\n            <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"SNMP Error: {errorStatus.prettyPrint()} for port {port_num} when attempting to set to {'on' if state == 1 else 'off'}"<\/span>)<\/span><\/span>\n            <\/span>return<\/span><\/span>\n        <\/span>else<\/span>:<\/span><\/span>\n            <\/span>state_str<\/span> = <\/span>'on'<\/span> <\/span>if<\/span> <\/span>state<\/span> == 1 <\/span>else<\/span> <\/span>'off'<\/span><\/span>\n            <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/ports\/{port_num}\/state"<\/span>, <\/span>state_str<\/span>)<\/span><\/span>\n            <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"SNMP set command sent successfully for port {port_num}, updated MQTT with state '{state_str}'."<\/span>)<\/span><\/span>\n    <\/span>except<\/span> <\/span>Exception<\/span> <\/span>as<\/span> <\/span>e<\/span>:<\/span><\/span>\n        <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Exception sending SNMP set command for port {port_num}: {e}"<\/span>)<\/span><\/span>\n<\/span>\n<\/span>\n<\/span>\ndef<\/span> <\/span>format_mac_address<\/span>(<\/span>raw_mac<\/span>):<\/span><\/span>\n    <\/span>if<\/span> <\/span>raw_mac<\/span>.<\/span>lower<\/span>().<\/span>startswith<\/span>(<\/span>"0x"<\/span>):<\/span><\/span>\n        <\/span>raw_mac<\/span> = <\/span>raw_mac<\/span>[2:]<\/span><\/span>\n    <\/span>raw_mac<\/span> = <\/span>raw_mac<\/span>.<\/span>upper<\/span>()<\/span><\/span>\n    <\/span>formatted_mac<\/span> = <\/span>":"<\/span>.<\/span>join<\/span>(<\/span>raw_mac<\/span>[<\/span>i<\/span>:<\/span>i<\/span>+2] <\/span>for<\/span> <\/span>i<\/span> <\/span>in<\/span> <\/span>range<\/span>(0, <\/span>len<\/span>(<\/span>raw_mac<\/span>), 2))<\/span><\/span>\n    <\/span>return<\/span> <\/span>formatted_mac<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>publish_status<\/span>(<\/span>client<\/span>, <\/span>port_num<\/span>=<\/span>None<\/span>):<\/span><\/span>\n    <\/span>global<\/span> <\/span>global_serial<\/span>, <\/span>global_model<\/span>, <\/span>global_mac<\/span>, <\/span>global_port_names<\/span><\/span>\n<\/span>\n    <\/span>global_serial<\/span> = <\/span>'Unknown or Unable to Connect'<\/span><\/span>\n    <\/span>global_model<\/span> = <\/span>'Unknown or Unable to Connect'<\/span><\/span>\n    <\/span>global_mac<\/span> = <\/span>'Unknown or Unable to Connect'<\/span><\/span>\n<\/span>\n    <\/span>serial_temp<\/span> = <\/span>fetch_snmp_data<\/span>(<\/span>'.1.3.6.1.4.1.318.1.1.4.1.5.0'<\/span>)<\/span><\/span>\n    <\/span>model_temp<\/span> = <\/span>fetch_snmp_data<\/span>(<\/span>'.1.3.6.1.4.1.318.1.1.4.1.4.0'<\/span>)<\/span><\/span>\n    <\/span>raw_mac<\/span> = <\/span>fetch_snmp_data<\/span>(<\/span>'.1.3.6.1.2.1.2.2.1.6.2'<\/span>)<\/span><\/span>\n<\/span>\n    <\/span>if<\/span> <\/span>serial_temp<\/span> <\/span>is<\/span> <\/span>not<\/span> <\/span>None<\/span>:<\/span><\/span>\n        <\/span>global_serial<\/span> = <\/span>serial_temp<\/span><\/span>\n    <\/span>if<\/span> <\/span>model_temp<\/span> <\/span>is<\/span> <\/span>not<\/span> <\/span>None<\/span>:<\/span><\/span>\n        <\/span>global_model<\/span> = <\/span>model_temp<\/span><\/span>\n    <\/span>if<\/span> <\/span>raw_mac<\/span> <\/span>is<\/span> <\/span>not<\/span> <\/span>None<\/span>:<\/span><\/span>\n        <\/span>global_mac<\/span> = <\/span>format_mac_address<\/span>(<\/span>raw_mac<\/span>)<\/span><\/span>\n<\/span>\n    <\/span>system_uptime_oid<\/span> = <\/span>'.1.3.6.1.2.1.1.3.0'<\/span><\/span>\n    <\/span>system_uptime_ticks<\/span> = <\/span>fetch_snmp_data<\/span>(<\/span>system_uptime_oid<\/span>)<\/span><\/span>\n    <\/span>if<\/span> <\/span>system_uptime_ticks<\/span> <\/span>is<\/span> <\/span>not<\/span> <\/span>None<\/span>:<\/span><\/span>\n        <\/span>system_uptime_readable<\/span> = <\/span>convert_time_ticks_to_readable_format<\/span>(<\/span>system_uptime_ticks<\/span>)<\/span><\/span>\n        <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/uptime"<\/span>, <\/span>system_uptime_readable<\/span>)<\/span><\/span>\n    <\/span>else<\/span>:<\/span><\/span>\n        <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/uptime"<\/span>, <\/span>"Uptime fetch failed"<\/span>)<\/span><\/span>\n<\/span>\n    <\/span>port_range<\/span> = <\/span>range<\/span>(1, 9) <\/span>if<\/span> <\/span>port_num<\/span> <\/span>is<\/span> <\/span>None<\/span> <\/span>else<\/span> [<\/span>port_num<\/span>]<\/span><\/span>\n<\/span>\n    <\/span>for<\/span> <\/span>port_num<\/span> <\/span>in<\/span> <\/span>port_range<\/span>:<\/span><\/span>\n        <\/span>try<\/span>:<\/span><\/span>\n            <\/span>name_oid<\/span> = <\/span>f<\/span>'1.3.6.1.4.1.318.1.1.12.3.5.1.1.2.{port_num}'<\/span><\/span>\n            <\/span>state_oid<\/span> = <\/span>f<\/span>'1.3.6.1.4.1.318.1.1.12.3.5.1.1.4.{port_num}'<\/span><\/span>\n            <\/span>port_name<\/span> = <\/span>fetch_snmp_data<\/span>(<\/span>name_oid<\/span>) <\/span>or<\/span> <\/span>"Unknown Port Name"<\/span><\/span>\n            <\/span>port_state<\/span> = <\/span>'on'<\/span> <\/span>if<\/span> <\/span>fetch_snmp_data<\/span>(<\/span>state_oid<\/span>) == <\/span>'1'<\/span> <\/span>else<\/span> <\/span>'off'<\/span><\/span>\n            <\/span>global_port_names<\/span>[<\/span>port_num<\/span>] = <\/span>port_name<\/span><\/span>\n<\/span>\n            <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/ports\/{port_num}\/name"<\/span>, <\/span>port_name<\/span>)<\/span><\/span>\n            <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/ports\/{port_num}\/state"<\/span>, <\/span>port_state<\/span>)<\/span><\/span>\n        <\/span>except<\/span> <\/span>Exception<\/span> <\/span>as<\/span> <\/span>e<\/span>:<\/span><\/span>\n            <\/span>print<\/span>(<\/span>f<\/span>"Error updating port {port_num}: {e}"<\/span>)<\/span><\/span>\n<\/span>\n    # <\/span>Publish<\/span> <\/span>global<\/span> <\/span>device<\/span> <\/span>information<\/span><\/span>\n    <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/serial"<\/span>, <\/span>global_serial<\/span>)<\/span><\/span>\n    <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/model"<\/span>, <\/span>global_model<\/span>)<\/span><\/span>\n    <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/mac"<\/span>, <\/span>global_mac<\/span>)<\/span><\/span>\n    <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>f<\/span>"apc_pdu_{device_id}\/status\/identifier"<\/span>, <\/span>device_id<\/span>)<\/span><\/span>\n    <\/span><\/span>\n    # <\/span>Ensure<\/span> <\/span>discovery<\/span> <\/span>messages<\/span> <\/span>are<\/span> <\/span>published<\/span> <\/span>even<\/span> <\/span>if<\/span> <\/span>there<\/span>'s an issu<\/span>e<\/span><\/span>\n    <\/span>try<\/span>:<\/span><\/span>\n        <\/span>publish_discovery_messages<\/span>(<\/span>client<\/span>)<\/span><\/span>\n    <\/span>except<\/span> <\/span>Exception<\/span> <\/span>as<\/span> <\/span>e<\/span>:<\/span><\/span>\n        <\/span>debug_print<\/span>(<\/span>f<\/span>"Error publishing discovery messages: {e}"<\/span>)<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>convert_time_ticks_to_readable_format<\/span>(<\/span>time_ticks<\/span>):<\/span><\/span>\n    <\/span>total_seconds<\/span> = <\/span>int<\/span>(<\/span>time_ticks<\/span>) \/ 100  # <\/span>Convert<\/span> <\/span>TimeTicks<\/span> <\/span>to<\/span> <\/span>seconds<\/span><\/span>\n<\/span>\n    <\/span>days<\/span> = <\/span>total_seconds<\/span> <\/span>\/\/ (24 * 3600)<\/span><\/span>\n    <\/span>total_seconds<\/span> = <\/span>total_seconds<\/span> % (24 <\/span>*<\/span> 3600)<\/span><\/span>\n<\/span>\n    <\/span>hours<\/span> = <\/span>total_seconds<\/span> <\/span>\/\/ 3600<\/span><\/span>\n    <\/span>total_seconds<\/span> %= 3600<\/span><\/span>\n<\/span>\n    <\/span>minutes<\/span> = <\/span>total_seconds<\/span> <\/span>\/\/ 60<\/span><\/span>\n<\/span>\n    <\/span>return<\/span> <\/span>f<\/span>"{int(days)} days, {int(hours)} hours, {int(minutes)} minutes"<\/span><\/span>\n<\/span>\n<\/span>\ndef<\/span> <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>message<\/span>):<\/span><\/span>\n    <\/span>if<\/span> <\/span>debug_mode<\/span>:<\/span><\/span>\n        <\/span>debug_topic<\/span> = <\/span>f<\/span>"apc_pdu_{device_id}\/debug\/logs"<\/span><\/span>\n        <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>debug_topic<\/span>, <\/span>message<\/span>)<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>on_connect<\/span>(<\/span>client<\/span>, <\/span>userdata<\/span>, <\/span>flags<\/span>, <\/span>rc<\/span>):<\/span><\/span>\n    <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Connected with result code {rc}"<\/span>)<\/span><\/span>\n    <\/span>for<\/span> <\/span>port_num<\/span> <\/span>in<\/span> <\/span>range<\/span>(1, 9):<\/span><\/span>\n        <\/span>topic<\/span> = <\/span>f<\/span>"apc_pdu_{device_id}\/control\/ports\/{port_num}"<\/span><\/span>\n        <\/span>client<\/span>.<\/span>subscribe<\/span>(<\/span>topic<\/span>)<\/span><\/span>\n        <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Subscribing to topic: {topic}"<\/span>)<\/span><\/span>\n<\/span>\n<\/span>\ndef<\/span> <\/span>on_message<\/span>(<\/span>client<\/span>, <\/span>userdata<\/span>, <\/span>msg<\/span>):<\/span><\/span>\n    <\/span>message<\/span> = <\/span>msg<\/span>.<\/span>payload<\/span>.<\/span>decode<\/span>(<\/span>'utf-8'<\/span>)<\/span><\/span>\n    <\/span>topic_parts<\/span> = <\/span>msg<\/span>.<\/span>topic<\/span>.<\/span>split<\/span>(<\/span>'\/'<\/span>)<\/span><\/span>\n    <\/span>if<\/span> <\/span>len<\/span>(<\/span>topic_parts<\/span>) != 4:<\/span><\/span>\n        <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Received message on unexpected topic: {msg.topic}"<\/span>)<\/span><\/span>\n        <\/span>return<\/span><\/span>\n<\/span>\n    <\/span>expected_prefix<\/span> = <\/span>f<\/span>'apc_pdu_{device_id}'<\/span><\/span>\n    <\/span>received_prefix<\/span> = <\/span>topic_parts<\/span>[0]<\/span><\/span>\n<\/span>\n    # <\/span>Debug<\/span> <\/span>output<\/span> <\/span>for<\/span> <\/span>diagnostic<\/span> <\/span>purposes<\/span><\/span>\n    <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Diagnostic: Expecting prefix '{expected_prefix}', received '{received_prefix}'"<\/span>)<\/span><\/span>\n<\/span>\n    <\/span>if<\/span> <\/span>received_prefix<\/span> == <\/span>expected_prefix<\/span> <\/span>and<\/span> <\/span>topic_parts<\/span>[1] == <\/span>'control'<\/span> <\/span>and<\/span> <\/span>topic_parts<\/span>[2] == <\/span>'ports'<\/span>:<\/span><\/span>\n        <\/span>try<\/span>:<\/span><\/span>\n            <\/span>port_num<\/span> = <\/span>int<\/span>(<\/span>topic_parts<\/span>[3])<\/span><\/span>\n            <\/span>state<\/span> = 1 <\/span>if<\/span> <\/span>message<\/span>.<\/span>lower<\/span>() == <\/span>'on'<\/span> <\/span>else<\/span> 0  # <\/span>Assuming<\/span> <\/span>'0'<\/span> <\/span>is<\/span> <\/span>the<\/span> <\/span>correct<\/span> <\/span>state<\/span> <\/span>for<\/span> <\/span>'off'<\/span><\/span>\n            <\/span>control_port<\/span>(<\/span>snmp_ip_address<\/span>, <\/span>port_num<\/span>, <\/span>state<\/span>, <\/span>client<\/span>)<\/span><\/span>\n        <\/span>except<\/span> <\/span>ValueError<\/span> <\/span>as<\/span> <\/span>e<\/span>:<\/span><\/span>\n            <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Error processing command for topic {msg.topic}: {e}"<\/span>)<\/span><\/span>\n    <\/span>else<\/span>:<\/span><\/span>\n        <\/span>publish_debug<\/span>(<\/span>client<\/span>, <\/span>f<\/span>"Received message does not match expected structure: {msg.topic}"<\/span>)<\/span><\/span>\n<\/span>\n<\/span>\n<\/span>\ndef<\/span> <\/span>publish_discovery_messages<\/span>(<\/span>client<\/span>):<\/span><\/span>\n    <\/span>global<\/span> <\/span>global_serial<\/span>, <\/span>global_model<\/span>, <\/span>global_mac<\/span>, <\/span>global_port_names<\/span><\/span>\n<\/span>\n    # <\/span>Publishing<\/span> <\/span>for<\/span> <\/span>each<\/span> <\/span>port<\/span><\/span>\n    <\/span>for<\/span> <\/span>port_num<\/span> <\/span>in<\/span> <\/span>range<\/span>(1, 9):<\/span><\/span>\n        <\/span>port_name<\/span> = <\/span>global_port_names<\/span>.<\/span>get<\/span>(<\/span>port_num<\/span>, <\/span>f<\/span>"Port {port_num}"<\/span>)<\/span><\/span>\n        <\/span>device_name<\/span> = <\/span>f<\/span>"Port {port_num} - {port_name}"<\/span><\/span>\n<\/span>\n        <\/span>port_discovery_message<\/span> = {<\/span><\/span>\n            "<\/span>name<\/span>": <\/span>device_name<\/span>,<\/span><\/span>\n            "<\/span>state_topic<\/span>": <\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>device_id<\/span>}\/<\/span>status<\/span>\/<\/span>ports<\/span>\/{<\/span>port_num<\/span>}\/<\/span>state<\/span>"<\/span>,<\/span><\/span>\n            <\/span>"command_topic"<\/span>: <\/span>f<\/span>"apc_pdu_{device_id}\/control\/ports\/{port_num}"<\/span>,<\/span><\/span>\n            <\/span>"unique_id"<\/span>: <\/span>f<\/span>"apc_pdu_port_{port_num}_{global_serial}_{device_id}"<\/span>,<\/span><\/span>\n            <\/span>"icon"<\/span>: <\/span>"mdi:power-plug"<\/span>,<\/span><\/span>\n            <\/span>"device"<\/span>: {<\/span><\/span>\n                "<\/span>identifiers<\/span>": [<\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>snmp_ip_address<\/span>}<\/span>_<\/span>{<\/span>device_id<\/span>}<\/span>"]<\/span>,<\/span><\/span>\n                <\/span>"name"<\/span>: <\/span>f<\/span>"APC PDU {global_model}"<\/span>,<\/span><\/span>\n                <\/span>"model"<\/span>: <\/span>global_model<\/span>,<\/span><\/span>\n                <\/span>"manufacturer"<\/span>: <\/span>"APC"<\/span>,<\/span><\/span>\n            },<\/span><\/span>\n            <\/span>"payload_on"<\/span>: <\/span>"on"<\/span>,<\/span><\/span>\n            <\/span>"payload_off"<\/span>: <\/span>"off"<\/span>,<\/span><\/span>\n            <\/span>"value_template"<\/span>: <\/span>"{{ value if value == 'on' else 'off' }}"<\/span><\/span>\n        }<\/span><\/span>\n<\/span>\n        <\/span>publish<\/span>.<\/span>single<\/span>(<\/span><\/span>\n            <\/span>f<\/span>"homeassistant\/switch\/apc_pdu_{device_id}\/port_{port_num}\/config"<\/span>,<\/span><\/span>\n            <\/span>payload<\/span>=<\/span>json<\/span>.<\/span>dumps<\/span>(<\/span>port_discovery_message<\/span>),<\/span><\/span>\n            <\/span>hostname<\/span>=<\/span>mqtt_broker<\/span>,<\/span><\/span>\n            <\/span>port<\/span>=<\/span>mqtt_port<\/span>,<\/span><\/span>\n            <\/span>auth<\/span>={"<\/span>username<\/span>": <\/span>mqtt_user<\/span>, "<\/span>password<\/span>": <\/span>mqtt_password<\/span>},<\/span><\/span>\n            <\/span>retain<\/span>=<\/span>True<\/span>,<\/span><\/span>\n        )<\/span><\/span>\n<\/span>\n    # <\/span>Serial<\/span> <\/span>Number<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>serial_discovery_message<\/span> = {<\/span><\/span>\n        "<\/span>name<\/span>": "<\/span>Serial<\/span> <\/span>Number<\/span>",<\/span><\/span>\n        "<\/span>state_topic<\/span>": <\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>device_id<\/span>}\/<\/span>status<\/span>\/<\/span>serial<\/span>"<\/span>,<\/span><\/span>\n        <\/span>"unique_id"<\/span>: <\/span>f<\/span>"apc_pdu_serial_{global_serial}_{device_id}"<\/span>,<\/span><\/span>\n        <\/span>"icon"<\/span>: <\/span>"mdi:alphabetical"<\/span>,<\/span><\/span>\n        <\/span>"device"<\/span>: {<\/span><\/span>\n            "<\/span>identifiers<\/span>": [<\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>snmp_ip_address<\/span>}<\/span>_<\/span>{<\/span>device_id<\/span>}<\/span>"]<\/span>,<\/span><\/span>\n            <\/span>"name"<\/span>: <\/span>f<\/span>"APC PDU {global_model}"<\/span>,<\/span><\/span>\n            <\/span>"model"<\/span>: <\/span>global_model<\/span>,<\/span><\/span>\n            <\/span>"manufacturer"<\/span>: <\/span>"APC"<\/span>,<\/span><\/span>\n        },<\/span><\/span>\n    }<\/span><\/span>\n    <\/span>publish<\/span>.<\/span>single<\/span>(<\/span><\/span>\n        <\/span>f<\/span>"homeassistant\/sensor\/apc_pdu_{device_id}\/serial\/config"<\/span>,<\/span><\/span>\n        <\/span>payload<\/span>=<\/span>json<\/span>.<\/span>dumps<\/span>(<\/span>serial_discovery_message<\/span>),<\/span><\/span>\n        <\/span>hostname<\/span>=<\/span>mqtt_broker<\/span>,<\/span><\/span>\n        <\/span>port<\/span>=<\/span>mqtt_port<\/span>,<\/span><\/span>\n        <\/span>auth<\/span>={"<\/span>username<\/span>": <\/span>mqtt_user<\/span>, "<\/span>password<\/span>": <\/span>mqtt_password<\/span>},<\/span><\/span>\n        <\/span>retain<\/span>=<\/span>True<\/span>,<\/span><\/span>\n    )<\/span><\/span>\n<\/span>\n    # <\/span>Model<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>model_discovery_message<\/span> = {<\/span><\/span>\n        "<\/span>name<\/span>": "<\/span>Model<\/span>",<\/span><\/span>\n        "<\/span>state_topic<\/span>": <\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>device_id<\/span>}\/<\/span>status<\/span>\/<\/span>model<\/span>"<\/span>,<\/span><\/span>\n        <\/span>"unique_id"<\/span>: <\/span>f<\/span>"apc_pdu_model_{global_serial}_{device_id}"<\/span>,<\/span><\/span>\n        <\/span>"icon"<\/span>: <\/span>"mdi:information-outline"<\/span>,<\/span><\/span>\n        <\/span>"device"<\/span>: {<\/span><\/span>\n            "<\/span>identifiers<\/span>": [<\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>snmp_ip_address<\/span>}<\/span>_<\/span>{<\/span>device_id<\/span>}<\/span>"]<\/span>,<\/span><\/span>\n            <\/span>"name"<\/span>: <\/span>f<\/span>"APC PDU {global_model}"<\/span>,  <\/span><\/span>\n            <\/span>"model"<\/span>: <\/span>global_model<\/span>,<\/span><\/span>\n            <\/span>"manufacturer"<\/span>: <\/span>"APC"<\/span>,<\/span><\/span>\n        },<\/span><\/span>\n    }<\/span><\/span>\n    <\/span>publish<\/span>.<\/span>single<\/span>(<\/span><\/span>\n        <\/span>f<\/span>"homeassistant\/sensor\/apc_pdu_{device_id}\/model\/config"<\/span>,<\/span><\/span>\n        <\/span>payload<\/span>=<\/span>json<\/span>.<\/span>dumps<\/span>(<\/span>model_discovery_message<\/span>),<\/span><\/span>\n        <\/span>hostname<\/span>=<\/span>mqtt_broker<\/span>,<\/span><\/span>\n        <\/span>port<\/span>=<\/span>mqtt_port<\/span>,<\/span><\/span>\n        <\/span>auth<\/span>={"<\/span>username<\/span>": <\/span>mqtt_user<\/span>, "<\/span>password<\/span>": <\/span>mqtt_password<\/span>},<\/span><\/span>\n        <\/span>retain<\/span>=<\/span>True<\/span>,<\/span><\/span>\n    )<\/span><\/span>\n<\/span>\n    # <\/span>MAC<\/span> <\/span>Address<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>mac_discovery_message<\/span> = {<\/span><\/span>\n        "<\/span>name<\/span>": "<\/span>MAC<\/span> <\/span>Address<\/span>",<\/span><\/span>\n        "<\/span>state_topic<\/span>": <\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>device_id<\/span>}\/<\/span>status<\/span>\/<\/span>mac<\/span>"<\/span>,<\/span><\/span>\n        <\/span>"unique_id"<\/span>: <\/span>f<\/span>"apc_pdu_mac_{global_serial}_{device_id}"<\/span>,<\/span><\/span>\n        <\/span>"icon"<\/span>: <\/span>"mdi:ethernet"<\/span>,<\/span><\/span>\n        <\/span>"device"<\/span>: {<\/span><\/span>\n            "<\/span>identifiers<\/span>": [<\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>snmp_ip_address<\/span>}<\/span>_<\/span>{<\/span>device_id<\/span>}<\/span>"]<\/span>,<\/span><\/span>\n            <\/span>"name"<\/span>: <\/span>f<\/span>"APC PDU {global_model}"<\/span>,<\/span><\/span>\n            <\/span>"model"<\/span>: <\/span>global_model<\/span>,<\/span><\/span>\n            <\/span>"manufacturer"<\/span>: <\/span>"APC"<\/span>,<\/span><\/span>\n        },<\/span><\/span>\n        <\/span>"value_template"<\/span>: <\/span>"{{ value }}"<\/span><\/span>\n    }<\/span><\/span>\n    <\/span>publish<\/span>.<\/span>single<\/span>(<\/span><\/span>\n        <\/span>f<\/span>"homeassistant\/sensor\/apc_pdu_{device_id}\/mac\/config"<\/span>,<\/span><\/span>\n        <\/span>payload<\/span>=<\/span>json<\/span>.<\/span>dumps<\/span>(<\/span>mac_discovery_message<\/span>),<\/span><\/span>\n        <\/span>hostname<\/span>=<\/span>mqtt_broker<\/span>,<\/span><\/span>\n        <\/span>port<\/span>=<\/span>mqtt_port<\/span>,<\/span><\/span>\n        <\/span>auth<\/span>={"<\/span>username<\/span>": <\/span>mqtt_user<\/span>, "<\/span>password<\/span>": <\/span>mqtt_password<\/span>},<\/span><\/span>\n        <\/span>retain<\/span>=<\/span>True<\/span>,<\/span><\/span>\n    )<\/span><\/span>\n<\/span>\n    # <\/span>Identifier<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>identifier_discovery_message<\/span> = {<\/span><\/span>\n        "<\/span>name<\/span>": "<\/span>Identifier<\/span>",<\/span><\/span>\n        "<\/span>state_topic<\/span>": <\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>device_id<\/span>}\/<\/span>status<\/span>\/<\/span>identifier<\/span>"<\/span>,<\/span><\/span>\n        <\/span>"unique_id"<\/span>: <\/span>f<\/span>"apc_pdu_identifier_{global_serial}_{device_id}"<\/span>,<\/span><\/span>\n        <\/span>"icon"<\/span>: <\/span>"mdi:identifier"<\/span>,<\/span><\/span>\n        <\/span>"device"<\/span>: {<\/span><\/span>\n            "<\/span>identifiers<\/span>": [<\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>snmp_ip_address<\/span>}<\/span>_<\/span>{<\/span>device_id<\/span>}<\/span>"]<\/span>,<\/span><\/span>\n            <\/span>"name"<\/span>: <\/span>f<\/span>"APC PDU {global_model}"<\/span>,<\/span><\/span>\n            <\/span>"model"<\/span>: <\/span>global_model<\/span>,<\/span><\/span>\n            <\/span>"manufacturer"<\/span>: <\/span>"APC"<\/span>,<\/span><\/span>\n        },<\/span><\/span>\n    }<\/span><\/span>\n<\/span>\n    # <\/span>Publishing<\/span> <\/span>the<\/span> <\/span>Identifier<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>publish<\/span>.<\/span>single<\/span>(<\/span><\/span>\n        <\/span>f<\/span>"homeassistant\/sensor\/{device_id}\/identifier\/config"<\/span>,<\/span><\/span>\n        <\/span>payload<\/span>=<\/span>json<\/span>.<\/span>dumps<\/span>(<\/span>identifier_discovery_message<\/span>),<\/span><\/span>\n        <\/span>hostname<\/span>=<\/span>mqtt_broker<\/span>,<\/span><\/span>\n        <\/span>port<\/span>=<\/span>mqtt_port<\/span>,<\/span><\/span>\n        <\/span>auth<\/span>={"<\/span>username<\/span>": <\/span>mqtt_user<\/span>, "<\/span>password<\/span>": <\/span>mqtt_password<\/span>},<\/span><\/span>\n        <\/span>retain<\/span>=<\/span>True<\/span>,<\/span><\/span>\n    )<\/span><\/span>\n<\/span>\n    # <\/span>Uptime<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>uptime_discovery_message<\/span> = {<\/span><\/span>\n        "<\/span>name<\/span>": <\/span>f<\/span>"<\/span>Uptime<\/span>",<\/span><\/span>\n        "<\/span>state_topic<\/span>": <\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>device_id<\/span>}\/<\/span>status<\/span>\/<\/span>uptime<\/span>"<\/span>,<\/span><\/span>\n        <\/span>"unique_id"<\/span>: <\/span>f<\/span>"apc_pdu_uptime_{global_serial}_{device_id}"<\/span>,<\/span><\/span>\n        <\/span>"icon"<\/span>: <\/span>"mdi:timer-outline"<\/span>,<\/span><\/span>\n        <\/span>"device"<\/span>: {<\/span><\/span>\n            "<\/span>identifiers<\/span>": [<\/span>f<\/span>"<\/span>apc_pdu_<\/span>{<\/span>snmp_ip_address<\/span>}<\/span>_<\/span>{<\/span>device_id<\/span>}<\/span>"]<\/span>,<\/span><\/span>\n            <\/span>"name"<\/span>: <\/span>f<\/span>"APC PDU {global_model}"<\/span>,<\/span><\/span>\n            <\/span>"model"<\/span>: <\/span>global_model<\/span>,<\/span><\/span>\n            <\/span>"manufacturer"<\/span>: <\/span>"APC"<\/span>,<\/span><\/span>\n        },<\/span><\/span>\n    }<\/span><\/span>\n<\/span>\n    # <\/span>Publishing<\/span> <\/span>the<\/span> <\/span>Uptime<\/span> <\/span>Discovery<\/span> <\/span>Message<\/span><\/span>\n    <\/span>publish<\/span>.<\/span>single<\/span>(<\/span><\/span>\n        <\/span>f<\/span>"homeassistant\/sensor\/{device_id}\/uptime\/config"<\/span>,<\/span><\/span>\n        <\/span>payload<\/span>=<\/span>json<\/span>.<\/span>dumps<\/span>(<\/span>uptime_discovery_message<\/span>),<\/span><\/span>\n        <\/span>hostname<\/span>=<\/span>mqtt_broker<\/span>,<\/span><\/span>\n        <\/span>port<\/span>=<\/span>mqtt_port<\/span>,<\/span><\/span>\n        <\/span>auth<\/span>={"<\/span>username<\/span>": <\/span>mqtt_user<\/span>, "<\/span>password<\/span>": <\/span>mqtt_password<\/span>},<\/span><\/span>\n        <\/span>retain<\/span>=<\/span>True<\/span>,<\/span><\/span>\n    )<\/span><\/span>\n<\/span>\ndef<\/span> <\/span>safe_publish<\/span>(<\/span>client<\/span>, <\/span>topic<\/span>, <\/span>payload<\/span>):<\/span><\/span>\n    <\/span>try<\/span>:<\/span><\/span>\n        <\/span>client<\/span>.<\/span>publish<\/span>(<\/span>topic<\/span>, <\/span>payload<\/span>)<\/span><\/span>\n    <\/span>except<\/span> <\/span>Exception<\/span> <\/span>as<\/span> <\/span>e<\/span>:<\/span><\/span>\n        <\/span>debug_print<\/span>(<\/span>f<\/span>"Failed to publish MQTT message: {e}"<\/span>)<\/span><\/span>\n<\/span>\n<\/span>\ndef<\/span> <\/span>connect_with_retry<\/span>(<\/span>client<\/span>, <\/span>broker<\/span>, <\/span>port<\/span>, <\/span>max_retries<\/span>=5, <\/span>delay<\/span>=5):<\/span><\/span>\n    <\/span>for<\/span> <\/span>attempt<\/span> <\/span>in<\/span> <\/span>range<\/span>(<\/span>max_retries<\/span>):<\/span><\/span>\n        <\/span>try<\/span>:<\/span><\/span>\n            <\/span>client<\/span>.<\/span>connect<\/span>(<\/span>broker<\/span>, <\/span>port<\/span>, 60)<\/span><\/span>\n            <\/span>debug_print<\/span>(<\/span>"Successfully connected to MQTT broker."<\/span>)<\/span><\/span>\n            <\/span>return<\/span> <\/span>True<\/span><\/span>\n        <\/span>except<\/span> <\/span>Exception<\/span> <\/span>as<\/span> <\/span>e<\/span>:<\/span><\/span>\n            <\/span>debug_print<\/span>(<\/span>f<\/span>"Failed to connect to MQTT broker: {e}. Retrying in {delay} seconds..."<\/span>)<\/span><\/span>\n            <\/span>time<\/span>.<\/span>sleep<\/span>(<\/span>delay<\/span>)<\/span><\/span>\n    <\/span>debug_print<\/span>(<\/span>"Failed to connect after maximum retries."<\/span>)<\/span><\/span>\n    <\/span>return<\/span> <\/span>False<\/span><\/span>\n<\/span>\nif<\/span> <\/span>__name__<\/span> == <\/span>"__main__"<\/span>:<\/span><\/span>\n    <\/span>client<\/span> = <\/span>mqtt<\/span>.<\/span>Client<\/span>()<\/span><\/span>\n    <\/span>client<\/span>.<\/span>username_pw_set<\/span>(<\/span>mqtt_user<\/span>, <\/span>mqtt_password<\/span>)<\/span><\/span>\n    <\/span>client<\/span>.<\/span>on_connect<\/span> = <\/span>on_connect<\/span><\/span>\n    <\/span>client<\/span>.<\/span>on_message<\/span> = <\/span>on_message<\/span><\/span>\n    <\/span><\/span>\n    <\/span>if<\/span> <\/span>connect_with_retry<\/span>(<\/span>client<\/span>, <\/span>mqtt_broker<\/span>, <\/span>mqtt_port<\/span>):<\/span><\/span>\n        <\/span>client<\/span>.<\/span>loop_start<\/span>()<\/span><\/span>\n<\/span>\n        <\/span>try<\/span>:<\/span><\/span>\n            <\/span>while<\/span> <\/span>True<\/span>:<\/span><\/span>\n                <\/span>publish_status<\/span>(<\/span>client<\/span>)<\/span><\/span>\n                <\/span>time<\/span>.<\/span>sleep<\/span>(<\/span>sleep_duration<\/span>)<\/span><\/span>\n        <\/span>except<\/span> <\/span>KeyboardInterrupt<\/span>:<\/span><\/span>\n            <\/span>debug_print<\/span>(<\/span>"Script stopped by user."<\/span>)<\/span><\/span>\n        <\/span>finally<\/span>:<\/span><\/span>\n            <\/span>client<\/span>.<\/span>disconnect<\/span>()<\/span><\/span>\n    <\/span>else<\/span>:<\/span><\/span>\n        <\/span>debug_print<\/span>(<\/span>"Exiting due to connection issues."<\/span>)<\/span><\/span>\n<\/span><\/code><\/pre><\/div>\n","protected":false},"excerpt":{"rendered":"
                  Guide for SNMP and MQTT Integration Script This is a script I developed to retrieve status information from my APC PDU. While there may be other solutions available, I chose …<\/p>\n","protected":false},"author":1,"featured_media":7167,"comment_status":"open","ping_status":"open","sticky":true,"template":"","format":"standard","meta":{"footnotes":""},"categories":[352,355,354,353],"tags":[],"class_list":["post-7166","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-coding","category-home-assistant","category-linux","category-python"],"_links":{"self":[{"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/posts\/7166","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/phixd.us\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=7166"}],"version-history":[{"count":22,"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/posts\/7166\/revisions"}],"predecessor-version":[{"id":7661,"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/posts\/7166\/revisions\/7661"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/phixd.us\/index.php?rest_route=\/wp\/v2\/media\/7167"}],"wp:attachment":[{"href":"https:\/\/phixd.us\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=7166"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/phixd.us\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=7166"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/phixd.us\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=7166"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}