Django получает новую запись в таблице и создает новую таблицу, если значение столбца уникально

В настоящее время я изучаю django и пытаюсь создать бэкэнд для управления IOT-устройствами и отображения их состояния на веб-странице и ищу некоторые рекомендации / методы лучшей практики.

У меня есть N устройств, каждое из которых имеет уникальный device_id. Они периодически передают данные, и таблица mySQL обновляется с некоторыми значениями и device_id в первом столбце. Я хочу создать некий механизм сортировки, который проверяет главную таблицу на наличие новых записей каждую минуту (или каждую новую запись в строке), поэтому я использовал django-celery-beat для создания задания по расписанию. Теперь я хочу создать новую таблицу, если в этот столбец пришла новая запись device_id с device_id в качестве имени таблицы (только если имя таблицы еще не существует) и типом таблицы, который будет выбран по значению столбца sensor_type.

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

Спасибо.

Вернуться на верх