У нас растёт число внешних интеграций, и каждому партнёру нужно получать наши события по HTTP сразу, как только у нас что-то меняется. Проблема в том, что колбэки уходят прямо из того запроса, который их спровоцировал: тормозящий получатель тянет за собой наш код, упавшие вызовы пропадают без следа, а через неделю я не могу восстановить, ушло ли конкретное уведомление вообще. Хочу закрыть эту тему раз и навсегда и вынести всю исходящую доставку в один самостоятельный сервис. Задача сервиса — принять событие от наших внутренних систем, надёжно его записать и затем разослать копию на каждый эндпоинт, подписанный на этот тип события, так чтобы доставка жила отдельно от бизнес-логики, которая событие сгенерировала.
Основной акцент — устойчивость к сбоям получателя, и именно это я хочу видеть проработанным. Любая попытка доставки подписывается, чтобы принимающая сторона убедилась в подлинности отправителя, содержит отметку времени и уникальный номер доставки против повторного проигрывания, а при неуспехе повторяется с растущей паузой и случайным разбросом вплоть до заданного лимита, после которого переходит в отложенный разбор как недоставленная. Обязательно ограничение одновременных отправок по каждому получателю, чтобы один зависший адрес не тормозил остальных, и поддержка ключей идемпотентности, чтобы повтор не порождал двойного эффекта у партнёра. Отдельно уточню рамки: мне не нужна универсальная брокерская очередь для внутренних заданий и не нужен входной API-шлюз-прокси. Нужна именно гарантированная исходящая рассылка вебхуков наружу, а очередь внутри — только средство, а не сам продукт.
Вдобавок мне важны прозрачность и рычаги управления, которые можно передать саппорту и партнёрам. Каждая попытка ложится в журнал с телом запроса, кодом и временем ответа, номером повтора, и всё это ищется по событию, получателю и статусу. Нужны ручной перезапуск неудачной или отложенной доставки, постановка эндпоинта на паузу с последующим возобновлением и смена ключей подписи без остановки сервиса. Прошу подойти как к продакшн-компоненту: с адекватной документацией и тестами, а не как к разовому наброску.
— Точка приёма входящих событий с проверкой и сохранением
— Подписки: связка типов событий с адресами получателей
— Подпись тела, отметка времени, номер доставки, защита от повторов
— Повторы с нарастающей паузой, разбросом и статусом недоставленных
— Лимит одновременных отправок на получателя и идемпотентность
— Журнал с поиском, ручным перезапуском и паузой получателя
— Смена ключей подписи, документация и автоматические тесты
Основной акцент — устойчивость к сбоям получателя, и именно это я хочу видеть проработанным. Любая попытка доставки подписывается, чтобы принимающая сторона убедилась в подлинности отправителя, содержит отметку времени и уникальный номер доставки против повторного проигрывания, а при неуспехе повторяется с растущей паузой и случайным разбросом вплоть до заданного лимита, после которого переходит в отложенный разбор как недоставленная. Обязательно ограничение одновременных отправок по каждому получателю, чтобы один зависший адрес не тормозил остальных, и поддержка ключей идемпотентности, чтобы повтор не порождал двойного эффекта у партнёра. Отдельно уточню рамки: мне не нужна универсальная брокерская очередь для внутренних заданий и не нужен входной API-шлюз-прокси. Нужна именно гарантированная исходящая рассылка вебхуков наружу, а очередь внутри — только средство, а не сам продукт.
Вдобавок мне важны прозрачность и рычаги управления, которые можно передать саппорту и партнёрам. Каждая попытка ложится в журнал с телом запроса, кодом и временем ответа, номером повтора, и всё это ищется по событию, получателю и статусу. Нужны ручной перезапуск неудачной или отложенной доставки, постановка эндпоинта на паузу с последующим возобновлением и смена ключей подписи без остановки сервиса. Прошу подойти как к продакшн-компоненту: с адекватной документацией и тестами, а не как к разовому наброску.
— Точка приёма входящих событий с проверкой и сохранением
— Подписки: связка типов событий с адресами получателей
— Подпись тела, отметка времени, номер доставки, защита от повторов
— Повторы с нарастающей паузой, разбросом и статусом недоставленных
— Лимит одновременных отправок на получателя и идемпотентность
— Журнал с поиском, ручным перезапуском и паузой получателя
— Смена ключей подписи, документация и автоматические тесты
