Очереди RabbitMQ
Для реализации очередей исполнения задач, в рамках системы используется RabbitMQ. Для корректной работы системы реализованы следующие очереди:
| Наименование очереди | Описание | Наполняется сервисом | Вычитывается сервисом |
|---|---|---|---|
| enclave_tasks | Обрабатывает задачи для исполнения Анклавом, такие как матчинг и выгрузка данных на VM | Back-end API | Enclave |
| datasets | Обрабатывает задачи на обновление метаинформации о датасетах из Apache Atlas в платформе | Atlas Entity Syncer | Dataset updater |
| glossaries | Обрабатывает задачи на обновление метаинформации о глоссариях из Apache Atlas в платформе | Atlas Entity Syncer | Glossary updater |
| glossary_terms | Обрабатывает задачи на обновление метаинформации о Бизнес-терминах из Apache Atlas в платформе | Atlas Entity Syncer | Term updater |
| instances | Обрабатывает задачи на обновление метаинформации об инстансах из Apache Atlas в платформе | Atlas Entity Syncer | 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 |