ESP-8266/ESP32 NodeMCU Lua: азы программирования.

Скелет программы IoT ч.3.4. Плюс полив огорода.
В предыдущем топике обещал упаковать все в программу и закончить устройство. Но, подумалось - а чем еще можно догрузить бедный ESP-8266?
O! Будем поливать огород! Пусть наша маленькая железка пищит от напряжения!
Полив огорода будет таким:

• два раза в день - с восходом и на закате;
• основное управление - от внутренних часов модуля, резервное - от датчика освещенности;
• можно задавать интервалы дней полива как утром так и в ночь.

Интервалы - вещь достаточно важная. Например, помидоры во время вызревания плодов поливают один раз в три дня. А вот во время роста - хоть каждый день да по два раза.

Полив можно делать разный, но, ИМХО, последнее время популярным становится капельный (иногда - сочащийся). Чем он хорош? Вода медленно струится по трубкам - не требуется емкость для ее нагрева. Какова бы ни была температура на входе системы полива - под корень растения она попадет с уличной температурой. Главное здесь не забыть сбросить давление в системе полива - не более 1 Атм.

Кран у нас будет шаровый, типа такого. Он управляется двумя проводниками: подаем на один 12 вольт на 30 секунд - открываем, на другой - закрываем.


В общем, с добавлением этой функции у нас появляется некислая смесь бульдога с носорогом, а модуль начинает трещать по швам:


Вот такое семейство файлов там нынче трудится. В этой конфигурации модуль уже не принимает команды через терминал: при превышении некоторого количества/объема терминал "ломается".
В целом не мешает жить для готового устройства, но настраивать его в терминале уже становится невозможно.

Но, проект наш учебный, не так ли? Доведем модуль "до изнеможения": в момент обработки команд от брокера его куча уменьшается до 7000 попугаев! И ничего, работает!

Кстати, так выглядит вывод MqttSpy:


В общем, описание законченного устройства опять откладывается, раскрываю суть работы полива.

На полив работают три файла:

• analize.lua - ясный перец, принимает от брокера команды на установку интервалов полива и на немедленные запуск/прекращение полива:
• garden.lua - непосредственно решает про полив;
• turnvalve.lua - открывает и закрывает кран.

 

Как работают скрипты?
analyze.lua - там все типовое, парсит команду и дает указания. Итоговый файл будет выдан позже, по причине того, что обслуживает все части программы.

Кусок analyze.lua:

Спойлер: analyze.lua

Код (Lua):

 -- ...
      elseif top == "water" then
            if dt == "ON" then
                dat.startwater = 1
                print("Watering Now")
            end
            if dt == "OFF" then
                dat.startwater = 0
                print("Stop Water Now")
            end
        elseif top == "day" then
            dat.intervalDay = tonumber(dt) or 0
            dat.lastDay = 0
            print('Set dat.intervalDay at '..dat.intervalDay)
            dofile('savedata.lua')
            table.insert(topub, {'intervalDay', dat.intervalDay})
        elseif top == "night" then
            dat.intervalNgt =  tonumber(dt) or 0
            dat.lastNgt = 0
            print('Set dat.intervalNgt at '..dat.intervalNgt)
            dofile('savedata.lua')
            table.insert(topub, {'intervalNgt', dat.intervalNgt})
        -- ...

Далее:

Спойлер: garden.lua

Код (Lua):

    -- Измеряем освещенность
    dat.lux = 1024 - adc.read(0)
    table.insert(topub, {'lux',dat.lux})
    print("lux: "..dat.lux)
    -- Узнаем который час
    local tm = rtctime.epoch2cal(rtctime.get()+3*60*60)
    --print(string.format("%02d:%02d:%02d", tm.hour, tm.min, tm.sec))
    -- Если с часами все нормально и знаем время заката и рассвета
    if tm.year ~= 1970 and dat.setH ~= 100 and dat.riseH ~= 100 then
        -- Время минут сейчас
        local tmnow = tm.hour * 60 + tm.min
        -- Время минут заката
        local nght = dat.setH * 60 + dat.setM
        -- Время  минут рассвета
        local day = dat.riseH * 60 + dat.riseM

        -- Сейчас день или ночь по времени?
        if tmnow > nght and dat.now == 'Day' then
            dat.now = 'Night'
        elseif tmnow > day and dat.now == 'Night' then
            dat.now = 'Day'
        end
    else
        -- Плохо со временем -  узнаем по освещенности
        if dat.lux > 100 and dat.now == 'Night' then
            dat.now = 'Day'
        elseif  dat.lux < 5  and dat.now == 'Day' then
            dat.now = 'Night'
        end

    end
    print('Now is '..dat.now)

    -- Если это включение устройства (устанавливается при старте)
    if dat.powerON  then
        dat.powerON = nil
        -- выключаем полив а всякий случай
        dat.startwater = 0
        -- Типа решение о поливе уже принято
        if dat.now == 'Day' then
            dat.makedesDay = 1
        else
            dat.makedesNgt = 1
        end
    end
    -- Сейчас день и мы не принимали решени о поливе
if dat.now == 'Day' and dat.makedesDay == 0 then
    -- День наступил - сбрасываем флаг принятия ночных решений
    dat.makedesNgt = 0
    -- Соотносим с количеством дней интервала между поливами
    -- Если выждали нормально
    if dat.lastDay >= dat.intervalDay then
        -- Поливаем
        dat.lastDay = 0
        print('Water at Day!')
        dat.startwater = 1
    else
        -- Иначе не поливаем но добавляем день
        dat.lastDay = dat.lastDay + 1
        print('Day Interval:', dat.lastDay)
        dofile('savedata.lua')
    end
    -- Оповещаем о решении брокер
    table.insert(topub, {'lastDay', dat.lastDay})
    -- Выставляем флаг что все решено
    dat.makedesDay = 1
end

-- Ночью действуем аналогично дневному алгоритму

if dat.now == 'Night' and dat.makedesNgt == 0 then
    dat.makedesDay = 0
    if dat.lastNgt >= dat.intervalNgt then
        dat.lastNgt = 0
        print('Water at Night!')
        dat.startwater = 1
    else
        dat.lastNgt = dat.lastNgt + 1
        print('Night interval:', dat.lastNgt)
        dofile('savedata.lua')
    end
    table.insert(topub, {'lastNgt', dat.lastNgt})
    dat.makedesNgt = 1
end
-- Если есть хоть какое-то значение dat.startwater:
if dat.startwater then
    dofile('turnvalve.lua')
end

tm, tmnow, nght, day = nil, nil, nil, nil

И кран:

Спойлер: turnvalve.lua

Код (Lua):

--
do
    print('turnvalve works.')
    -- Этот файл просто так не вызывается!
    -- Раз вызвали - прекращаем подачу питания на любые ноги крана, если она есть.
    if dat.vlpowered then
        gpio.write(pins.open, gpio.HIGH)
        gpio.write(pins.close, gpio.HIGH)
    end
    -- Если есть таймер подачи питания на ноги крана - убиваем
    if dat.powerpin then
        dat.powerpin:stop()
        dat.powerpin:unregister()
        dat.powerpin = nil
    end

    -- Функция подачи питания на ногу крана и удержания ее там 30 секунд
    local function runpin(pin)
        --Есть питание на ноге
        dat.vlpowered = true
        -- Подаем электричество
        gpio.write(pin, gpio.LOW)
        print('ON pin '..pin)
        -- Создаем таймер отключения питания
        dat.powerpin = tmr.create()
        dat.powerpin:register(30000, tmr.ALARM_SINGLE, function(tm)
            -- Отключаем питание
            gpio.write(pin, gpio.HIGH)
            dat.vlpowered = nil
            tm = nil
            dat.powerpin = nil
            print("OFF by 30 sec. pin "..pin)
        end)
        -- Запуск таймера
        dat.powerpin:start()
    end

    -- При вызове файла проверяем зпись в таблице о том открывать или закрывать кран

    -- Если открывать
    if dat.startwater == 1 then
        -- Открываем
        runpin(pins.open)
        -- Оповещаем брокер
        table.insert(topub, {'iswatering',"ON", 1})

        -- Если не запущен таймер закрытия крана - создаем
        if not dat.tmrpoliv then
            dat.tmrpoliv = tmr.create()
            -- Определяем когда закрыть
            dat.tmrpoliv:register(dat.poliv * 1000, tmr.ALARM_SINGLE, function(t)
                -- Оповещаем брокер
                table.insert(topub, {'iswatering',"OFF", 1})
                -- Шлем питание на ногу
                runpin(pins.close)
                t = nil
                dat.tmrpoliv = nl
            end)
            -- Запускаем таймер
            dat.tmrpoliv:start()
        end

    end

    -- Если закрыть
    if dat.startwater == 0 then
        print("Got stop watering!")
        -- Если работает таймер полива - убиваем
        if dat.tmrpoliv then
            dat.tmrpoliv:stop()
            dat.tmrpoliv:unregister()
            dat.tmrpoliv = nil
        end
        -- Оповещаем брокер
        table.insert(topub, {'iswatering',"OFF", 1})
        -- Шлем питание на ногу закрытия крана
        runpin(pins.close)
    end
    dat.startwater = nil
end

Все. В следующий раз точно поясню как это безмерное количество файлов собирается в одну программу. И мы организуем прикол: запустим "умный дом на ардуино ESP-8266"

 

Скелет программы IoT ч.4. Вся программа.
Наконец, настало время собрать воедино наши кубики.

Вспомним, что Lua от NodeMCU - асинхронный код и заботиться о согласовании событий особо нет необходимости. То есть, например, мы можем создать таймер и раз в минуту выполнять такую функцию:

Код (Lua):

function dispatch()
    dofile('getsun.lua') -- Получили время закат/рассвет
    dofile('lightnow.lua') -- Управляем освещением
    dofile('scedset.lua') -- Проверяем расписание для отопителя
    dofile('temper.lua') -- Управляем отопителем
    dofile('garden.lua') -- Управляем поливом
    dofile('makepubl.lua') -- Готовим и публикуем данные на брокер
end
tmr.create():alarm(60000, 1, dispatch)

Это должно работать, но следует учесть две особенности.

1. Если у нас присутствует асинхронный код, то обычный, "линейный" код будет выполняться без ожидания результатов асинхронного.

В данном случае у нас:
getsun.lua - добывает данные о солнце в асинхроне. lightnow.lua начнет работать без его результатов.
temper.lua - имеет задержку на чтение датчиков температуры до 750 мс, следовательно garden.lua проскочит без температуры (но она для него не важна), а вот makepubl.lua точно не увидит результатов работы термометра и управления отопителем в целом, а это уже плохо.

Мы с вами уже знаем как решить проблему асинхрона - он всегда имеет callback функцию и в нее можно втолкнуть, например, тот же dofile('....lua').

Для обычного случая так и рекомендуется делать. Вот пример. В getsun.lua затолкаем lightnow.lua:

Спойлер: Втыкаем CALLBACK

Код (Lua):

local offset = 3
-- 'api.sunrise-sunset.org/json?lat=55.75583&lng=37.61778'
local function rep(dt)
    print(dt..': Sunset at '..dat.setH..':'.. dat.setM, ' Sunrise at '..dat.riseH..':'..dat.riseM)
    table.insert(topub, {'sunset',dat.setH..':'.. dat.setM})
    table.insert(topub, {'sunrise',dat.riseH..':'..dat.riseM})
    setH, setM, riseH, riseM, request, makeDig, ttmm, offset, rep = nil, nil, nil, nil, nil, nil, nil, nil, nil

    ------------  Втыкаем: -------------------
    dofile('lightnow.lua')
    -------------------------------
end

if dat.setHMcount < 10 then
    dat.setHMcount = dat.setHMcount + 1
    rep('Just')
else
    local setH, setM, riseH, riseM, makeDig
    local request = "GET /json?lat=55.75583&lng=37.61778&formatted=0 HTTP/1.1\r\n"..
        "Host: api.sunrise-sunset.org\r\n\r\n"
    conn=net.createConnection(net.TCP, 0)
    conn:on("connection", function(conn, payload) conn:send(request) end)
    conn:on("receive", function(conn, payload)
        local ttmm = string.sub(payload,string.find(payload,'sunrise')+20,string.find(payload,'sunset')+24)
        payload = nil
        riseH, riseM, setH, setM = string.match(ttmm,'(%d+):(%d+).+sunset.+T(%d+):(%d+)')
        makeDig = function(dig, trans)
            dig = tonumber(dig)
            if trans then
                dig = (dig + offset < 24) and (dig + offset) or (dig - 21)
            end
            return dig
        end
        if setH and setM then
            dat.setH = makeDig(setH, true)
            dat.setM = makeDig(setM)
        end
        if riseH and riseM then
            dat.riseH = makeDig(riseH, true)
            dat.riseM = makeDig(riseM)
        end
        dat.setHMcount =  0
        rep('Got')
        conn:close()
        end)
    conn:connect(80, 'api.sunrise-sunset.org')
end

Отлично! Но, решив одну проблему мы продили другую: теперь getsun.lua и lightnow.lua стали асинхронными, и тот же makepubl.lua не увидит итогов их работы.
Да, ладно - справимся! Воткнем и его в callback:

Спойлер: Кусочек getsun.lua:

Код (C++):

--...
local function rep(dt)
    print(dt..': Sunset at '..dat.setH..':'.. dat.setM, ' Sunrise at '..dat.riseH..':'..dat.riseM)
    table.insert(topub, {'sunset',dat.setH..':'.. dat.setM})
    table.insert(topub, {'sunrise',dat.riseH..':'..dat.riseM})
    setH, setM, riseH, riseM, request, makeDig, ttmm, offset, rep = nil, nil, nil, nil, nil, nil, nil, nil, nil

    ------------  Втыкаем: -------------------
    dofile('lightnow.lua')
    dofile('makepubl.lua')
    -------------------------------
end
-- ...
 

Все! Проблема решена!
Стоп! Забыли про температуру. Но ее тоже можно отвесить в каллбэки таким же образом.

То есть через правильное прописывание очередного dofile('... .lua') в предыдущем проблема решается.
И так можно делать. Да более того - так и делается, в основном.

Продвинутый вариант - продумать и разделить программу на асинхронные и последовательные куски кода. Аснхрон(ы) вызывать заранее и кидть результаты в таблицу, а потом, через некоторое время, по окончанию работы самого "тугого" асинхрона callback вызывает все остальное. Тоже работает.

2. Но тут вступает в работу вторая особенность: в тяжелых случаях может банально не хватить памяти.
Продвинутые пользователи тут же вспомнят о функции collectgarbage ( ) - и правильно.
Но,

• для ее работы тоже нужно "место";
• для ее работы тоже нужно "время".

Втыкание ее в последовательный код мало что дает. Вот если "оттормозиться" - тогда функция отработает хорошо. Однако, при любой паузе в линейном коде система сама запускает освобождение памяти и без нашего напоминания collectgarbage ( ) .

Как быть? Есть неспешный вариант! (А куда нам спешить - мы все равно исполняем наши файлы раз в минуту, а можно и реже - чего "забивать эфир" брокера повторяющейся информацией!)

Вспомним, таблицы в Lua - гора самоцветов. Записью таблицы может быть все что угодно, и даже - функция. Мы навтыкаем в таблицу последовательность вызовов файлов на исполнение и будем неспеша, каждые три секунды вызывать.

Почему три? По наблюдению, вызов getsun (самый длинный) занимает до 1.5 секунд. Еще столько-же хватит системе подчистить память.

Вот как это выглядит:

Спойлер: Ай, красота!

Код (Lua):

dispatch = function()
    -- Таблица функций для вызова
    threads = {
        function() dofile('getsun.lua') end,
        function() dofile('lightnow.lua')end,
        function() dofile('scedset.lua')end,
        function() dofile('temper.lua')end,
        function() dofile('garden.lua')end,
        function() dofile('makepubl.lua')end
    }
    -- Счетчик шагов вызова из таблицы threads
    local nextc = 1
    -- Вызываем следующую запись из таблицы
    local function ne()
        if nextc <= #threads then
            print('no '..nextc)
            -- Это непосредственно вызов очередной записи
            threads[nextc]()
            nextc = nextc + 1
        end
    end
    -- Первый вызов
    ne()
    -- Остальное вызываем пошгово через 3 секунды:
    tmr.create():alarm(3000, 1, function(t)
        if nextc <= #threads then
            ne()
        else
            t:stop()
            t:unregister()
            t = nil
            nextc, ne, threads = nil, nil, nil
        end
    end)

end

tmr.create():alarm(60000, 1, dispatch)

.... Еще не конец!

 

Все, коллеги. Перед вами универсальный диспетчер запуска любых чужих скопипащенных кусков кода!

На это можно было бы и закончить - уже все работает, но есть еще любопытная деталь. Она касается именно нашей, крутейшей железки.

Вы, конечно, еще не проверили код выше - а он выдаст вот такую ошибку:



Какой-то объект уже очищен, мы что-то пытаемся соединить с nil и никаких указаний на проблемное место!
Приехали... Вроде раньше было все логично - и на тебе!
Хорошо что счетчик указывает на проблему в третьем, scedset.lua, файле, но где она - не понятно! Если закомментировать строку с его вызовом - все работает.
Проблема касается того, что мы в первых трех файлах создаем и уничтожаем локальные переменные с одинаковыми (вполне разумными) названиями. По-отдельности все это работало бы, но вместе - вот какая незадача.

Вы можете поковыряться в файлах и найти что там не так, но я точно знаю, что оно вам не надо.
И это в коде, который буквально построчно закомментирован. А если это код, где двадцать переменных каждая с обозначением из пары буков?..

В арсенале Lua есть функция защищенного вызова того, что может повести себя неадекватно - pcall(...).
Можно переписать код (мой) код с ее применением. Но оно вам надо? Есть прикольнее решение - называется сопрограммы (coroutine)! Вот здесь я начинал о ней, но так и не закончил

Ок, тем не менее, применим эту штуку здесь:

Спойлер: Корутина, однако...

Код (Lua):

-- Функция вызова обработки файлов по таймеру

dispatch = function()
    print('\n')
    -- Флаг работы глдавной функции
    dat.dispatch = true
    -- Таблица запускаемых на исполнение файлов - корутин
    local threads = {}
    -- Перечень файлов, что надо последовательно выполнять
    local filestorun = {
        'getsun.lua',    -- (Для 1 и 3)Проверка времени восход/закат
        'lightnow.lua',    -- (1)Управление освещением
        'scedset.lua',    -- (2)Проверка расписания для отопителя
        'temper.lua',    -- (2)Управление отопителем
        'garden.lua',    -- (3)Полив
        'makepubl.lua'    -- Подготовка даных к публикации
    }
    -- Переменная для создания сопрограммы (корутины)
    local co
    -- Перебираем таблицу с именами файлов для выполнения
    for _, v in ipairs(filestorun) do
        -- Создаем корутину для каждого имени файла
        co = coroutine.create(function ()
            -- Корутина не исполняет свой код до прямой команды на исполнение:
            return dofile(v)
        end)
        -- Вставляем задачу сопрограммы в таблицу для исполнения
        table.insert(threads, co)
    end
    -- Счетчик вызванных сопрограмм из таблицы
    local nextc = 1
    -- Функция вызова очередной сопрограммы
    local function ne()
        -- Если не достигли конца таблицы
        if nextc <= #threads then
            -- Вызываем корутину и одновременно печатаем результат ее вызова
            print('no '..nextc, filestorun[nextc] , (coroutine.resume(threads[nextc])))
            -- Увличиваем счетчик очередного вызова
            nextc = nextc + 1
        end
    end
    -- Старт вызова первой сопрограммы
    ne()
    -- Отальные сопрограммы вызываются через 3 секунды каждая
    tmr.create():alarm(3000, 1, function(t)
        if nextc <= #threads then
            ne()
        else
            t:stop()
            t:unregister()
            t = nil
            nextc, ne, threads = nil, nil, nil
        end
    end)

end
-- Каждую минуту выполняем наши файлы
tmr.create():alarm(60000, 1, dispatch)

Итак, выше перед вами файл main.lua - недостающее звено нашего проекта. Он несложен, совсем несложен, но делает великое дело - изолирует друг от друга код и запускает его в защищенном режиме.



Также с комментариями файл:

Спойлер: setglobals.lua

Код (Lua):

myClient = "test001"  -- (!!!) Заменить на свое!
dat = {
    target = 22, -- (!!!) Целевая температура отопителя по умолчанию
    askds = '', -- (!!!) DS18b20 адрес для управления отопителем
    -- askds = 't0054', -- Пример установки адреса
    poliv = 3600, -- (!!!) Время полива в секундах
-----------------------------------------
    dispatch = false,
    light = 'OFF',
    lightF = false,
    arm = 'OFF',
    heat = 'OFF',
    broker = false,
    siren = 'OFF',
    auto = 'ON',
    clpub = 0, -- count lost publications
    ----- Восход/закат
    -- 100 - до получения правильных данных
    setH = 100,
    setM = 100,
    riseH = 100,
    riseM = 100,
    setHMcount = 10,
    ------ Полив
    now = 'Night',
    lux = 0,
    makedesDay = 0,
    lastDay = 0,
    intervalDay = 0,
    makedesNgt = 0,
    lastNgt = 0,
    intervalNgt = 0,
    -- Включение после подачи питания
    -- чтобы сразу не начался полив
    powerON = 'true'
}
-- Если вам лень переименовывать клиент - я переименую
if myClient == "test001" then
    myClient = "home_"..node.chipid()
    print('\n\n\nClient is: '..myClient..'!!!!!!!!!\n\n\n')
end
pins = { --Ноги
    light = 0, -- освещение
    heat = 7, -- нагреватель
    siren = 6, -- сирена
    open = 8, -- открыть кран
    close = 9, -- закрыть кран
    pir = 5, -- ПИР датчик
}
for _,v in pairs(pins) do
    gpio.mode(v, gpio.OUTPUT)
end
gpio.mode(pins.pir,gpio.INPUT)

topub = {}
killtop = {}

-- Перерабатываем расписание в машинное
if file.exists('transform.lua') and file.exists('sced.lua') and  not file.exists('timeschd.lua') then
      dofile('transform.lua')
end

-- Восстанавливаем сохраненные данные с прошлой сессии
if file.exists('setsaveddat.lua') then
      dofile('setsaveddat.lua')
end

-- Если сохранен режим охраны - ставим
if dat.arm == "ON" then
    dofile('setarm.lua')
end
-- Коннект к брокеру
dofile('setmqtt.lua')
-- Главная программа
dofile('main.lua')

Вот оно в работе:



Настало время приложить архив всего о чем писалось ранее - прилагаю.
В нем две папки - версия без полива и с поливом. С поливом - максимально тяжелая ситуевина.
Полагаю, вы сами сможете "распилить" этот проект на части, если вам, например, нужен лишь полив или охрана + полив.

Осталось написать только заключительную часть. В ней постараюсь объяснить, почему весь этот мой труд, хотя он отлично работает, вам ни разу не нужен и вы можете счастливо прожить без него.
Наверное.

 

Была бы возможность нажать "Мне нравится" дважды - нажал бы трижды!
Может начнете писать книгу, альтернативную изданию Иерусалимски? Слог у Вас шикарный! Супер!

 

Спасибо! Однако, эти заметки мало кому нужны

Сейчас взялся за часы на матрице MAX7219. Утилитарный проект, в отличие от шикарного, что сейчас Иван двигает. Зато проще. Часы уже работают стабильно но код ещё слабоват.

 

Часы на MAX7219.

Вот так:

Мы видим текущее время, текущую температуру за окном, ожидаемые температуру и состояние неба.

Первый вопрос - зачем? В сети полно готовых решений. Вот замечательный открытый проект от Ивана.

Наши часы отличаются тем, что решают две узкоспециализированные задачи.

Первая задача - не опоздать на работу и быстро принять решение о правильной одежде и зонте. О второй задаче - позже.

То что часы от Ивана крутые и красивые имеет обратную сторону - длительность оповещения о текущей и предстоящей погоде сильно затягивается.
Когда утром, в спешке, носишься по квартире, надо оттормозиться, чтобы прочитать что сейчас тебе расскажут о погоде в том месте, где ты всегда находишься. Смысл? Как то меня сие раздражает.

Бегущая строка хороша в общественном транспорте - ты там ничего не делаешь, и можно заняться чтением движущихся буковок. Это даже успокаивает. А вот дома, ИMХО, это не всегда подходит.

В общем, начнем...

Погоду будем забирать на сайте https://www.apixu.com/ - регистрируемся и получаем ключ.
А потом вот файлик askweatherAll.lua - ловите свою погодку:

Код (Lua):

local key = "Ваш Ключ"
local city = "Moscow"
-- Таблица с рабочими данными
if not dat then dat = {} end
-- Разные переменные
local tnow, sky, max, min, codenow, codef
-- Стринг полученного ответа от сервера
local answer = ''
local conn

-- Функция обработки полученного запроса
local function getdata()
    -- Закрываем и уничтожаем соединение
    conn:close()
    conn = nil
    -- Нет ответа - не повезло
    if answer == "" then
        print('Lost answer!')
    else
        -- Захватываем из ответа (1) текущую температуру, (2) код текущей погоды,
        -- (3) максимальную темрературу сегодня, (4) минимальную температуру сегодня,
        -- (5) код ожидаемой погоды
        tnow, codenow, max, min, codef =  string.match(answer,'temp_c":(%p*%d+.%d*),.+"code":(%d+).+maxtemp_c":(%p*%d+).+mintemp_c":(%p*%d+).+"code":(%d+)')
        answer = nil
        -- Если что-то не получилось захватить - делаем значения по умолчанию.
        tnow = tnow or '- 50'
        max = max or '-50'
        min = min or '-50'
        codenow = tonumber(codenow) or 1000
        codef = tonumber(codef) or 1000
        -- Заносим в рабочую таблицу данные
        dat.asktemp = tnow..'0'
        print('Got Temp: '..dat.asktemp)
        dat.maxtemp = max
        dat.mintemp = min
        print('Got Max: '.. dat.maxtemp..', Min: '..dat.mintemp)
        dat.codenow = codenow
        dat.codef = codef
        print('Got Sky codes: '..dat.codenow..' '..dat.codef)
    end
    -- Зачищаем хвосты
    answer = nil
    tnow, sky, max, min, key, city, codenow, codef, getdata = nil, nil, nil, nil, nil, nil, nil, nil, nil
    dat.askw = 0
end

-- Готовим текст запроса к серверу
local request = "GET http://api.apixu.com/v1/forecast.json?key="..key.."&q="..city.." HTTP/1.1\r\n"..
    "Host: api.apixu.com\r\n\r\n"
-- Определяем соединение
conn=net.createConnection(net.TCP, 0)
-- Реакция на соединение - отправляем запрос
conn:on("connection", function(conn, payload) conn:send(request); request = nil end)

-- Реакция на получение данных
conn:on("receive", function(conn, payload)
    -- Данные приходят от сервера кадрами, если первый кадр -
    -- пишем его в переменную answer
    if answer == '' then
        answer = payload
    -- на втором кадре -  добавляем к переменной answer,закрываем соединение
    -- и отправляем ответ в обработку.
    else
        answer = answer .. payload
        payload = nil
        getdata()
    end
end)
-- Приступаем к соединению и запросу.
conn:connect(80, 'api.apixu.com')

На выходе:

 

Часы на MAX7219 - 2
Теперь модуль для работы с MAX7219. В принципе, вы можете его подхватить у Marcel .
А можно воспользоваться моим. Он чуть-чуть быстрее. Ну просто самую малость.
Да что там... Я его полностью переписал.

Не забыть, что в прошивке должны быть модули SPI и bit.

Работать с модулем так:

Код (Lua):

dig = {}
dig['1'] = {16,48,16,16,16,16,56,0}
dig['2'] = {56,68,4,56,64,64,124,0}
dig['3'] = {124,4,8,24,4,68,56,0}
dig['4'] = {8,24,40,72,124,8,8,0}
dig['5'] = {124,64,120,4,4,68,56,0}
dig['6'] = {28,32,64,120,68,68,56,0}
dig['7'] = {124,4,4,8,16,32,64,0}
dig['8'] = {56,68,68,56,68,68,56,0}
dig['9'] = {56,68,68,60,4,8,112,0}
dig['0'] = {56,68,76,84,100,68,56,0}
dig['+'] = {0,4,4,31,4,4,0,0}
dig['-'] = {0,0,0,124,0,0,0,0}
dig['z'] = {0,0,0,0,0,0,0,0}
dig['r'] = {16,16,40,68,68,68,56,0} -- rain
dig['c'] = {0,48,74,69,65,62,0,0} -- cloud
dig['R'] = {0,4,2,127,2,4,0,0} -- arrow

max7219 = require("max7219")
max7219.setup({numberOfModules = 4, SSPin = 8, intensity = 6 })
max7219.clear()
max7219.setIntensity(1)

max7219.write({dig['1'],dig['2'],dig['R'],dig['+']})

Модуль зацеплен за этот пост.

Ноги соединять:
D5 - clock
D7 - data
D8 - CS

Питание на MAX7219 подавать - 5 вольт.

 

Часы на MAX7219 - Заключение и все файлы проекта
Наметился один интересный проект - будем закругляться с часами. С первым вариантом. Второй будет позже, пока не знаю когда.

Этот - очень прикидочный, невыверенный, тестовый!

Выкладываю проект полностью, все файлы. Они без комментариев, кроме мест, где надо ввести ваши данные.

Что делают часы:
- показывают время, текущую температуру, температуру на сегодня днем, ожидаемое состояние неба;
- забирают информацию с трех источников одновременно:

1. сервер apixu.com
2. брокер MQTT
3. народный мониторинг.

С народного можно забирать до пяти датчиков температуры с целью усреднения их значения. Можно и один забирать - усреднится сам с собой. Усредненное значение сравнивается с информацией с apixu.com и если разница более трех градусов (на народном датчики то частенько дохнут) - предпочтение отдается серверу apixu.com.
- с 6 утра до 23 - яркость увеличенная
- с 6 утра до 16 - выдается прогноз погоды на день, после 16 - ожидаемая минимальная температура
- естественно, можно выбирать что в приоритете для текущей погоды. Например, в Москве я беру и усредняю минимальные данные с трех разных датчиков народного мониторинга, на даче - со своего термометра через брокер;
-- можно включать и выключать в настройках анимацию.

Анимация - это не бегущая строка! Бегущие строки - для эстетов и крутых парней, которые имеют время пялиться на светодиоды .

Соединение и модули прошивки указаны в предыдущем посту. К обычным модулям добавка
SPI и bit - обязательна.
Файлы в приложении распакуйте, откройте каждый - в некоторых надо внести собственные изменения.

Где надо уточнять я натыкал восклицательных знаков, увидите сразу.

Обязательно: _asknarod.lua, askweatherAll.lua - не заработают без ваших персональных данных.

asknarod.lua - укажите до пяти датчиков для чтения.

setmqtt.lua соединит вас брокером iot.eclipse.org и ни на что не подпишет - тоже ковыряйте.

Даже если ничего не исправлять Часы подхватят время и будут работать. Вместо прогноза погоды и текущей погоды получите нули. Остановите / закомментируйте таймер tmrwth в конце файла main.lua и получите просто часы с синхронизацией точного времени каждые 1000 секунд.

Надеюсь, почитав эту тему вы настроите часы под себя с легкостью. Нет - задавайте вопросы.

Вопрос "я сделал все как здесь написано а оно ВООБЩЕ не работает" - задавать здесь.

 

Часы MAX7219. Все апдейты неспеша здесь.
Апдейт. Вечером берет погоду на завтра.
Повторюсь, пока, до отдельного упоминания, это все прикидки, устройство не находится в разделе готовых проектов.

UPD-2 - уточнение. Други, я там перед отправкой запроса на сервера забыл проверку наличия wifi. Полагаю, сами сделаете. Надо main.lua поправить:

Код (Lua):

if dat.askw > 50 and wifi.sta.status() == 5 then

Ну, кроме того, еще забыл файлик про снег. Файл dsnow.lua есть, но скрипт им не пользуется. Его надо воткнуть в начало файла prtForecast.lua на основе анализа вот этой странички: http://www.apixu.com/doc/Apixu_weather_conditions.json

UPD-3. 13/08/2018. По результатам наблюдения за работой часов сделал некоторые обновления.
Из файла установки связи с MQTT брокером убрал функцию проверки текущего времени - она теперь в файле main.lua.

main.lua несколько изменил, внеся в него проверку не только наличия wifi, но и выхода в Internet.
Файл - max7219_3Amperka.zip - полный комплект файлов.

UPD4. 28/08/2018. Амперка_12_09M - почищены способы обработки температур и их ошибок и т.п. Поправлен выбор состояния неба. Добавлена пара новых состояний.

UPD5. 31/08/2018. Amperka_12_15 - Поразмыслил над модулями Apixu и Народного мониторинга.
В народном мониторинге был недосмотр - если мониторинг вернул меньше датчиков чем запрашивалось, все падало. Исправил. Apixu немного переосмыслил с точки зрения борьбы за память.

UPD6. 03/09/2018. Амперка12_16.zip

Дальше все будет здесь.

 

Модуль для MAX31855.
Применять так:

Код (Lua):

do
    -- Таблица для наполнения температурами от термопары и max31855
    local tmp = {}
    -- Грузим модуль
    max = require('_max31855')
    -- Нога CS - SSPin = 8, а также ноги по умолчанию CLK - 5, SO - 6
    max.setup({SSPin = 8})
    -- Забираем температуру
    max.gettmp(tmp)
    -- Печатаем что получили
    table.foreach(tmp, print)
    -- Выгружаем модуль
    package.loaded['_max31855'] = nil
    -- Ликвидируемся
    max,tmp = nil,nil
end

Модуль в приложении. Это понятный вариант.

 

И еще один модуль max31855 - поплотнее (меньше памяти) и куда как более индийский (но суть та же)
Применяем:

Код (Lua):

do
    local tmp = {}
    max = require('_max31855n')
    -- 8 - нога CS, другие ноги SCL - 5, SO - 6
    max.gettmp(tmp, 8)
    table.foreach(tmp, print)
    package.loaded['_max31855n'] = nil
    max, tmp = nil,nil
end

Удалите из модуля инструкции print(...) и будет еще меньше. Удалите проверки на валидность передаваемых данных (пишите скрипты без ошибок) - станет совсем маленьким. "Сама, сама..."

Правильное применение:



Минимальное применение:



Модуль не проверяет ответ max31855 на биты ошибок.

 

Здравствуйте
Я собираю умную вентиляцию в ванную, взял за основу ваш код, тестировал работу с mqtt сервером и получил странное поведение. Когда после загрузки модуль не может подключится и ловит ошибку, то заново запускается setmqtt.lua и пытается подключится, но если модуль подключился к серверу и после теряет с ним связь, то после выполнения setmqtt.lua он просто перезагружается без сообщений об ошибках. Причем файл полость отрабатывает но вместо отработки таймера начинается перезагрузка.

Код (Lua):

-- Этот файл задает параметры и устанавливает соединение с mqtt брокером.
-- Скрипт обеспечивает надежное удержание соединения и его самовосстановление
-- при потере как wifi так и самого брокера по любым причинам.

if not mqttClient then
    mqttClient = mqtt.Client( MQTT_CLIENT_ID, 60, MQTT_LOGIN, MQTT_PASSWORD)
    mqttClient:lwt(MQTT_CLIENT_ID..'/state', "OFF", 0, 0) --последняя воля
    mqttClient:on("message",
        function(client, topic, data) --получение сообщения от брокера:
            -- очищаем пришедший от брокера топик до чистого топика-команды
            -- приходить они будут в формате 'myClient/command/setTemperature'
            -- "очищенная" и передаваемая для анализа - 'setTemperature'
            local top = string.gsub(topic, MQTT_TOPIC.."/command/","")
            print('Got now:',top, ":", data)
            if data then
                -- заполняем таблицу killtop данными формата
                -- '{'<topic>', '<data>'}'
                table.insert(killtop, {top, data})
                if not dat.analiz then
                    -- dofile("analize.lua")
                end
        end
    end)
    mqttClient:on("offline", function(con) --потеря связи с брокером:
        dat.broker = false
        print('mqttClient: offline')
        dofile('setmqtt.lua')
    end)
end

-- Если файл вызывается рекурсивно
-- соединение надо принудительно остановить
mqttClient:close()
print("mqttClient:close")

local count = 0
print("set count")
local connecting = function(getmq)
    if wifi.sta.status() == wifi.STA_GOTIP then
        print('Got wifi')
        tmr.stop(getmq)
        print('tmr.stop(getmq)')
        tmr.unregister(getmq)
        print('tmr.unregister(getmq)')
        getmq = nil
        print('getmq = nil')
        mqttClient:connect(MQTT_BROKER_IP, MQTT_BROKER_PORT, 0, 0,
        function(client)
            print("Connected to Broker")
            -- mqttClient:subscribe(MQTT_TOPIC.."/command/#",0, function(conn)
            mqttClient:subscribe("/#",0, function(conn)        
                print("Subscribed: "..MQTT_TOPIC.."/command/#")
            end)
            mqttClient:publish(MQTT_TOPIC..'/state',"ON",0,0)
            dat.broker = true
            count = nil
        end,
        function(client, reason)
            print("mqtt error: "..reason)
            dofile('setmqtt.lua')
        end)
    else
        print("Wating for WiFi "..count.." times")
        count = count + 1
        -- if count > 20 then node.restart() end
    end
end
print("set connecting")
-- Таймер периодически запускает функцию соединения
tmr.create():alarm(5000, 1, function(timer)
    print("tmr.create")
    -- и передает в нее свои опознавательные знаки
    -- чтобы его остановить и "убить"
    connecting(timer)
end)
tmr.delay(6000)
print("end")
 

в консоли я получаю

Код (Text):

Connected to Broker
Subscribed: /bath/ventilation/command/#
Got now:    /bath/ventilation/state    :    ON
mqttClient: offline
mqttClient:close
set count
set connecting
end

ets Jan  8 2013,rst cause:1, boot mode:(3,6)

load 0x40100000, len 26040, room 16
tail 8
chksum 0xa3
load 0x3ffe8000, len 2180, room 0
tail 4
chksum 0xf9
load 0x3ffe8884, len 136, room 4
tail 4
chksum 0x07
csum 0x07
„гм‚'м“{‚уo<дЊdЏp{lc›Я|;“lњoаѓgг l`„г;›dЊdЊ$`ЊгsЫlд$„l`„г{“dЗџ

NodeMCU custom build by frightanic.com
    branch: master
    commit: 8181c3be7aed9f0a0ceb73ac8137c1a519e8a8e9
    SSL: false
    modules: dht,file,gpio,mqtt,net,node,tmr,uart,wifi
build created on 2018-07-21 21:25
powered by Lua 5.1.4 on SDK 2.2.1(cfd48f3)
lua: cannot open init.lua
>
 

предполагая что тут какая то проблем с таймером

 

А мой код работает нормально? Проверяли?

 

это он и есть, поменял имена перемененных и константа и добавил коменты ну и закомитал вызовы остальных файлов когда выявил баг, сейчас работают только два файла setglobals.lua и setmqtt.lua

 

Все таки попробуйте мой "чистый"

 

попробую, и если он отработает как искать причину бага?

 

Странный вопрос, не так ли?

Пытайтесь последовательно отключить все что Вы добавили. Я пока с сотового - завтра посмотрю что к чему.

 

Смотрите, в консоли при перезагрузке есть такая строка:


Это значит что причина перезагрузки - сброс питания.
Проверьте работу на отдельном источнике - не исключаю, что ваш компьютер не додает корма модулю в момент переподключения.