Экспорт сообщений в Data Streams
-
В консоли управления выберите каталог, в котором находится реестр.
-
Выберите сервис IoT Core.
-
Выберите в списке нужный реестр.
-
Перейдите на вкладку Экспорт в Data Stream.
-
В правом верхнем углу нажмите кнопку Добавить экспорт.
-
Заполните поля:
- Имя — имя экспорта.
- Фильтр MQTT-топиков — укажите топик, из которого будут экспортироваться сообщения, или фильтр с использованием символов подстановки. Если поле пустое, экспортируются сообщения из всех топиков реестра и всех топиков устройств внутри реестра.
- Поток данных — укажите поток данных, в который будут отправляться сообщения из MQTT-топиков, или создайте новый. Если вы создали новый поток, нажмите кнопку Обновить для обновления списка потоков.
- Сервисный аккаунт — укажите сервисный аккаунт с ролью
yds-writer.
-
Нажмите кнопку Добавить.
Если у вас еще нет интерфейса командной строки Yandex Cloud (CLI), установите и инициализируйте его.
По умолчанию используется каталог, указанный при создании профиля CLI. Чтобы изменить каталог по умолчанию, используйте команду yc config set folder-id <идентификатор_каталога>. Также для любой команды вы можете указать другой каталог с помощью параметров --folder-name или --folder-id.
Чтобы создать экспорт:
-
Получите список реестров в каталоге:
yc iot registry listРезультат:
+----------------------+-------------------+ | ID | NAME | +----------------------+-------------------+ | arenou2oj4********** | my-registry | +----------------------+-------------------+ -
Создайте экспорт:
yc iot registry yds-export add \ --registry-name <название_реестра> \ --name <название_экспорта> \ --database <путь_базы_данных> \ --stream <название_потока> \ --mqtt-topic-filter <топик> \ --stream-service-account-name <имя_сервисного_аккаунта>Где:
--registry-name— имя реестра.--name— имя экспорта.--database— размещение базы данных, в которой хранятся данные потока: вторая часть значения поля Эндпоинт (часть после вхождения/?database=). Например,/ru-central1/r1gra875baom********/g5n22e7ejf**********.--stream— имя потока данных, в который будут отправляться сообщения из MQTT-топиков.--mqtt-topic-filter— топик, из которого будут экспортироваться сообщения, или фильтр с использованием символов подстановки. Если параметр не указан, экспортируются сообщения из всех топиков реестра и всех топиков устройств внутри реестра.--stream-service-account-name— имя сервисного аккаунта с рольюyds-writer.
Результат:
id: are520n46t********** name: export-from-topic registry_id: areqqa5ntm********** database: /ru-central1/b1gia87mbaom********/etnu4r0v1c********** stream: topic-message-stream service_account_id: ajeu9klp40********** created_at: "2023-09-18T09:52:28.840124837Z"
Чтобы добавить экспорт в Data Streams для реестра, воспользуйтесь вызовом gRPC API RegistryService/AddDataStreamExport.