Связаться с экспертомПопробовать бесплатно
Создавайте контент и получайте гранты!Готовы написать своё руководство? Участвуйте в контент-программе и получайте гранты на работу с облачными сервисами!
Подробнее о программе
Проект Яндекса
© 2026 ООО «Яндекс.Облако»

Как начать работать с топиками в Yandex Cloud Notification Service

Статья создана
Обновлена 25 сентября 2026 г.
Открыть в Markdown

Cloud Notification Service (CNS) — сервис для мультиканальной отправки уведомлений пользователям. HTTP API сервиса совместим с Amazon SNS API.

Чтобы отправлять сообщения в разные эндпоинты одновременно, используйте топики. Топик позволяет отправлять уведомления сразу всем подписанным на него эндпоинтам.

Чтобы начать работать с топиками:

  1. Подготовьте облако к работе.
  2. Создайте каналы для уведомлений и эндпоинты:
  3. Создайте топик.
  4. Подпишите эндпоинты на топик.
  5. Отправьте уведомление в топик.

Подготовьте облако к работе

Зарегистрируйтесь в Yandex Cloud и создайте платежный аккаунт:

  1. Перейдите в консоль управления, затем войдите в Yandex Cloud или зарегистрируйтесь.
  2. На странице Yandex Cloud Billing убедитесь, что у вас подключен платежный аккаунт, и он находится в статусе ACTIVE или TRIAL_ACTIVE. Если платежного аккаунта нет, создайте его и привяжите к нему облако.

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

Подробнее об облаках и каталогах.

Создайте топик

  1. В консоли управления выберите каталог.

  2. Перейдите в сервис Cloud Notification Service.

  3. Слева выберите раздел Топики.

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

  5. Введите имя топика. Имя топика должно быть уникальным в Cloud Notification Service.

  6. (Опционально) Настройте запись логов:

    1. В разделе Логирование включите Запись логов.
    2. В списке Каталог выберите каталог, в котором будет расположена лог-группа.
    3. В поле Лог-группа выберите существующую лог-группу или создайте новую.

  7. (Опционально) Включите опцию Yandex Message Queue, чтобы отправлять сообщения в очереди Message Queue, которые подписаны на топик. Укажите сервисный аккаунт, у которого есть роль ymq.writer:

    • на каталог, в котором находятся очереди, подписанные на топик;
    • на каталог, в котором находится сам сервисный аккаунт.

    Как назначить роль.

  8. Нажмите Создать топик.

  1. Если у вас еще нет AWS CLI, установите и сконфигурируйте его.

  2. Выполните команду:

    aws sns create-topic \
  --name <имя_топика> \
  --attributes "{\"SQSServiceAccountId\":\"<идентификатор_сервисного_аккаунта>\"}"

    Где:

    • name — произвольное имя топика, должно быть уникальным в Cloud Notification Service.

    • SQSServiceAccountId — идентификатор сервисного аккаунта, от имени которого сообщения из топика будут отправляться в очереди Message Queue. Необязательный параметр. У сервисного аккаунта должна быть роль ymq.writer:

      • на каталог, в котором находятся очереди, подписанные на топик;
      • на каталог, в котором находится сам сервисный аккаунт.

      Примечание

      Чтобы указать сервисный аккаунт в атрибуте SQSServiceAccountId, у пользователя должна быть роль iam.serviceAccounts.user на каталог, в котором находится сервисный аккаунт. Иначе команда завершится с ошибкой авторизации.

    Подробнее о команде aws sns create-topic смотрите в документации AWS.

  1. Если у вас еще нет AWS SDK для Python (boto3), установите и настройте его.

  2. Чтобы создать канал push-уведомлений, используйте следующий код:

    response = client.create_topic(
    Name="<имя_топика>",
    Attributes={
        "SQSServiceAccountId": "<идентификатор_сервисного_аккаунта>",
    },
)

print(f"Topic ARN:", response['TopicArn'])

    Где:

    • Name — произвольное имя топика, должно быть уникальным в Cloud Notification Service.

    • SQSServiceAccountId — идентификатор сервисного аккаунта, от имени которого сообщения из топика будут отправляться в очереди Message Queue. Необязательный параметр. У сервисного аккаунта должна быть роль ymq.writer:

      • на каталог, в котором находятся очереди, подписанные на топик;
      • на каталог, в котором находится сам сервисный аккаунт.

      Примечание

      Чтобы указать сервисный аккаунт в атрибуте SQSServiceAccountId, у пользователя должна быть роль iam.serviceAccounts.user на каталог, в котором находится сервисный аккаунт. Иначе команда завершится с ошибкой авторизации.

Подпишите эндпоинты на топик

  1. Выберите топик.

  2. Слева выберите Подписки.

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

  4. Выберите тип канала уведомлений:

    • Мобильные push-уведомления.

      Введите ARN эндпоинта в формате: arn:aws:sns::<cloud_id>:endpoint/<platform>/<channel_name>/<endpoint_unique_id>. Скопировать ARN эндпоинта можно на странице его настроек.

    • Push-уведомления в браузере.

      Введите ARN эндпоинта в формате: arn:aws:sns::<cloud_id>:endpoint/<platform>/<channel_name>/<endpoint_unique_id>.

    • SMS.

      Введите номер телефона в формате E.164, например +79991112233. Телефон не требуется предварительно добавлять в канале уведомлений SMS, при этом сам канал должен быть создан.

    • Yandex Message Queue

      Введите URL очереди Message Queue.

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

    Таким же образом подпишите на топик другие эндпоинты.

Выполните команду:

aws sns subscribe \
  --topic-arn <ARN_топика> \
  --protocol <тип_канала> \
  --notification-endpoint <ARN_эндпоинта_или_номер_телефона>

Где:

  • topic-arn — ARN топика.

  • protocol — тип канала отправки уведомлений, например sms, application, sqs.

  • notification-endpoint — эндпоинт, который подписывается на топик:

    • для мобильных push-уведомлений и push-уведомлений в браузере — ARN эндпоинта в формате arn:aws:sns::<cloud_id>:endpoint/<platform>/<channel_name>/<endpoint_unique_id>;
    • для SMS — номер телефона в формате E.164, например +79991112233;
    • для Message Queue — URL очереди.

    Чтобы топик мог отправлять сообщения в очередь, у него должен быть задан атрибут SQSServiceAccountId. Подробнее в инструкциях по созданию и управлению топиком.

Подробнее о команде aws sns subscribe смотрите в документации AWS.

Используйте следующий код:

try:
    response = client.subscribe(
        TopicArn = "<ARN_топика>",
        Protocol = "<тип_канала>",
        Endpoint = "<ARN_эндпоинта_или_номер_телефона_или_URL_очереди>"
    )
    print(f"Topic ARN: {response['TopicArn']}")
except botocore.exceptions.ClientError as error:
    print(f"Error: {error}")

Где:

  • TopicArn — ARN топика.

  • Protocol — тип канала для отправки уведомлений, например sms, application, sqs.

  • Endpoint — эндпоинт, который подписывается на топик:

    • для мобильных push-уведомлений и push-уведомлений в браузере — ARN эндпоинта в формате arn:aws:sns::<cloud_id>:endpoint/<platform>/<channel_name>/<endpoint_unique_id>;
    • для SMS — номер телефона в формате E.164, например +79991112233;
    • для Message Queue — URL очереди.

    Чтобы топик мог отправлять сообщения в очередь, у него должен быть задан атрибут SQSServiceAccountId. Подробнее в инструкциях по созданию и управлению топиком.

Отправьте уведомление в топик

  1. Выберите топик.

  2. Нажмите кнопку Отправить уведомление.

  3. Выберите вид уведомлений:

    • Одинаковые — во все типы каналов будет отправлено одно и то же уведомление.
    • Различные — можно ввести разные тексты для разных типов каналов.

  4. Введите единый текст для всех каналов или разные тексты для разных типов каналов в формате JSON. Если канал не указан, будет отправлен текст по умолчанию из поля default.

    Формат уведомления в JSON:

    {
  "default": "<Текст_по_умолчанию>",
  "sms": "<Текст_уведомления_для_sms>",
  "sqs":  "<Текст_уведомления_для_очереди_сообщений>",
  "WEB": "<Текст_уведомления_для_браузера>",
  "APNS": {
    "aps": {
      "alert": {
        "title": "Заголовок_уведомления",
        "body": "Текст_уведомления"
      }
    }
  },
  "GCM": {
    "notification": {
      "title": "Заголовок_уведомления",
      "body": "Текст_уведомления"
    }
  },
  "HMS": {
    "notification": {
      "title": "Заголовок_уведомления",
      "body": "<Текст_уведомления>"
    }
  },
  "RUSTORE": {
    "notification": {
      "title": "Заголовок_уведомления",
      "body": "<Текст_уведомления>"
    }
  }
}

  5. Нажмите кнопку Отправить.

Выполните команду:

Для отправки уведомления:

aws sns publish \
--topic-arn <ARN_топика> \
--message-structure json \
--message '{"default": "<текст_уведомления>","APNS": {"aps":{"alert":"<текст_уведомления>"}},"GCM": {"notification":{"body":"<текст_уведомления>"}},"HMS": {"notification":{"body":"<текст_уведомления>"}},"RUSTORE": {"notification":{"body":"<текст_уведомления>"}},"WEB": "<текст_уведомления>","sms": "<текст_уведомления>","sqs": "<текст_уведомления>"}'

Где:

  • topic-arn — ARN топика.
  • message-structure — формат сообщения json.
  • message — текст уведомления или путь к файлу с уведомлением. Для отправки разных уведомлений в зависимости от типа канала укажите канал и текст уведомления. Если какой-либо канал не указан, будет отправлено сообщение по умолчанию.

Подробнее о команде aws sns publish смотрите в документации AWS.

Используйте следующий код:

try:
    response = client.publish(
        TopicArn="<ARN_топика>",
        Message=json.dumps({
            "default": "<текст_уведомления>",
            "APNS": {"aps":{"alert":"<текст_уведомления>"}},
            "GCM": {"notification":{"body":"<текст_уведомления>"}},
            "HMS": {"notification":{"body":"<текст_уведомления>"}},
            "RUSTORE": {"notification":{"body":"<текст_уведомления>"}},
            "WEB": "<текст_уведомления>",
            "sms": "<текст_уведомления>",
            "sqs": "<текст_уведомления>"
        }),
        MessageStructure="json"
    )
    print(f"Message ID: {response["MessageId"]}")
except botocore.exceptions.ClientError as error:
    print(f"Error: {error}")

Где:

  • TopicArn — ARN топика.
  • Message — текст уведомления. Можно указать единый текст для всех типов каналов или разные тексты для каждого типа канала. Если какой-либо канал не указан, будет отправлено сообщение по умолчанию из поля default.
  • MessageStructure — формат сообщения (json).
Предыдущая
Начало работы с SMS
Следующая
Все инструкции