correlation_id în RabbitMQ: Corelarea Cererilor RPC în RabbitMQ

Tiparul RPC prin correlation_id

Când un client trimite o cerere către un server de procesare și așteaptă rezultatul pe o coadă dedicată de răspunsuri (reply_to), acesta poate trimite sute de cereri paralele pe aceeași coadă. Pentru a ști cărui apel îi corespunde fiecare răspuns sosit, serverul copiază proprietatea correlation_id din cerere direct în antetul răspunsului.

import uuid

corr_id = str(uuid.uuid4())
channel.basic_publish(
    exchange='',
    routing_key='calculator_rpc',
    properties=pika.BasicProperties(
        reply_to='coada_mea_raspuns',
        correlation_id=corr_id
    ),
    body=b'{"op": "sqrt", "val": 144}'
)