CloudAMQP

La plataforma Devprime es compatible de forma nativa con CloudAMQP, que proporciona un enfoque SaaS a RabbitMQ, un software de mensajería de código abierto que funciona con los protocolos Advanced Message Queuing Protocol (AMQP) y Streaming Text Oriented Messaging Protocol (MQTT).

Las configuraciones de CloudAMQP siguen el mismo modelo que las de RabbitMQ con un punto de atención al parámetro HostName que ya incluye la url y las credenciales proporcionadas al crear el servicio en CloudAMQP. Los parámetros de usuario/contraseña/puerto no son necesarios

Suscríbete a una cola en RabbitMQ

El siguiente JSON muestra la configuración predeterminada con las credenciales de RabbitMQ, el intercambio utilizado, el reintento, la reserva, los subprocesos y la opción ‘Suscribirse’ para recibir eventos en la cola ‘orderevents’ como se define en el elemento Colas.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

"DevPrime_Stream": [
    {
      "Enable": "true",
      "Alias": "Stream1",
      "Default": "true",
      "StreamType": "RabbitMQ",
      "HostName": "amqps://user:password@demo.rmq.cloudamqp.com/demo",
      "Exchange": "devprime",
      "ExchangeType": "direct",
      "Retry": "3",
      "Fallback": "State1",
      "Threads": "30",
      "Buffer": "1",
      "Subscribe": [
        {
          "Queues": "orderevents"
        }
      ]
    }
  ],

En el siguiente ejemplo, detallamos la configuración predeterminada del adaptador y la configuración específica de RabbitMQ.

Generalidades —
Habilitar Habilitar el adaptador de flujo (verdadero/falso)
Alias Define un nombre único para identificar el servicio
Predeterminado Establece como valor predeterminado el centario de tener más de una secuencia (Verdadero/Falso)
Tipo de corriente Establece el tipo de secuencia (RabbitMQ/Kafka)
Nombre de host Configura la url/credencial proporcionada por CloudAMQP
Intercambio Configura el RabbitMQ
ExchangeType Configura el tipo de Exchange
Reintentar Configurar el número de reintentos
Reserva Configura un estado para la resistencia automática en caso de error
Hilos Establece el número de conexiones simultáneas que procesan eventos
Búfer Define el número de eventos obtenidos por conexión
Suscríbete Configura las colas de RabbitMQ para lectura

Ejemplo en el registro de la aplicación con esta configuración:

1
2

[INF][ms-order][Stream][Type "RabbitMQ"][Alias "Stream1"]
["Enable"][Subscribe]["orderevents"][Parallel "30"][Buffer "1"]

Ejemplo de YAML con la configuración de la aplicación:
Para exportar las configuraciones como una variable de entorno y usarlas en Kubernetes, ejecute el comando en la CLI de Devprime:
dp export kubernetes

1
2
3
4
5
6

- name: devprime_stream1
    value: "alias=Stream1|||enable=true|||default=true|||streamtype=RabbitMQ|||
    hostname=amqps://user:password@demo.rmq.cloudamqp.com/demo|||
    exchange=devprime|||exchangetype=direct|||retry=3|||
    fallback=State1|||threads=30|||buffer=1|||
    subscribe=[queues=orderevents]"

Utilice los ejemplos de RabbitMQ para explorar otras variaciones en la configuración.

Última modificación January 10, 2024 (967dcac3)