Запись данных с устройства в базу данных

1. В консоли управления выберите каталог, в котором хотите создать сервисный аккаунт.
2. В списке сервисов выберите Identity and Access Management.
3. Нажмите кнопку Создать сервисный аккаунт.
4. Введите имя сервисного аккаунта: my-db-function-service-account.
5. Нажмите кнопку Добавить роль и выберите роли functions.functionInvoker и editor.
6. Нажмите кнопку Создать.

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

2. В списке сервисов выберите IoT Core.

3. Нажмите кнопку Создать реестр.

4. В поле Имя введите my-registry.

5. Введите пароль.

   • Длина — не менее 14 символов.
   • Должен содержать букву верхнего регистра, букву нижнего регистра и цифру.

   Важно

   Сохраните пароль, так как прочитать его из Yandex IoT Core будет невозможно.

6. Нажмите кнопку Создать.

После создания реестра вы попадете в его настройки.

1. Перейдите на вкладку Устройства.

2. Нажмите кнопку Добавить устройство.

3. В поле Имя введите my-device.

4. Введите пароль.

   • Длина — не менее 14 символов.
   • Должен содержать букву верхнего регистра, букву нижнего регистра и цифру.

   Важно

   Сохраните пароль, так как прочитать его из Yandex IoT Core будет невозможно.

5. Нажмите кнопку Создать.

1. В консоли управления выберите каталог, в котором нужно создать кластер БД.

2. В списке сервисов выберите Managed Service for PostgreSQL.

3. Нажмите кнопку Создать кластер.

4. В поле Имя кластера введите my-pg-database.

5. В поле Окружение выберите PRODUCTION.

6. В поле Версия выберите 12.

7. В блоке Класс хоста:

   • Укажите платформу Intel Cascade Lake.
   • Выберите тип burstable.
   • Укажите класс b2.medium.

   Важно

   Класс b2.medium был выбран только в рамках тестирования. В реальных проектах использовать хосты с гарантированной долей vCPU ниже 100% не рекомендуется.

8. В блоке Размер хранилища:

   • Выберите network-ssd.
   • Укажите размер равным 10 ГБ.

   Примечание

   Тип и размер диска следует выбирать в соответствии с решаемыми задачами. Значения, указанные выше, используются для тестирования.

9. В блоке База данных укажите атрибуты БД:

   • Имя базы данных. Имя БД должно быть уникальным в рамках каталога и содержать только латинские буквы, цифры и подчеркивания.
   • Имя пользователя — владельца БД. Имя пользователя должно содержать только латинские буквы, цифры и подчеркивания.
   • Пароль пользователя. Длина — от 8 до 128 символов.

   Для базы данных, которая создается вместе с кластером, устанавливаются настройки набора символов (кодировки) LC_CTYPE=C и LC_COLLATE=C. После создания эти настройки изменить нельзя, но вы можете создать новую базу с нужными настройками.

10. В блоке Хосты нажмите и включите опцию Публичный доступ.

11. В блоке Дополнительные настройки включите опцию Доступ из консоли управления.

12. Нажмите кнопку Создать кластер.

1. Выберите кластер my-pg-database.
2. Перейдите на вкладку SQL.
3. В поле Имя пользователя БД укажите имя пользователя, который владеет БД, созданной на предыдущем шаге.
4. В поле Пароль введите пароль, указанный при создании кластера.
5. Нажмите кнопку Подключиться.

1. В окне редактирования введите следующий запрос:

   Важно

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

   CREATE TABLE iot_events (
       event_id varchar(24) not null,
       device_id varchar(50) not null,
       event_datetime timestamptz not null,
       humidity float8 null,
       carbon_dioxide float8 null,
       pressure float8 null,
       temperature float8 null
   )
   

2. Нажмите кнопку Выполнить.

Дождитесь появления надписи о завершении выполнения запроса.

1. В консоли управления выберите каталог, в котором нужно создать функцию.
2. В списке сервисов выберите Cloud Functions.
3. Нажмите кнопку Создать функцию.
4. Введите имя функции.
5. Нажмите кнопку Создать.

1. В блоке Код функции:

   • В поле Среда выполнения выберите python37.
   • В поле Способ оставьте значение по умолчанию: Редактор кода.

2. Создайте файл myfunction.py.

3. В области редактирования файла вставьте код функции, размещенный на Github.

   Примечание

   Запрос, который используется для записи данных в БД, формируется в методе makeInsertStatement. Если необходимо убрать или добавить параметры, внесите изменения в этот метод.

4. В поле Точка входа укажите myfunction.msgHandler.

5. Задайте следующие параметры версии:

   • Таймаут — 10.
   • Память — 128 МБ.

6. В поле Сервисный аккаунт выберите my-db-function-service-account.

7. Добавьте переменные окружения:

   • VERBOSE_LOG — параметр, отвечающий за вывод подробной информации о выполнении функции. Введите значение True.
   • DB_HOSTNAME — имя хоста БД PostgreSQL для подключения.
   • DB_PORT — порт для подключения.
   • DB_NAME — имя базы данных для подключения.
   • DB_USER — имя пользователя для подключения.
   • DB_PASSWORD — пароль, который был введен при создании кластера.

   Чтобы определить значения параметров для подключения:

   1. В консоли управления выберите каталог, в котором вы создали кластер.
   2. В списке сервисов выберите Managed Service for PostgreSQL.
   3. Выберите кластер my-pg-database.
   4. В строке с нужной БД нажмите значок и выберите Подключиться.
   5. На вкладке PowerShell найдите пример строки подключения.
   6. Перенесите значения переменных host, port, dbname и user в соответствующее поле Значение переменных окружения функции.

8. Нажмите кнопку Сохранить изменения.

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

2. В списке сервисов выберите Cloud Functions.

3. На панели слева выберите Триггеры.

4. Нажмите кнопку Создать триггер.

5. В блоке Базовые параметры:

   • В поле Имя введите имя триггера.
   • В поле Описание введите описание триггера.
   • В поле Тип выберите IoT Core (устройство).

6. В блоке Настройки сообщений IoT Core:

   • В поле Реестр введите my-registry.

   • В поле Устройство введите my-device.

   • В поле MQTT-топик укажите топик, в который устройство отправляет данные:

     $devices/<идентификатор_устройства>/events
     

     Где <идентификатор_устройства> — идентификатор вашего устройства.

     Триггер будет срабатывать при появлении новых данных в указанном топике.

7. В блоке Настройки функции:

   • Выберите функцию для обработки данных, созданную ранее.
   • В поле Тег версии функции укажите $latest.
   • В поле Сервисный аккаунт укажите my-db-function-service-account.

8. Остальные поля оставьте пустыми или заполните по своему усмотрению.

9. Нажмите кнопку Создать триггер.