Buienradar script

[Erwin van der Zwart]

Hi,

They probably changed the XML format.

Here is a more stable version that ignores the XML changes and with auto object creation:

Code:

-- Geef station naam op die gebruikt dient te worden
station_naam = "Zwolle" -- Vul hier het weerstation naam in. (Zie tabel hieronder)

--Beschikbare weerstations
-- 1 = Venlo                                27 = Goeree
-- 2 = Arnhem                                28 = Leeuwarden
-- 3 = Berkhout                            29 = Lelystad
-- 4 = Cadzand                            30 = West-Utrecht                                            
-- 5 = Utrecht                            31 = Maastricht
-- 6 = Den Helder                        32 = Noordoostpolder
-- 7 = Eindhoven                        33 = Oost-Groningen
-- 8 = Weert                                34 = Oosterschelde
-- 10 = Gilzen Rijen                35 = Rotterdam
-- 11 = Goes                                36 = Rotterdam Haven
-- 12 = Oost-Overijssel            37 = Schaar
-- 13 = Groningen                        38 = Amsterdam
-- 14 = Oost-Zeeland                39 = Midden-Zeeland
-- 15 = Zwolle                            40 = West-Friesland
-- 16 = Gorinchem                        41 = Texel
-- 17 = Hoek van Holland        42 = Tholen
-- 18 = Zuid-Zeeland                43 = Twente
-- 19 = Hoogeveen                        44 = West-Zeeland
-- 20 = Wadden                            45 = Vlieland
-- 21 = Enkhuizen-Lelystad    46 = Vlissingen
-- 22 = Schiermonnikoog            47 = Uden
-- 23 = IJmond                            48 = Terneuzen
-- 24 = IJmuiden                        49 = Hoorn
-- 25 = Katwijk                            50 = Wijk aan Zee
-- 26 = Noord-Groningen            51 = Woensdrecht

-- Geef adressen + namen op en activeer de te gebruiken items (actief J/N), objecten worden automatisch aangemaakt indien niet bestaand.
adresmapping = {
 ['stationnaam'] = {
   actief = 'J',
   adres = '40/1/0',
   naam = 'Station naam',
   objecttype = dt.text
 },
 ['datum'] = {
   actief = 'J',
   adres = '40/1/1',
   naam = 'Tijd en datum laatste update van weerstation',
   objecttype = dt.text
 },
 ['zin'] = {
   actief = 'J',
   adres = '40/1/2',
   naam = 'Weer tekstueel',
   objecttype = dt.text
 },
 ['temperatuurGC'] = {
   actief = 'J',
   adres = '40/1/3',
   naam = 'Temperatuur',
   objecttype = dt.text
 },
 ['temperatuur10cm'] = {
   actief = 'J',
   adres = '40/1/4',
   naam = 'Temperatuur op 10 centimeter van maaiveld',
   objecttype = dt.text
 },
 ['luchtdruk'] = {
   actief = 'J',
   adres = '40/1/5',
   naam = 'Luchtdruk',
   objecttype = dt.text
 },
 ['luchtvochtigheid'] = {
   actief = 'J',
   adres = '40/1/6',
   naam = 'Luchtvochtigheid',
   objecttype = dt.text
 },
 ['regenMMPU'] = {
   actief = 'J',
   adres = '40/1/7',
   naam = 'Regen milimeter per uur',
   objecttype = dt.text
 },
 ['windrichting'] = {
   actief = 'J',
   adres = '40/1/8',
   naam = 'Windrichting',
   objecttype = dt.text
 },
 ['windrichtingGR'] = {
   actief = 'J',
   adres = '40/1/9',
   naam = 'Windrichting in graden',
   objecttype = dt.text
 },
 ['windsnelheidMS'] = {
   actief = 'J',
   adres = '40/1/10',
   naam = 'Windsnelheid in meters per seconde',
   objecttype = dt.text
 },
 ['windstotenMS'] = {
   actief = 'J',
   adres = '40/1/11',
   naam = 'Windstoten in meter per seconde',
   objecttype = dt.text
 },
 ['zichtmeters'] = {
   actief = 'J',
   adres = '40/1/12',
   naam = 'Zicht in meters',
   objecttype = dt.text
 },
 ['zonintensiteitWM2'] = {
   actief = 'J',
   adres = '40/1/13',
   naam = 'Zon intensitiet',
   objecttype = dt.text
 },
 ['icoonactueel'] = {
   actief = 'J',
   adres = '40/1/14',
   naam = 'URL actueel icoon',
   objecttype = dt.text
 },
 ['icoonid'] = {
   actief = 'J',
   adres = '40/1/15',
   naam = 'Icoon id',
   objecttype = dt.text
 },
 ['icoon'] = {
   actief = 'N',
   adres = '40/1/16',
   naam = 'Icoon',
   objecttype = dt.text
 },
 ['windsnelheidBF'] = {
   actief = 'N',
   adres = '40/1/17',
   naam = 'Windsnelheid in beaufort',
   objecttype =
   dt.text
 },
 ['regio'] = {
   actief = 'N',
   adres = '40/1/18',
   naam = 'Regio',
   objecttype = dt.text
 },
 ['stationcode'] = {
   actief = 'N',
   adres = '40/1/19',
   naam = 'Station code',
   objecttype = dt.text
 },
 ['stationid'] = {
   actief = 'N',
   adres = '40/1/20',
   naam = 'Station id',
   objecttype = dt.text
 },
 ['lat'] = {
   actief = 'N',
   adres = '40/1/21',
   naam = 'Latitude',
   objecttype = dt.text
 },
 ['latGraden'] = {
   actief = 'N',
   adres = '40/1/22',
   naam = 'Latitude in graden',
   objecttype = dt.text
 },
 ['lon'] = {
   actief = 'N',
   adres = '40/1/23',
   naam = 'Longitude',
   objecttype = dt.text
 },
 ['lonGraden'] = {
   actief = 'N',
   adres = '40/1/24',
   naam = 'Longitude in graden',
   objecttype = dt.text
 },
 ['url'] = {
   actief = 'N',
   adres = '40/1/25',
   naam = 'URL',
   objecttype = dt.text
 },
}

-- Load libs
require('socket.http')

-- Function to create objects
function createobject(item)
   grp.create({
       name = item.naam,
       address = item.adres,
       datatype = item.objecttype,
       --visparams = item.visparams,
       --enums = item.enums,
       --units = item.units,
       tags = {'Buienradar'},
                comment = 'Automatisch aangemaakt door buienradar script',
   })
end

-- Set timeout
socket.http.TIMEOUT = 15

-- Get data from API
local data = socket.http.request('http://xml.buienradar.nl/')
--log(data)
if not data then
 alert('Weerbericht kan niet worden opgehaald..')
 return
end

-- Create result table
weerstationtag = false
result = {}

-- callback for tag start
function starttag(parser, tag, attributes)
 -- create new storage in result table for each <item> tag
 if tag == 'weerstation' then
   weerstationtag = true
   table.insert(result, {})
 end
 currtag = tag
 
 -- Add attribute "id"
 if attributes.id ~= nil then
   if currtag then
     result[ #result ].stationid = attributes.id
   end
 end

 -- Add attribute "regio"
 if attributes.regio ~= nil then
   if weerstationtag and currtag then
     result[ #result ].regio = attributes.regio
   end
 end
 
 -- Add attribute "zin"
 if attributes.zin ~= nil then
   if weerstationtag and currtag then
     result[ #result ].zin = attributes.zin
   end
 end
 
 -- Add attribute "ID"
 if attributes.ID ~= nil then
   if weerstationtag and currtag then
     result[ #result ].icoonid = attributes.ID
   end
 end
 
end

-- callback for tag end
function endtag(p, tag)
 if tag == 'weerstation' then
   weerstationtag = false
 end
 currtag = nil
end

-- callback for character data
function cdata(parser, text, attributes)
 -- check if parser is inside of <item> and either in <title> or <description>
 if weerstationtag and currtag then
   if currtag == 'stationcode' then
     result[ #result ].stationcode = text
   elseif currtag == 'stationnaam' then
     result[ #result ].stationnaam = text
     elseif currtag == 'lat' then
       result[ #result ].lat = text
   elseif currtag == 'lon' then
     result[ #result ].lon = text
   elseif currtag == 'datum' then
     result[ #result ].datum = text  
   elseif currtag == 'luchtvochtigheid' then
     result[ #result ].luchtvochtigheid = text  
   elseif currtag == 'temperatuurGC' then
     result[ #result ].temperatuurGC = text  
   elseif currtag == 'windsnelheidMS' then
     result[ #result ].windsnelheidMS = text  
   elseif currtag == 'windsnelheidBF' then
     result[ #result ].windsnelheidBF = text  
   elseif currtag == 'windrichtingGR' then
     result[ #result ].windrichtingGR = text  
   elseif currtag == 'windrichting' then
     result[ #result ].windrichting = text  
   elseif currtag == 'luchtdruk' then
     result[ #result ].luchtdruk = text  
   elseif currtag == 'zichtmeters' then
     result[ #result ].zichtmeters = text
     elseif currtag == 'windstotenMS' then
     result[ #result ].windstotenMS = text
   elseif currtag == 'regenMMPU' then
     result[ #result ].regenMMPU = text
   elseif currtag == 'zonintensiteitWM2' then
     result[ #result ].zonintensiteitWM2 = text
     elseif currtag == 'icoonactueel' then
     result[ #result ].icoonactueel= text
   elseif currtag == 'temperatuur10cm' then
     result[ #result ].temperatuur10cm = text
   elseif currtag == 'url' then
     result[ #result ].url = text
   elseif currtag == 'latGraden' then
     result[ #result ].latGraden = text
   elseif currtag == 'lonGraden' then
     result[ #result ].lonGraden = text
   end
 end
end

-- create parser
lxp = require('lxp')
parser = lxp.new({
 StartElement = starttag,
 EndElement = endtag,
 CharacterData = cdata,
})

-- parse data
if parser:parse(data) then
 parseddata = result
else
 log('parse failed')
end
--log(parseddata)

-- loop through LUA result table
if #parseddata > 0 then
 for _, item in ipairs(parseddata) do
   -- Get item with selected station_naam
   if item.regio == station_naam then
     if adresmapping.zin.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.zin.adres)
       if currentvalue == nil then
           createobject(adresmapping.zin)
       end
       if item.zin ~= currentvalue then
         grp.update(adresmapping.zin.adres, item.zin)
       end
     end
     
     if adresmapping.temperatuurGC.actief == 'J' then      
       currentvalue = grp.getvalue(adresmapping.temperatuurGC.adres)
       if currentvalue == nil then
           createobject(adresmapping.temperatuurGC)
       end
       if item.temperatuurGC ~= currentvalue then
         grp.update(adresmapping.temperatuurGC.adres, item.temperatuurGC)
       end
     end
     
     if adresmapping.windstotenMS.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.windstotenMS.adres)
       if currentvalue == nil then
           createobject(adresmapping.windstotenMS)
       end
       if item.windstotenMS ~= currentvalue then
         grp.update(adresmapping.windstotenMS.adres, item.windstotenMS)
       end
     end
     
     if adresmapping.luchtdruk.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.luchtdruk.adres)
       if currentvalue == nil then
           createobject(adresmapping.luchtdruk)
       end
       if item.luchtdruk ~= currentvalue then
         grp.update(adresmapping.luchtdruk.adres, item.luchtdruk)
       end
     end
     
     if adresmapping.stationcode.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.stationcode.adres)
       if currentvalue == nil then
           createobject(adresmapping.stationcode)
       end
       if item.stationcode ~= currentvalue then
         grp.update(adresmapping.stationcode.adres, item.stationcode)
       end
     end
     
     if adresmapping.url.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.url.adres)
       if currentvalue == nil then
           createobject(adresmapping.url)
       end
       if item.url ~= currentvalue then
         grp.update(adresmapping.url.adres, item.url)
       end
     end
     
     if adresmapping.lonGraden.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.lonGraden.adres)
       if currentvalue == nil then
           createobject(adresmapping.lonGraden)
       end
       if item.lonGraden ~= currentvalue then
         grp.update(adresmapping.lonGraden.adres, item.lonGraden)
       end
     end
     
     if adresmapping.datum.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.datum.adres)
       if currentvalue == nil then
           createobject(adresmapping.datum)
       end
       if item.datum ~= currentvalue then
         grp.update(adresmapping.datum.adres, item.datum)
       end
     end
     
     if adresmapping.stationnaam.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.stationnaam.adres)
       if currentvalue == nil then
           createobject(adresmapping.stationnaam)
       end
       if item.stationnaam ~= currentvalue then
         grp.update(adresmapping.stationnaam.adres, item.stationnaam)
       end
     end
     
     if adresmapping.temperatuur10cm.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.temperatuur10cm.adres)
       if currentvalue == nil then
           createobject(adresmapping.temperatuur10cm)
       end
       if item.temperatuur10cm ~= currentvalue then
         grp.update(adresmapping.temperatuur10cm.adres, item.temperatuur10cm)
       end
     end
     
     if adresmapping.icoonactueel.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.icoonactueel.adres)
       if currentvalue == nil then
           createobject(adresmapping.icoonactueel)
       end
       if item.icoonactueel ~= currentvalue then
         grp.update(adresmapping.icoonactueel.adres, item.icoonactueel)
       end
     end
     
     if adresmapping.lat.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.lat.adres)
       if currentvalue == nil then
           createobject(adresmapping.lat)
       end
       if item.lat ~= currentvalue then
         grp.update(adresmapping.lat.adres, item.lat)
       end
     end
     
     if adresmapping.windrichtingGR.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.windrichtingGR.adres)
       if currentvalue == nil then
           createobject(adresmapping.windrichtingGR)
       end
       if item.windrichtingGR ~= currentvalue then
         grp.update(adresmapping.windrichtingGR.adres, item.windrichtingGR)
       end
     end
     
     if adresmapping.regio.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.regio.adres)
       if currentvalue == nil then
           createobject(adresmapping.regio)
       end
       if item.regio ~= currentvalue then
         grp.update(adresmapping.regio.adres, item.regio)
       end
     end
     
     if adresmapping.luchtvochtigheid.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.luchtvochtigheid.adres)
       if currentvalue == nil then
           createobject(adresmapping.luchtvochtigheid)
       end
       if item.luchtvochtigheid ~= currentvalue then
         grp.update(adresmapping.luchtvochtigheid.adres, item.luchtvochtigheid)
       end
     end
     
     if adresmapping.windrichting.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.windrichting.adres)
       if currentvalue == nil then
           createobject(adresmapping.windrichting)
       end
       if item.windrichting ~= currentvalue then
         grp.update(adresmapping.windrichting.adres, item.windrichting)
       end
     end
     
     if adresmapping.lon.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.lon.adres)
       if currentvalue == nil then
           createobject(adresmapping.lon)
       end
       if item.lon ~= currentvalue then
         grp.update(adresmapping.lon.adres, item.lon)
       end
     end
     
     if adresmapping.zichtmeters.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.zichtmeters.adres)
       if currentvalue == nil then
           createobject(adresmapping.zichtmeters)
       end
       if item.zichtmeters ~= currentvalue then
         grp.update(adresmapping.zichtmeters.adres, item.zichtmeters)
       end
     end
     
     if adresmapping.latGraden.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.latGraden.adres)
       if currentvalue == nil then
           createobject(adresmapping.latGraden)
       end
       if item.latGraden ~= currentvalue then
         grp.update(adresmapping.latGraden.adres, item.latGraden)
       end
     end
     
     if adresmapping.windsnelheidBF.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.windsnelheidBF.adres)
       if currentvalue == nil then
           createobject(adresmapping.windsnelheidBF)
       end
       if item.windsnelheidBF ~= currentvalue then
         grp.update(adresmapping.windsnelheidBF.adres, item.windsnelheidBF)
       end
     end
     
     if adresmapping.windsnelheidMS.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.windsnelheidMS.adres)
       if currentvalue == nil then
           createobject(adresmapping.windsnelheidMS)
       end
       if item.windsnelheidMS ~= currentvalue then
         grp.update(adresmapping.windsnelheidMS.adres, item.windsnelheidMS)
       end
     end
     
     if adresmapping.zonintensiteitWM2.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.zonintensiteitWM2.adres)
       if currentvalue == nil then
           createobject(adresmapping.zonintensiteitWM2)
       end
       if item.zonintensiteitWM2 ~= currentvalue then
         grp.update(adresmapping.zonintensiteitWM2.adres, item.zonintensiteitWM2)
       end
     end
     
     if adresmapping.regenMMPU.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.regenMMPU.adres)
       if currentvalue == nil then
           createobject(adresmapping.regenMMPU)
       end
       if item.regenMMPU ~= currentvalue then
         grp.update(adresmapping.regenMMPU.adres, item.regenMMPU)
       end
     end
     
     if adresmapping.stationid.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.stationid.adres)
       if currentvalue == nil then
           createobject(adresmapping.stationid)
       end
       if item.stationid ~= currentvalue then
         grp.update(adresmapping.stationid.adres, item.stationid)
       end
     end
     
     if adresmapping.icoonid.actief == 'J' then
       currentvalue = grp.getvalue(adresmapping.icoonid.adres)
       if currentvalue == nil then
         createobject(adresmapping.icoonid)
       end
       if item.icoonid ~= currentvalue then
         grp.update(adresmapping.icoonid.adres, item.icoonid)
         if adresmapping.icoon.actief == 'J' then
           if currentvalue == nil then
             createobject(adresmapping.icoon)
               end
           if item.icoonid == 'a' then
             grp.update(adresmapping.icoon.adres, 17)
           elseif item.icoonid == 'aa' then
             grp.update(adresmapping.icoon.adres, 6)
           elseif item.icoonid == 'b'then
             grp.update(adresmapping.icoon.adres, 12)
           elseif item.icoonid == 'bb'then
             grp.update(adresmapping.icoon.adres, 13)  
           elseif item.icoonid == 'c' or item.icoonid == 'cc' then
             grp.update(adresmapping.icoon.adres, 7)
           elseif item.icoonid == 'd' or item.icoonid == 'dd' then
             grp.update(adresmapping.icoon.adres, 10)
           elseif item.icoonid == 'e' or item.icoonid == 'ee' then
             grp.update(adresmapping.icoon.adres, 9)
           elseif item.icoonid == 'f' or item.icoonid == 'ff' then
             grp.update(adresmapping.icoon.adres, 2)
           elseif item.icoonid == 'g' or item.icoonid == 'gg' then
             grp.update(adresmapping.icoon.adres, 5)
           elseif item.icoonid == 'h' or item.icoonid == 'hh' then
             grp.update(adresmapping.icoon.adres, 3)
           elseif item.icoonid == 'i' or item.icoonid == 'ii' then
             grp.update(adresmapping.icoon.adres, 3)
           elseif item.icoonid == 'j' or item.icoonid == 'jj' then
             grp.update(adresmapping.icoon.adres, 19)
           elseif item.icoonid == 'k' or item.icoonid == 'kk' then
             grp.update(adresmapping.icoon.adres, 16)
           elseif item.icoonid == 'l' or item.icoonid == 'll' then
             grp.update(adresmapping.icoon.adres, 16)
           elseif item.icoonid == 'm' or item.icoonid == 'mm' then
             grp.update(adresmapping.icoon.adres, 2)
           elseif item.icoonid == 'n' or item.icoonid == 'nn' then
             grp.update(adresmapping.icoon.adres, 1)
           elseif item.icoonid == 'o' or item.icoonid == 'oo' then
             grp.update(adresmapping.icoon.adres, 11)
           elseif item.icoonid == 'p' or item.icoonid == 'pp' then
             grp.update(adresmapping.icoon.adres, 11)
           elseif item.icoonid == 'q' or item.icoonid == 'qq' then
             grp.update(adresmapping.icoon.adres, 16)
           elseif item.icoonid == 'r' or item.icoonid == 'rr' then
             grp.update(adresmapping.icoon.adres, 19)
           elseif item.icoonid == 's' or item.icoonid == 'ss' then
             grp.update(adresmapping.icoon.adres, 5)
           elseif item.icoonid == 't' or item.icoonid == 'tt' then
             grp.update(adresmapping.icoon.adres, 8)
           elseif item.icoonid == 'u' or item.icoonid == 'uu' then
             grp.update(adresmapping.icoon.adres, 4)
           elseif item.icoonid == 'v' or item.icoonid == 'vv' then
             grp.update(adresmapping.icoon.adres, 1)
           elseif item.icoonid == 'w' or item.icoonid == 'ww' then
             grp.update(adresmapping.icoon.adres, 15)
           elseif item.icoonid == 'x' or item.icoonid == 'xx' then
             grp.update(adresmapping.icoon.adres, 9)
           elseif item.icoonid == 'y' or item.icoonid == 'yy' then
             grp.update(adresmapping.icoon.adres, 20)
           elseif item.icoonid == 'z' or item.icoonid == 'zz' then
             grp.update(adresmapping.icoon.adres, 20)
           elseif item.icoonid == '0' or item.icoonid == '00' then
             grp.update(adresmapping.icoon.adres, 19)
           elseif item.icoonid == '1' or item.icoonid == '11' then
             grp.update(adresmapping.icoon.adres, 20)
           else
             grp.update(adresmapping.icoon.adres, 19)
           end
         end
       end  
     end
   end
 end
end

BR,

Erwin