Если перестали выгружаться сущности в DWH проверить работает ли STRP-connector, на борде если не работает коннектор, то узнать причину для этого пользоваться ручкой статуса коннектора GET https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors/top-storage.product-storage-exporter.export.product-instance/status (пример с product-instance, сбой по дру)
с bearer токеном dp auth print-token
далее действовать по сообщению ошибки, возможно понадобится изменить конфигурацию коннектора https://gitlab.tcsbank.ru/strp/strp-connector/-/tree/master/cluster/test.kafka_kaas_common_cluster/top-storage
В случае, если в аудит таблицах проблемные записи то исправить их, чтобы узнать проблемные rev можно пользоваться аудитом, смотреть какие записи выгружались последние и искать близжайшие revs
select * from <TABLE_NAME>_aud where rev > start_rev and rev < end_rev
select * from <TABLE_NAME>_aud where id = '02zJKVHTCLgdASNZlt09OOm0' order by rev asc;
Также есть ручки
- Все коннекторы - GET https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors
- Настройки коннектора - GET https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors/top-storage.product-storage-exporter.export.product-instance
- Статус коннектора - GET https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors/top-storage.product-storage-exporter.export.product-instance/status
- Рестарт таски в коннекторе - POST https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors/top-storage.product-storage-exporter.export.product-instance/tasks/0/restart
- Пауза коннектора - PUT https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors/top-storage.product-storage-exporter.export.product-instance/pause
- Включение коннектора - PUT https://connect-prod-kaas-common.prod-kaas-common.internal.ds-prod2.prod.k8s.tcsbank.ru/connectors/top-storage.product-storage-exporter.export.product-instance/resume