Domoticz

Code: Select all

return
{
    on =
    {
        timer =
        {
            'every minute' ,
        },
    },

    logging =
    {
        level = domoticz.LOG_ERROR, -- change to domoticz.LOG_DEBUG when not working as expected
        marker = 'forcePushToInfluxdb with filter Example',
    },

    execute = function(dz)

        local myInfluxDevices =
        {
            64, 73, 29, 33, 76, 77, 79, 86, 16, 71
        }

        local function forcePushToInfluxdb(dv)
            dz.log('Forcing push to influxDb of ' .. dv.name .. ' : '  ..dv.sValue, dz.LOG_FORCE)

            local url = dz.settings['Domoticz url'] ..  '/json.htm?type=command&param=udevice&idx=' .. dv.idx  ..
                    '&nvalue=' .. ( dv.nValue or 0  ) ..
                    '&svalue=' .. ( dv.sValue or '' )
            dz.openURL(url)
        end

        dz.devices().filter(myInfluxDevices).forEach(function(dv)
            forcePushToInfluxdb(dv)
        end)
    end
}

Code: Select all

2021-02-07 20:11:54.768 Error: EventSystem: Warning!, lua script /home/pi/domoticz/dzVents/runtime/dzVents.lua has been running for more than 10 seconds
2021-02-07 20:12:31.426 Error: MQTT: disconnected, restarting (rc=14)
2021-02-07 20:12:39.128 Error: dzVents: Error: (3.0.2) forcePushToInfluxdb with filter Example: ------ Finished Influx push force after >10 seconds. (using 1.341 seconds CPU time !)
2021-02-07 20:12:40.034 Error: EventSystem: Warning!, lua script /home/pi/domoticz/dzVents/runtime/dzVents.lua has been running for more than 10 seconds
2021-02-07 20:12:51.884 Error: EventSystem: Warning!, lua script /home/pi/domoticz/dzVents/runtime/dzVents.lua has been running for more than 10 seconds
2021-02-07 20:12:51.946 Error: BasePush: Could not determine data push value
2021-02-07 20:12:51.951 Error: BasePush: Could not determine data push value
2021-02-07 20:12:53.115 Error: BasePush: Could not determine data push value
2021-02-07 20:12:53.116 Error: BasePush: Could not determine data push value

Code: Select all

return
{
    on =
    {
        devices =
        {
            16, 29, 33, 76, 77, 86, 71
        },
    },
   
    logging =
    {
        level = domoticz.LOG_DEBUG,
        marker = 'Push to Influx',
    },
 
    data =
    {
        lastExecutionTimes = { initial = {} },
    },
   
    execute = function(dz, item)

        dz.log('Device ' .. item.name .. ' was changed ' .. item.rawData[1], dz.LOG_DEBUG)
       
        local function pushToInfluxdb(idx , nValue, rawData )
            local sValue = table.concat(rawData,';')
            local nValue = nValue or 0
           
            local url = dz.settings['Domoticz url'] ..  '/json.htm?type=command&param=udevice&idx=' .. idx  ..
                        '&nvalue=' .. nValue ..
                        '&svalue=' .. sValue
            dz.openURL(url)
            
        end

        if dz.data.lastExecutionTimes[item.name] == nil or ( dz.data.lastExecutionTimes[item.name] < ( dz.time.dDate - 1 ) ) then
            pushToInfluxdb( item.idx, 0, item.rawData )
            dz.data.lastExecutionTimes[item.name] = dz.time.dDate
        else
            dz.log('Too soon after last update; we don\'t want an endless loop', dz.LOG_DEBUG)
        end
    end
}

Code: Select all

2021-02-08 21:45:41.655 Error: BasePush: Could not determine data push value
2021-02-08 21:49:35.089 Error: BasePush: Could not determine data push value
2021-02-08 21:49:35.123 Error: BasePush: Could not determine data push value
2021-02-08 21:57:38.453 Error: BasePush: Could not determine data push value
2021-02-08 21:57:38.453 Error: BasePush: Could not determine data push value
2021-02-08 21:57:38.487 Error: BasePush: Could not determine data push value

Code: Select all

on = {
            timer = { 'at daytime' },
            devices = {16, 29, 33, 76, 77, 86, 71}
    },

Code: Select all

                dz.openURL({
                    url = "http://<ipaddress>:8086/api/v2/write?org=<Organisation>&bucket=<Bucketname>&precision=s" ,
                    method = "POST",
                    callback= "Influxdb",
                    headers = {
                        ['Authorization'] = 'Token ' .. TOKEN,
                        ['Content-Type'] = 'text/plain'
                    },
                    postData = pushdata,
                    callback = 'Influxdb'

Code: Select all

                if item.deviceType == "General" and item.deviceSubType == "kWh" then
                    pushdata = item.name::gsub(' ', '-') -- ' watt=' .. tostring(item.usage)
                end
                if item.deviceType == "Temp + Humidity" and item.deviceSubType == "WTGR800" then
                    pushdata = item.name:gsub(' ', '-') .. ' temp=' .. tostring(dz.utils.round(item.temperature,1)) .. '\n' ..
                        item.name:gsub(' ', '-') .. ' humi=' .. tostring(dz.utils.round(item.humidity,0))
                end