(26.06.2024, 11:05)admin Wrote: Similar integration: https://forum.logicmachine.net/showthrea...4#pid31274
In case someone needs it, below is a scheduled script that runs every 5 minutes to retrieve temp data from some sensors and write them into LM5 groups. (I'm pretty sure that it could be improved)
Code:
local https = require('ssl.https')
local json = require('json')
local ltn12 = require('ltn12')
-- Airthings API endpoints and credentials
local tokenEndpoint = 'https://accounts-api.airthings.com/v1/token'
local clientId = 'xx'
local clientSecret = 'xx'
-- local deviceSerialNumber = '3130000665' -- Specific device serial number
local devices = {
{ serialNumber = 'xx', location = '7east' },
{ serialNumber = 'xx', location = '7west' },
{ serialNumber = 'xx', location = '7mid' }
}
local accessToken
-- Custom logging function
-- Function to get access token
function getAccessToken()
local requestBody = 'grant_type=client_credentials'
.. '&client_id=' .. clientId
.. '&client_secret=' .. clientSecret
.. '&scope=read:device'
local response_body = {}
local _, code, headers, status = https.request{
url = tokenEndpoint,
method = 'POST',
headers = {
['Content-Type'] = 'application/x-www-form-urlencoded',
['Content-Length'] = #requestBody
},
source = ltn12.source.string(requestBody),
sink = ltn12.sink.table(response_body)
}
local response = table.concat(response_body)
-- log("DEBUG", "Response body: " .. response)
-- log("DEBUG", "HTTP status code: " .. tostring(code))
-- log("DEBUG", "HTTP status: " .. tostring(status))
if code == 200 then
local jsonResponse = json.decode(response)
accessToken = jsonResponse.access_token
log("INFO", 'Access token received: ' .. accessToken)
else
log("ERROR", 'Error fetching access token: ' .. tostring(code) .. ' ' .. tostring(status))
end
end
-- Function to get data from a specific device
function getDeviceData(serialNumber)
local deviceDataEndpoint = 'https://ext-api.airthings.com/v1/devices/' .. serialNumber .. '/latest-samples'
local response_body = {}
local _, code, headers, status = https.request{
url = deviceDataEndpoint,
method = 'GET',
headers = {
['Authorization'] = 'Bearer ' .. accessToken
},
sink = ltn12.sink.table(response_body)
}
local response = table.concat(response_body)
-- log("DEBUG", "Device data response body: " .. response)
-- log("DEBUG", "HTTP status code: " .. tostring(code))
-- log("DEBUG", "HTTP status: " .. tostring(status))
if code == 200 then
local jsonResponse = json.decode(response)
return jsonResponse
else
-- log("ERROR", 'Error fetching device data: ' .. tostring(code) .. ' ' .. tostring(status))
return nil
end
end
-- Main script
getAccessToken()
-- if accessToken then
-- local data = getDeviceData(deviceSerialNumber)
-- if data then
-- log("INFO", "Data for device " .. deviceSerialNumber .. ": " .. json.encode(data))
-- end
-- end
-- Main script
getAccessToken()
if accessToken then
i = 1 -- Initialize index
for _, device in ipairs(devices) do
i = i + 1 -- Increment index for group address
local data = getDeviceData(device.serialNumber)
if data then
local temperature = tostring(data.data.temp)
log("INFO", "Temperature " .. device.location .. " == " .. temperature)
-- Inside your loop for devices
grp.checkwrite("32/1/" .. i, temperature) -- Write temperature to group address
-- log(i)
end
end
end
