CDC из MySQL или PostgreSQL через Debezium
Проверяем версию базы, режим binary log или WAL, ключи таблиц, объём данных, частоту изменений и требования целевой системы. Разворачиваем Debezium Connector либо Debezium Server, создаём отдельную роль с нужными правами и защищаем соединения.
Когда стоит обратиться
Обычно к нам обращаются в таких ситуациях:
- Полная выгрузка товаров или заказов долго работает, нагружает рабочую базу и всё равно оставляет данные устаревшими.
- Интеграция видит новые записи, а обновления и удаления периодически теряются между системами.
- Поиск или отчётность должны получать изменения вскоре после транзакции на сайте.
Что именно мы сделаем
Проверяем версию базы, режим binary log или WAL, ключи таблиц, объём данных, частоту изменений и требования целевой системы.
Разворачиваем Debezium Connector либо Debezium Server, создаём отдельную роль с нужными правами и защищаем соединения.
Запускаем initial snapshot — начальный снимок существующих данных — и подтверждаем переход к непрерывному чтению журнала.
Настраиваем события создания, обновления и удаления, преобразование полей, идемпотентную запись и обработку изменений схемы.
Добавляем контроль lag — задержки потока — проверяем перезапуск, повторную доставку и восстановление после временной остановки.
Что входит в стоимость
49 900 ₽ за всю работу
Проверяем версию базы, режим binary log или WAL, ключи таблиц, объём данных, частоту изменений и требования целевой системы. Разворачиваем Debezium Connector либо Debezium Server, создаём отдельную роль с нужными правами и защищаем соединения. Запускаем initial snapshot — начальный снимок существующих данных — и подтверждаем переход к непрерывному чтению журнала.
Перед сдачей проверяем, что новая запись, изменение и удаление появляются в целевой системе с ожидаемым ключом и содержимым. В комплект результата входят: рабочий CDC-поток из MySQL или PostgreSQL через Debezium; схема событий, преобразований и правил записи в целевую систему; панель или журнал задержки плюс инструкция по перезапуску и восстановлению. Небольшие связанные уточнения, которые появляются во время работы, уже учитываем в стоимости.
Что будет готово
Передадим вам
- Рабочий CDC-поток из MySQL или PostgreSQL через Debezium.
- Схема событий, преобразований и правил записи в целевую систему.
- Панель или журнал задержки плюс инструкция по перезапуску и восстановлению.
Перед сдачей проверим
- Новая запись, изменение и удаление появляются в целевой системе с ожидаемым ключом и содержимым.
- После перезапуска коннектор продолжает поток с сохранённой позиции и без лишних дублей в результате.
- Мониторинг показывает текущую задержку и сообщает о длительной остановке передачи.
Как это выглядит на практике
Обновление товара в аналитике и поиске
Типичная ситуация: полная выгрузка товаров или заказов долго работает, нагружает рабочую базу и всё равно оставляет данные устаревшими. Сначала меняем цену и остаток тестового товара в рабочей базе, затем Debezium считывает событие из журнала транзакций, а в финале целевая система обновляет запись по устойчивому идентификатору товара.
- 01
Меняем цену и остаток тестового товара в рабочей базе.
- 02
Debezium считывает событие из журнала транзакций.
- 03
Целевая система обновляет запись по устойчивому идентификатору товара.
- 04
Удаляем тестовую запись и проверяем корректную обработку события удаления.
Что понадобится для работы
От вас
- Временный административный доступ к MySQL или PostgreSQL и сетевым настройкам.
- Доступ к Kafka, Redpanda, Debezium Server либо возможность развернуть нужный транспорт.
- Описание целевой системы, таблиц, ключей и требований к свежести данных.
Если у вас немного другая ситуация
Небольшие уточнения, которые помогают довести согласованный результат до рабочего состояния, уже учитываем в цене. Если по ходу работы появится отдельный крупный блок или понадобится платная лицензия, сначала обсудим варианты и стоимость. Расскажите о своей ситуации — подстроим план под неё.
- 3 000 ₽после подписания договора через Диадок
- 46 900 ₽после выполнения, демонстрации и приёмки результата
Предоплата входит в общую стоимость. Оставшуюся сумму оплачиваете после демонстрации и приёмки готовой работы.
Часто спрашивают
Об этой услуге
Чем CDC отличается при сравнении с обычной репликацией базы?
Репликация создаёт вторую базу того же типа для отказоустойчивости или чтения. CDC превращает изменения в события, которые удобно направлять в поиск, аналитику и разные прикладные системы.
Какую нагрузку Debezium создаёт на рабочую базу?
После начального снимка коннектор читает штатный журнал транзакций. Настраиваем размер пакетов и права так, чтобы основная работа базы сохраняла приоритет.
Что произойдёт при добавлении нового столбца?
Debezium передаст изменение схемы вместе с последующими событиями. Настраиваем совместимое преобразование и показываем порядок обновления целевой таблицы.
Обязательно разворачивать Kafka?
Для крупного потока Kafka или Redpanda дают удобное хранение и повторное чтение. Для компактной интеграции Debezium Server способен передавать события напрямую в поддерживаемую систему.
Цена и изменения по ходу работы
Цена на странице окончательная?
Да. Перед началом мы сверяем исходные данные и фиксируем результат в договоре. Указанная на странице сумма покрывает согласованную работу целиком, даже если её техническая реализация потребует больше времени, чем ожидалось при оценке.
Что означает резерв незапланированных работ?
Это уже включённый в цену запас времени на небольшие связанные уточнения заказчика, которые появляются после старта: например, добавить поле, изменить формат уведомления или учесть ещё одно условие обработки.
Резерв рассчитывается по формуле: стоимость услуги × 30% ÷ 1 500 ₽. Для услуги за 30 000 ₽ это 6 часов. Эти часы относятся только к дополнительным, заранее незапланированным уточнениям. Они не являются сроком проекта и не ограничивают время на основную работу: согласованный результат мы выполняем полностью.
Можно уточнять детали уже во время работы?
Да. Небольшие связанные изменения обычно помещаются во включённый резерв и не требуют доплаты. Если новая идея заметно меняет результат или превращается в самостоятельную задачу, сначала обсудим подход и стоимость. Любое решение согласуем до выполнения.
Начало работы и оплата
Как оформляются договор и оплата?
Подписываем договор через Диадок. Предоплата составляет 3 000 ₽ и входит в общую стоимость услуги. Остаток оплачивается после демонстрации и приёмки готового результата.
Когда начинается срок выполнения?
Срок отсчитывается после согласования задачи, получения необходимых доступов и материалов, подписания договора и поступления предоплаты. Конкретную дату старта и плановый день готовности подтверждаем перед началом.
Как учитываются платные лицензии и внешние сервисы?
До старта проверяем, нужны ли тарифы, лицензии, сертификаты или дополнительные ресурсы внешних систем. Если они потребуются, заранее покажем варианты и стоимость. По возможности аккаунты и лицензии оформляются сразу на заказчика.
Проверка результата и гарантия
Как принимается готовая работа?
Вместе проверяем согласованные сценарии на контрольных данных или тестовой копии, а затем демонстрируем результат. Для интеграций сверяем передачу данных и обработку ошибок, для сайта — работу нужных страниц и действий пользователя, для отчёта — расчёты и обновление данных.
Какая гарантия действует после сдачи?
На выполненные изменения действует гарантия 3 месяца. Если в изменённой нами части обнаружится ошибка нашей реализации, проверим и исправим её без дополнительной оплаты. Переданные материалы, настройки и код остаются у заказчика.