Порядок обработки запросов на выгрузку данных

Запрос на выгрузку данных обрабатывается в следующем порядке:

  1. Внешняя информационная система отправляет запрос INSERT INTO download_external_table в Prostore.
  2. Запрос поступает в сервис исполнения запросов Prostore.
  3. Если запрос был запущен на исполнение в асинхронном режиме, сервис исполнения запросов возвращает ответ о принятии запроса на обработку.
  4. Сервис исполнения запросов запрашивает актуальную информацию о логической схеме данных в сервисной базе данных и определяет, из какого датасорса следует выгрузить данные.
  5. Сервис исполнения запросов отправляет в коннектор выбранного датасорса команду на выгрузку данных.
  6. Коннектор выгружает данные в топик Kafka, с которым связана внешняя таблица выгрузки, указанная в запросе INSERT INTO download_external_table.
  7. Если запрос был запущен на исполнение в синхронном режиме, сервис исполнения запросов возвращает ответ о результате загрузки данных.

Подробнее о компонентах системы см. в разделе Компоненты системы и их связи.