RPC модуль — это специально разработанный компонент, который действует как посредник между Cloudlink и внешним сервисом. Он подключается к определенной очереди RabbitMQ внутри Kubernetes кластера. После разработки и деплоя модуля его функционал можно интегрировать в конструктор Cloudlink, позволяя использовать сторонний сервис как узел в графе.
🌐 Развертывание RPC-модуля может осуществляться:
✅ внутри Kubernetes кластера Cloudlink. В этом случае он размещается и работает в том же кластере Kubernetes, где находятся все необходимые сервисы;
✅ вне Kubernetes-кластера. При этом варианте, чтобы обеспечить корректную работу, важно настроить связь с RabbitMQ, State Service и остальными сервисами, которые находятся внутри кластера.
🔧 Пример использования:
from app.adapter import NovaAdapter
from app.settings import APP_NAME, TASK_EXECUTION_TIMEOUT
from cld_rpc_utils.utils import TaskReceiver
task_receiver = TaskReceiver(NovaAdapter, APP_NAME, TASK_EXECUTION_TIMEOUT)
task_receiver.get_messages()
Так можно вывести любой ваш платформенный или инфраструктурный сервис без ожидания доработок и новых релизов.
#cloudlink #микросервисы