Потому что если так, то тебе достаточно прост держать счётчик: -- глобальный, на всяк случ, если данная переменная уже есть то используем её bad_counter = bad_counter or 0 ... if isGoodRequest then bad_counter = 0 else bad_counter = bad_counter + 1 end if bad_counter == 5 then sendMail(...) end Тогда вообще на каждые пять плохих запросов подряд будет слать, и если много-много плохих запросов подряд — пришлёт только один раз. Если надо в целом на каждые пять плохих — обнуляем счётчик одновременно с sendMail

Вот, уже вырисовывается)

а isGoodRequest откуда береться?

Ну как ты проверяешь запрос, плохой он или хороший? Вот и запихни то условие вместо isGoodRequest (но добавь not, или поменяй местами условия if и else)

Вот ща типа полностью то как оно должно быть: badreq = badreq or 0 local status = event:getHeader("State") or '' local gateway = event:getHeader("Gateway") or '' if status == "NOREG" and gateway == "mixnet" then badreq = badreq + 1 else badreq = 0 end if badreq == 5 then sendmail(...) -- если хотим чтобы отправляло на -- каждые пять плохих запросов подряд: -- badreq = 0 end

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

Вот "плохой" статус это NOREG, но gateway несколько

Тогда ставь то условие, которое тебе нужно, панимаищ? : )

ну, я же могу их перечислить OR?

Можешь

А можешь и не or, а таблицей

хотя нет. тогда будет считаться в общем на все гейты

А ещё можешь занести их в табличку isBad = { NOREG = true, NOREGISTER = true, BADREG = true } if isBad[status] then ... Или в такую табличку которую я приводил выше

В целом, можно извратиться и сделать таблицу определения комбинаций, с которыми надо что-то уведомлять. enum = { NOREG = { mixnet = true, }, BLABLA = { intranet = true, extranet = true } } local status = event:getHeader("State") or '' local gateway = event:getHeader("Gateway") or '' if enum[status] and enum[status][gateway] then sendMail('y@and.ex', status .. ':' .. gateway) end

Вот такую

Тебе нужна помощь с составлением условий, какой запрос плохой а какой хороший? : )

Можешь поменять местами гейты и статусы, тогда можно будет вместо if enum[status] and enum[status][gateway] then ... написать if enum[gateway] and enum[gateway][status] then ... Это не принципиально, но может быть меньше придётся заполнять, например отсутствие реакции на некоторые гейты в принципе (просто не добавляем их в enum, добавляем туда только то на что реагируем).

Да я вот пока не вкурил. Условие плохое одно, но гейтов несколько. Если я сейчас так запилю, то счетчик же будет срабатывать на все NOREG. Скажем если с каждого гейта придет по одному NOREG, то оповещалка сработает

Ага

А тебе нужно чтобы на каждый гейт срабатывало по разному?

Нужно чтоб каждый гейт считался

Тогда мути более сложный счётчик. -- можем использовать local, -- потому что таблички ссылочные, -- заодно инициализируем, если это первый запрос -- и её пока не существует local badReq = badReq or {} local status = event:getHeader("State") or '' local gateway = event:getHeader("Gateway") or '' -- заполняем нулём, если у нас ещё нет инфы по этому гейтвею badReq[gateway] = badReq[gateway] or 0 if status == "NOREG" then badReq[gateway] = badReq[gateway] + 1 else badReq[gateway] = 0 end if badReq[gateway] == 5 then sendmail(...) -- badReq[gateway] = 0 end

Теперь у тебя есть восхитительная табличка badReq, которая хранит все плохие статусы подряд для каждого гейтвея. Прекольно, да?

Здорово)

Буду пробовать

Спасибо

Лучше подробно изучи луа, таблички — очень мощный инструмент. И довольно простой.

Да вот как раз и пытаюсь осваивать

Но без практики много непонятного. Причем я ни разу не программер

Ничо, это всё придёт с практикой. Я тоже не особо программер, хотя работаю им.

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

ключ - время с точностью до часа\5ти часов INCR - и понеслась душа в рай

редиска предпочтительнее тем, что можно шарить стейт между пачкой воркеров\машин

всем привет. подскажите - как передать объект в lua_State - указатель. чтобы его можно было везде достать?

https://www.lua.org/pil/28.1.html void *lua_newuserdata (lua_State *L, size_t size); static int newarray (lua_State *L) { int n = luaL_checkint(L, 1); size_t nbytes = sizeof(NumArray) + (n - 1)*sizeof(double); NumArray *a = (NumArray *)lua_newuserdata(L, nbytes); a->size = n; return 1; /* new userdatum is already on the stack */ }

Чтобы потом везде достать — передаёшь его как аргумент луа-функций.

Если хочешь чего-то похожего на ООП с луёвой стороны — вешаешь на этот указатель метатаблицу с __index равному табличке с методами объекта. Тогда сам указатель при вызове методов будет передаваться первым аргументом автоматически.

Если хочешь чего-то похожего на ООП с луёвой стороны — вешаешь на этот указатель метатаблицу с __index равному табличке с методами объекта. Тогда сам указатель при вызове методов будет передаваться первым аргументом автоматически.

вот про этот вариант где почитать?

В следующих трёх главах. Стрелка вправо.

понял, спасибо

Нужно чтоб каждый гейт считался

А пробовали prometheus посмотреть для хранения статусов? в grafana можно отображать красивые и яркие графики, а через alertmanager-bot делать рассылку сообщений при наступлении различных событий через необходимые каналы связи (почта, телеграм, slak, e.t.c), это я к тому что бы не тратить время на создание того что уже есть и можно взять коробку за даром - то есть безвозмездно. Но я мог не верно понять решаемую вами задачу и мой совет заглянуть в доку prometheus вообще не к месту

А пробовали prometheus посмотреть для хранения статусов? в grafana можно отображать красивые и яркие графики, а через alertmanager-bot делать рассылку сообщений при наступлении различных событий через необходимые каналы связи (почта, телеграм, slak, e.t.c), это я к тому что бы не тратить время на создание того что уже есть и можно взять коробку за даром - то есть безвозмездно. Но я мог не верно понять решаемую вами задачу и мой совет заглянуть в доку prometheus вообще не к месту

Да, пробовал. Красиво, но для меня избыточно.

Тогда мути более сложный счётчик. -- можем использовать local, -- потому что таблички ссылочные, -- заодно инициализируем, если это первый запрос -- и её пока не существует local badReq = badReq or {} local status = event:getHeader("State") or '' local gateway = event:getHeader("Gateway") or '' -- заполняем нулём, если у нас ещё нет инфы по этому гейтвею badReq[gateway] = badReq[gateway] or 0 if status == "NOREG" then badReq[gateway] = badReq[gateway] + 1 else badReq[gateway] = 0 end if badReq[gateway] == 5 then sendmail(...) -- badReq[gateway] = 0 end

Привет. Что то пошло не так... local name = event:getHeader("Event-Name") or '' local subb = event:getHeader("Event-Subclass") or '' --freeswitch.consoleLog("INFO", "Получен Event! " .. name) — Вылавливаем нужный EVENT if name == "CUSTOM" and subb == "sofia::gateway_state" then local badReq = badReq or {} local gateway = event:getHeader("Gateway") local status = event:getHeader("Ping-Status") -- заполняем нулём, если у нас ещё нет инфы по этому гейтвею badReq[gateway] = badReq[gateway] or 0 if status == "UP" then freeswitch.consoleLog("INFO", "Исходный:".. badReq[gateway] .."\n") badReq[gateway] = badReq[gateway] + 1 freeswitch.consoleLog("INFO", "Прибавили:".. badReq[gateway] .."\n") else badReq[gateway] = 0 freeswitch.consoleLog("INFO", "Статус: DOWN\n") end if badReq[gateway] == 2 then freeswitch.consoleLog("INFO", "Bingo..." ..gateway.. "\n") -- sendmail(...) -- badReq[gateway] = 0 end В итоге получаем 2019-05-30 09:24:35.671710 [INFO] switch_cpp.cpp:1365 Исходный:0 2019-05-30 09:24:35.671710 [INFO] switch_cpp.cpp:1365 Прибавили1 2019-05-30 09:24:36.331678 [INFO] switch_cpp.cpp:1365 Исходный:0 2019-05-30 09:24:36.331678 [INFO] switch_cpp.cpp:1365 Прибавили1 2019-05-30 09:24:43.731713 [INFO] switch_cpp.cpp:1365 Исходный:0 2019-05-30 09:24:43.731713 [INFO] switch_cpp.cpp:1365 Прибавили1 2019-05-30 09:24:44.391710 [INFO] switch_cpp.cpp:1365 Исходный:0

https://m.habr.com/ru/company/toshibarus/blog/444502/

А пробовали prometheus посмотреть для хранения статусов? в grafana можно отображать красивые и яркие графики, а через alertmanager-bot делать рассылку сообщений при наступлении различных событий через необходимые каналы связи (почта, телеграм, slak, e.t.c), это я к тому что бы не тратить время на создание того что уже есть и можно взять коробку за даром - то есть безвозмездно. Но я мог не верно понять решаемую вами задачу и мой совет заглянуть в доку prometheus вообще не к месту

Лог нжинкс пишешь в джсон формате тянешь его в прометеус - мониторинг готов :)

Да, пробовал. Красиво, но для меня избыточно.

А что вам показалось избыточным?

FS стоит на одноплатнике. Не хочется её захламлять

Лог нжинкс пишешь в джсон формате тянешь его в прометеус - мониторинг готов :)

Не совсем соглашусь что сборка данных в json формате из nginx prometheus'ом - является готовым мониторингом, скорее это просто сбор и хранение данных с виеменной меткой, для того что бы это стало мониторингом необходим процесс отслеживания событий, что более ближе к мониториргу чем красивые графики на экранах в grafana

Парни, а какое время жизни таблицы в Lua? badReq = badReq or {}; Записываю в таблицу данные и при следующем запросе их уже нет

Парни, а какое время жизни таблицы в Lua? badReq = badReq or {}; Записываю в таблицу данные и при следующем запросе их уже нет

может ты данные перетираешь?

Парни, а какое время жизни таблицы в Lua? badReq = badReq or {}; Записываю в таблицу данные и при следующем запросе их уже нет

Пока на них есть ссылка

Технически пока на них есть ссылка, а после - до итерации GC

Не знаю. Вроде как нет. Правильно ли я заполняю данными в этом случаее? Я про переменную badReq["".. gateway ..""] Т.к. значений несколько... badReq = badReq or {}; n = badReq["".. gateway ..""] or 0; badReq["".. gateway ..""] = badReq["".. gateway ..""] or n; freeswitch.consoleLog("INFO", "Записано в ': ".. badReq["".. gateway ..""': ".. badReq["".. gateway ..""] .."\n"); n = n + 1; badReq["".. gateway ..""] = n; freeswitch.consoleLog("INFO", "После прибавления: ".. badReq["".. gateway ..""] .."\n"); else badReq["".. gateway ..""] = 0; freeswitch.consoleLog("INFO", "+1\n"); end;

Не знаю. Вроде как нет. Правильно ли я заполняю данными в этом случаее? Я про переменную badReq["".. gateway ..""] Т.к. значений несколько... badReq = badReq or {}; n = badReq["".. gateway ..""] or 0; badReq["".. gateway ..""] = badReq["".. gateway ..""] or n; freeswitch.consoleLog("INFO", "Записано в ': ".. badReq["".. gateway ..""': ".. badReq["".. gateway ..""] .."\n"); n = n + 1; badReq["".. gateway ..""] = n; freeswitch.consoleLog("INFO", "После прибавления: ".. badReq["".. gateway ..""] .."\n"); else badReq["".. gateway ..""] = 0; freeswitch.consoleLog("INFO", "+1\n"); end;

Эээ, а что должно конкатенировать “” .. gateway .. “”?

Во что*

Строка. Название гейта gateway = event:getHeader("Gateway") status = event:getHeader("Ping-Status")

Строка. Название гейта gateway = event:getHeader("Gateway") status = event:getHeader("Ping-Status")

Ничего не понял

gateway - переменная?

да

Почему не использовать просто badReq[gateway] или badReq[tostring(gateway)]?

да я уже по всякому пробовал. А если я запилю badReq[gateway] в название строки переменная попадет? Или все же имя строки "gateway"?

В общем проблема ясна. Таблица "умирает". Живет только на 1 запрос

Есть ли возможность продлить ей время жизни?

ngx.shared ?

Есть ли возможность продлить ей время жизни?

а что говорит ваш debug когда вы дэбажите этот сценарий?

При каждом EVENTE пустые данные. Т.к. это FreeSWITCH деграет этот скрипт при наступлении события

При каждом EVENTE пустые данные. Т.к. это FreeSWITCH деграет этот скрипт при наступлении события

так вы угадываете или вам это debuger показывает с возможностю пошагового прохождения вашего сценария?

При каждом EVENTE пустые данные. Т.к. это FreeSWITCH деграет этот скрипт при наступлении события

Это значит всего лишь то, что моё предупреждение сработало, и FreeSWITCH очищает/создаёт новую ВМ на каждый запрос.

Шарь данные через БД.

Я смотрел дебаг в консоле. Данных в таблице при новом запросе нет

Вот это вот

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

Ну что же, буду курить как отправить в Redis из скрипта, и дальше эти данные считывать

)

А, кстати, можешь ещё попробовать убрать local перед badReq, на всякий случай

Пробовал

Ну тады глобал спейс каждый раз новый : )

Как отправить — local badReqCount = redis:hget("badReq", gateway) or 0 if isBadReq then badReqCount = badReqCount + 1 else badReqCount = 0 end redis:hset("badReq", gateway, badReqCount) ...

Редиска супер простая

Редиска супер простая

Недавно видел учебник по редиске

Интересно, что там можно понаписать на учебник по Редиске?

На самом деле, довольно много всего. Типа "как правильно шардировать, в чём прекол пайплайнов и как их применять чтобы было круто, как оптимизировать память, дёргать удалённые процедуры и писать оптимизированную фигню" и т.п.