Comment provisionner un PaaS RabbitMQ ?

Pour commencer, rendez-vous sur ITCare et recherchez votre service global cible où vous créerez votre nouveau cluster RabbitMQ.

Recherchez votre service Global dans la barre de recherche supérieure et cliquez dessus pour afficher sa page d'information.

Une fois dans votre Service Global, cliquez sur le bouton Créer une ressource, sélectionnez RabbitMQ et la version requise.

Remplir le formulaire :

• Sélectionner une topologie

• Définir le nom du futur cluster

• Si topologie Cluster : sélectionner le nombre de broker (3+)

• Le dimensionnement

• Le stockage requis sur chaque broker

• La localisation cible

• Le réseau cible

• Les options de gestion (sauvegarde, surveillance, 24/7, réplication site distant)

Cliquer sur Suivant une fois les champs remplis. A l'étape suivante, saisir le mot de passe du compte super user qui sera fourni puis cliquer sur Suivant.

Réviser la synthèse avant de soumettre le formulaire.

Une fois le déploiement prêt, vous en serez informé par e-mail.

Démarrer un cluster

En haut de la page du cluster, cliquez sur le bouton Gérer, puis sur Démarrer et confirmer.

Une notification par courriel sera envoyée lorsque le service sera activé.

Arrêter un cluster

En haut de la page du cluster, cliquez sur le bouton Gérer, puis sur Stop.

Saisissez un numéro RFC pour le suivi (facultatif). Cliquez sur Soumettre.

Une notification par courrier électronique sera envoyée lorsque le cluster sera arrêté.

Redimensionner les nœuds

En haut de la page du cluster, cliquez sur le bouton Gérer, puis sur Redimensionner.

Sélectionnez les nœuds que vous souhaitez redimensionner et sélectionnez la nouvelle taille (cpu/ram).

Une notification par courriel sera envoyée lorsque tous les nœuds auront été redimensionnés.

Supprimer un cluster

En haut de la page du cluster, cliquez sur le bouton Gérer, puis sur Supprimer. Cette action arrêtera et supprimera toutes les machines virtuelles.

Saisissez un numéro RFC pour le suivi (facultatif), puis cliquez sur Soumettre.

Une notification par courriel sera envoyée lorsque le cluster sera supprimé.

Gérer un cluster

Interface utilisateur de gestion

Une fois que votre déploiement est prêt, vous pouvez accéder à l'interface utilisateur de gestion de votre déploiement à partir d'ITCare.

Ce lien est disponible dans le panneau "Configuration" de votre déploiement.

API HTTP

RabbitMQ peut également être géré via une API.

Une fois que vous avez obtenu le lien vers votre interface de gestion, l'API est disponible en ajoutant simplement /api à la fin de l'URL.

Pour obtenir plus d'informations sur l'utilisation de l'API, veuillez consulter la documentation ci-dessous.

Comment produire des messages en Python ?

Cette section fournit des exemples de code Python pour produire des messages vers une queue simple ou une queue de quorum.

Bien sûr, vous pouvez utiliser le langage de développement de votre choix ou n'importe quel middleware qui supporte AMQP.

En outre, si AMQPS est activé (TLS/SSL), une configuration supplémentaire est nécessaire. Il y a aussi un exemple pour cela.

File d'attente simple

#!/usr/bin/python3
import pika
 
credentials = pika.PlainCredentials('user','password')
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='hostname', credentials=credentials))
channel = connection.channel()
 
channel.queue_declare(queue='simple-queue')
 
channel.basic_publish(exchange="", routing_key='simple-queue', body='Hello World!')
print(" [x] Sent 'Hello World!'")
 
connection.close()

File d'attente Quorum

#!/usr/bin/python3
import pika
 
credentials = pika.PlainCredentials('user','password')
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='hostname', credentials=credentials))
channel = connection.channel()
 
channel.queue_declare(queue="quorum-queue",durable=True,arguments={"x-queue-type": "quorum"})
 
channel.basic_publish(exchange="", routing_key='quorum-queue', body='Hello World!')
print(" [x] Sent 'Hello World!'")
 
connection.close()

AMQPS

Lorsque TLS/SSL est activé pour AMQP procotol, le certificat doit être géré soit en le déclarant, soit en l'ajoutant à votre magasin de certificats.

#!/usr/bin/python3
import pika
import ssl
 
logging.basicConfig(level=logging.INFO)
context = ssl.create_default_context(cafile="/path/to/certificate/my-certificate.pem")
ssl_options = pika.SSLOptions(context, "hostname")
credentials = pika.PlainCredentials('user','password')
conn_params = pika.ConnectionParameters(host='hostname', port=5671, ssl_options=ssl_options, credentials=credentials)
 
with pika.BlockingConnection(conn_params) as conn:
    ch = conn.channel()
    ch.queue_declare(queue="quorum-queue",durable=True,arguments={"x-queue-type": "quorum"})
    ch.basic_publish(exchange="", routing_key='quorum-queue', body='Hello World!')
    print(" [x] Sent 'Hello World!'")
 
connection.close()

Comment consommer des messages en Python ?

Cette section fournit des exemples de code Python pour consommer des messages.

#!/usr/bin/python3
import pika, sys, os
 
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
 
def main():
    credentials = pika.PlainCredentials('user','password')
    connection = pika.BlockingConnection(pika.ConnectionParameters(host='hostname', credentials=credentials))
 
    channel = connection.channel()
 
    # Simple queue
    # channel.queue_declare(queue='hello')
    # channel.basic_consume(queue="hello", on_message_callback=callback, auto_ack=True)
 
    # Quorum queue
    channel.queue_declare(queue="quorum-queue",durable=True,arguments={"x-queue-type": "quorum"})
    channel.basic_consume(queue="quorum-queue", on_message_callback=callback, auto_ack=True)
 
    print(' [*] Waiting for messages. To exit press CTRL+C')
    channel.start_consuming()
 
if __name__ == '__main__':
    try:
        main()
    except KeyboardInterrupt:
        print('Interrupted')
        try:
            sys.exit(0)
        except SystemExit:
            os._exit(0)

Topologies

Instance autonome

RabbitMQ peut être provisionné en tant qu'instance autonome en libre-service en utilisant ITCare.

Propriétés

Une fois déployée, l'instance unique aura les propriétés suivantes :

Cluster

RabbitMQ peut être provisionné en tant que cluster en libre-service en utilisant ITCare.

Un cluster RabbitMQ peut être déployé selon une topologie à 3 ou 5 nœuds, adaptée à l'utilisation des quorums.

Les nœuds seront répartis sur toutes les zones de disponibilité disponibles dans la zone ciblée.

Quorum Queues

Les files d'attente quorum sont fortement recommandées avec les clusters RabbitMQ émis à partir du PaaS Cegedim.cloud pour une résilience maximale !

Une file d'attente de quorum sera nativement répliquée sur tous les nœuds participant au cluster.

Caractéristiques

Cette section énumère les fonctionnalités disponibles pour le client, ainsi que la manière de les demander ou de les exécuter :

Sécurité

Authentification

L'authentification utilise la base de données interne de RabbitMQ.

Autorisation et mots de passe

Cette section énumère la gestion des mots de passe pour le PaaS RabbitMQ :

Transport sécurisé

TLS/SSL peut être activé pour le protocole AMQP lors du provisionnement ou par la suite.

Par défaut, il est désactivé pour éviter toute surcharge inutile.

Politiques

Cette section énumère la gestion des politiques pour le PaaS RabbitMQ :

Emplacement des données

Les données pour le PaaS RabbitMQ de cegedim.cloud sont stockées sur des machines virtuelles dédiées créées lors de la demande.

Ces machines virtuelles et le stockage associé sont hébergés et gérés dans les centres de données de cegedim.cloud.

Description

RabbitMQ est un courtier de messages open source léger et populaire.

Il prend en charge plusieurs protocoles de messagerie et peut être déployé dans des configurations distribuées pour répondre aux exigences à grande échelle et de disponibilité.

RabbitMQ fournit un large éventail d'outils de développement pour les langages les plus courants.

Plateforme en tant que Service

RabbitMQ est déployé sur site dans les centres de données de cegedim.cloud.

cegedim.cloud garantit le même niveau de service que l'offre Compute : déploiement des instances, maintien en condition opérationnelle, flexibilité, sécurité, monitoring sont ainsi assurés par nos experts.

Deux topologies sont disponibles :

• Instance autonome

• Cluster

La topologie Cluster est prête pour la production avec au moins 3 nœuds (jusqu'à 5) répartis sur toutes les Zones de Disponibilité d'une région cible.

Le protocole pris en charge par défaut est AMQP (d'autres protocoles peuvent être activés sur demande). Le TLS/SSL peut être activé pour le protocole AMQP lors de l'approvisionnement ou ultérieurement sur demande.

Le dimensionnement peut être configuré en fonction de vos besoins.

Facturation

L'estimation des coûts pour un nœud RabbitMQ est disponible via votre Service Delivery Manager.

La facturation est basée sur le nombre de nœuds auxquels s'ajoutent les frais supplémentaires de stockage, de sauvegarde, surveillance 24/7.