Руководство администратора

Настоящее Руководство содержит описание и сценарии эксплуатации и администрирования TQE(MQ).

• Сценарии использования.

TQE(MQ) выступает в качестве брокера, ответственного за передачу сообщений потребителям. Потребители получают только те сообщения, на которые подписаны. Такой подход снижает избыточный трафик данных, повышает эффективность обработки и обеспечивает максимально высокую пропускную способность.

Каждое сообщение состоит из нескольких полей:

• id - идентификатор сообщения. Монотонно возрастающий уникальный ключ генерируемый мастером набора реплик. При асинхронной репликации монотонность и уникальность поддерживаются только на уровне одной реплики.
• sharding_key - ключ шардирования. Опциональное поле. Если оно указано, на его основе выбирается целевой шард для сообщения. Если поле не указано, система самостоятельно назначает ключ для равномерной загрузки шарда. При статическом шардировании sharding_key обязателен.
• routing_key - ключ фильтрации. Опциональное поле. Если оно указано, очередь отвечает на запрос только сообщениями с указанным routing_key.
• deduplication_key - ключ дедупликации. Опциональное поле. Если оно указано, перед каждой вставкой очередь проверяет наличие такого ключа в индексе. По умолчанию очередь отвечает ошибкой, если такой ключ уже существует.
• payload - содержимое сообщения.
• metadata - метаданные.
• timestamp - время вставки.