Очереди RabbitMQ
Для реализации очередей исполнения задач, в рамках системы используется RabbitMQ. Для корректной работы системы реализованы следующие очереди:
| Наименование очереди | Описание | Наполняется сервисом | Вычитывается сервисом |
|---|---|---|---|
| enclave_tasks | Обрабатывает задачи для исполнения Анклавом, такие как матчинг и выгрузка данных на VM | Back-end API | Enclave |
| datasets | Обрабатывает задачи на обновление метаинформации о датасетах из Каталога данных в платформе | MetadataService | Dataset updater |
| glossaries | Обрабатывает задачи на обновление метаинформации о глоссариях из Каталога данных в платформе | MetadataService | Glossary updater |
| glossary_terms | Обрабатывает задачи на обновление метаинформации о Бизнес-терминах из Каталога данных в платформе | MetadataService | Term updater |
| instances | Обрабатывает задачи на обновление метаинформации об инстансах из Каталога данных в платформе | MetadataService | Instance syncer |
| pipeline_cleanroom_event_status | Обрабатывает задачи на обновление статусов запусков моделей CleanRoom в платформе | Tekton Webhook Listener | CleanRoom Status Watcher |
| create_pipeline_runner | Обрабатывает задачи на запуски модели CleanRoom | Back-end API | Pipeline Runner |
| emails | Обрабатывает задачи на отправку писем от Vaultee OIDC Provider | Back-end API | Email-service |
| pipeline_stopper | Обрабатывает задачи на остановку запусков CleanRoom | Back-end API | Pipeline Stopper |
| tables-for-audience-dataset | Обрабатывает задачи на создание датасетов на основе таблиц по результату исполнения модели | Back-end API | Pipeline Stopper |
| tables-for-sync | Обрабатывает задачи на синхронизацию метаданных таблиц | dbMetadataserviceSync | MetadataService |