Unclosed client session
client_session: <aiohttp.client.ClientSession object at 0x79fb881c7200>
Unclosed connector
connections: ['[(<aiohttp.client_proto.ResponseHandler object at 0x79fb83fdd310>, 39095.821291985)]']
connector: <aiohttp.connector.TCPConnector object at 0x79fb880772c0>

async def run(store_daily: False):
    global total_usage

    try:
        devices = await Discover.discover(username="xxx", password="xxx")
    except kasa.exceptions.KasaException as k:
        conlog.error("Discover error {}".format(k))
        return

    for key in devices:
        device = devices[key]
        await device.update(update_children = True)
        if device.has_emeter:
            now = datetime.datetime.now()
            e = device.modules["Energy"]
#            print(f"{device.alias}: {e.current_consumption}W, {e.current}A, {e.consumption_today}kWh")
            total_usage = total_usage + e.consumption_today
            msg = {}
            msg["name"] = device.alias
            msg["voltage"] = e.voltage
            msg["current"] = e.current
            msg["today"] = e.consumption_today
            msg["datetime"] = now
            msg["model"] = device.model
            msg["ip"] = device.host
            alias = f"energy/device/{device.alias}"
            try:
                mqttc.publish(alias, json.dumps(msg, default=str))
            except:
                conlog.error("Unable to publish energy data for: {}".format(device.alias))

            if store_daily:
                conlog.info("Storing SQL data")
                try:
                    cur = maria.cursor()
                    cur.execute("""INSERT INTO energy (id,kwh,date,alias) VALUES(0,%s,CURRENT_TIMESTAMP,%s)""", e.consumption_today, device.alias)
                    maria.commit()
                except:
                    conlog.error("Error committing daily values for {}".format(device.alias))

            children = device.children
            for child in children:
                await child.update()
                ec = child.modules["Energy"]
                total_usage = total_usage + ec.consumption_today
#                print(f"{child.alias}: {ec.current_consumption}W, {ec.current}A, {ec.consumption_today}kWh")
                cmsg = {}
                cmsg["name"] = child.alias
                cmsg["voltage"] = ec.voltage
                cmsg["current"] = ec.current
                cmsg["today"] = ec.consumption_today
                cmsg["datetime"] = now
                cmsg["model"] = child.model
                cmsg["ip"] = child.host
                calias = f"energy/device/{child.alias}"
                try:
                    mqttc.publish(calias, json.dumps(cmsg, default=str))
                except:
                    conlog.error("Unable to publish energy data for: {}".format(child.alias))

                if store_daily:
                    conlog.info("Storing child SQL data")
                    try:
                        cur = maria.cursor()
                        cur.execute("""INSERT INTO energy (id,kwh,date,alias) VALUES(0,%s,CURRENT_TIMESTAMP, %s)""", e.consumption_today, child.alias)
                        maria.commit()
                    except:
                        conlog.error("Error committing daily values for {}".format(child.alias))

Name: python-kasa
Version: 0.10.2
Summary: Python API for TP-Link Kasa and Tapo devices
Home-page: 
Author: python-kasa developers
Author-email: 
License: GPL-3.0-or-later
Location: /home/pete/.local/lib/python3.12/site-packages
Requires: aiohttp, asyncclick, cryptography, mashumaro
Required-by: