Источник
Учебная форма с сервером db.example, портом 5432 и базой analytics_demo. Подключение к внешней базе не выполнялось.
Для SQL-подключения выберите таблицу или режим запроса. Запросы должны только читать данные; изменяющие команды не являются способом настройки источника. Задайте нужные поля и лимиты выборки и проверьте небольшую выборку перед полным запуском.
Получатель
| Режим | Поведение | Необходимая настройка |
|---|---|---|
| insert | Добавить новые строки. | Таблица и сопоставление полей. |
| update | Изменить существующие записи по ключу. | Ключевые поля и обновляемые значения. |
| upsert | Обновить совпадающие записи или добавить отсутствующие. | Стабильный ключ, схема и правила записи. |
Получатель всегда пишет в таблицу, а не выполняет произвольный SQL-запрос. Для update/upsert нужны ключевые поля. ClickHouse поддерживает только добавление.
Ключи и типы
- Ключ должен однозначно определять запись.
- Перед записью проверьте повторы входных ключей.
- Типы чисел, дат и пустых значений должны соответствовать схеме базы.
- Обязательные поля без значений по умолчанию нужно заполнить.
- Отдельно оцените повторный запуск: insert может создавать дубликаты.
Проверка результатов
Сравните ожидаемое число добавлений/обновлений с журналом и запросом конкретных ключей в целевой таблице. При потере ответа базы сначала сверьте фактические записи, затем решайте, нужен ли повтор.