Быстрый прототип IIoT-решения на Raspberry PI и Yandex IoT. Часть вторая

[oleg_gavrilov]

Я правильно понял, что вы учите людей вызывать cloud function на каждое событие в MQTT, и вставлять в pg записи по одной? Может, хоть какое-то примечание сделаете, что это «применимо только в образовательных целях»? Извиняюсь, если пропустил что-то.

[vldplcd]

Да, все верно, статья скорее образовательная — обзор того, как быстро набросать простое решение в облаке, чтобы телеметрия не пропадала, а куда-нибудь сохранялась, т.е. какие инструменты для этого можно использовать (все-таки не раз подчеркивали, что это цикл статей о «быстром прототипе»)).

Естественно, в промышленных решениях необходимо решать задачи обработки более плотного потока данных (по сравнению с тем, что был в разобранном примере). И если сейчас единичные вставки прокатывают (все-таки при слабой интенсивности pg их адекватно переваривает), то с увеличением нагрузки и использованием, скажем, Clickhouse, нужно что-то придумывать. Самое простое — с помощью того же сервиса очередей формировать большие батчи, которые затем направлять на вставку СУБД. Кажется, это хорошая тема для отдельной статьи)

[slog2]

В статье не хватает ещё одного абзаца — сколько денег придётся платить яндексу.

[robofreak]

У меня получилось так

[robofreak]

Спасибо за статью, очень полезная. Я повторила все, что здесь описано, и у меня заработало.

Единственное, нашла ошибку в коде: в функцииmakeCreateTableStatement стоит лишняя открывающая скобочка в выражении, из-за чего таблица не создается. Если убрать ее, то все в порядке.

[robofreak]

И еще: в одной папке с функцией-обработчиком index.py должен лежать файл requirements.txt со строчкой psycopg2==2.9.9
Очевидный момент, но не для всех - если кто с Python не дружит, то может достаточно много времени потратить на поиск ошибки.