Mise en route : création et connexion à un courtier RabbitMQ

1. Connectez-vous à la console Amazon MQ.

2. Dans la page Select broker engine (Sélectionner le moteur de l'agent), choisissez RabbitMQ, puis choisissez Next (Suivant).

3. Dans la page Select deployment mode (Sélectionner le mode de déploiement), choisissez le mode de déploiement, par exemple, Cluster deployment (Déploiement en cluster), puis choisissez Next (Suivant).

   • Un broker à instance unique est composé d'un courtier dans une zone de disponibilité derrière un Network Load Balancer NLB (). Le broker communique avec votre application et avec un volume EBS de stockage Amazon. Pour de plus amples informations, veuillez consulter Option 1 : courtier à instance unique Amazon MQ pour RabbitMQ.

   • Un déploiement en cluster RabbitMQ pour une haute disponibilité est un regroupement logique de trois nœuds d'agent RabbitMQ derrière d'un Network Load Balancer, chacun partageant des utilisateurs, des files d'attente et un état distribué sur plusieurs zones de disponibilité (AZ). Pour de plus amples informations, veuillez consulter Option 2 : déploiement du cluster Amazon MQ pour RabbitMQ.

4. Sur la page Configure settings (Configurer les paramètres), dans la section Details (Détails), effectuez ce qui suit :

   1. Saisissez le nom de l'agent.

      Important

      N'ajoutez pas d'informations personnellement identifiables (PII) ou d'autres informations confidentielles ou sensibles dans les noms des courtiers. Les noms des courtiers sont accessibles à d'autres AWS services, notamment CloudWatch aux journaux. Les noms d'agents ne sont pas destinées à être utilisées pour des données privées ou sensibles.

   2. Cliquez sur Broker instance type (Type d'instance de l'agent) (par exemple, mq.m5.large). Pour de plus amples informations, veuillez consulter Broker instance types.

   Note

   La section Paramètres supplémentaires propose des options permettant d'activer CloudWatch les journaux et de configurer l'accès au réseau pour votre courtier. Si vous créez un courtier RabbitMQ privé sans accès public, vous devez sélectionner un cloud privé virtuel (VPC) et configurer un groupe de sécurité pour accéder à votre courtier.

5. Dans la page Configure settings (Configuration des paramètres), dans la section RabbitMQ access (Accès à RabbitMQ), renseignez les champs Username (Nom d'utilisateur) et Password (Mot de passe). Les restrictions suivantes s'appliquent aux informations d’identification de connexion des agents :

   • Votre nom d'utilisateur peut contenir uniquement des caractères alphanumériques, des tirets, des points et des traits de soulignement (- . _). Cette valeur ne doit pas contenir de caractères tilde (~). Amazon MQ interdit l'utilisation de guest comme nom d'utilisateur.

   • Votre mot de passe doit comporter 12 caractères minimum, dont au moins 4 caractères uniques, et ne doit pas contenir de virgules, de deux-points ou de signes égal (,:=).

   Important

   N'ajoutez pas d'informations personnellement identifiables (PII) ou d'autres informations confidentielles ou sensibles dans les noms d'utilisateur des courtiers. Les noms d'utilisateur des courtiers sont accessibles à d'autres AWS services, notamment aux CloudWatch journaux. Les noms d'utilisateur des agents ne sont pas destinées à être utilisées pour des données privées ou sensibles.

6. Choisissez Suivant.

7. Dans la page Review and create (Vérifier et créer), vous pouvez vérifier vos sélections et les modifier si nécessaire.

8. Choisissez Create broker (Créer un agent).

   Alors qu'Amazon MQ crée votre agent, il affiche l'état Creation in progress (Création en cours).

   La création d'un agent prend environ 15 minutes.

   Lorsque votre agent est créé avec succès, Amazon MQ affiche l'état Running (En cours d'exécution).

9. Choisissez MyBroker.

   Dans la page MyBrokerpage, dans la section Connect, notez la console Web RabbitMQ de votre courtierURL, par exemple :

   https://b-c8349341-ec91-4a78-ad9c-a57f23f235bb.mq.us-west-2.amazonaws.com

   Notez également le point de AMQPterminaison sécurisé de votre courtier. Voici un exemple de amqpspoint de terminaison exposant un port d'écouteur 5671.

   amqps://b-c8349341-ec91-4a78-ad9c-a57f23f235bb.mq.us-west-2.amazonaws.com:5671

1. Connectez-vous à la console Amazon MQ.

2. Dans la liste des courtiers, choisissez le nom de votre courtier (par exemple, MyBroker).

3. Dans la page MyBrokerpage, dans la section Connexions, notez les adresses et les ports de la console Web du courtier URL et des protocoles au niveau du fil.

4. Dans la section Details (Détails), sous Security and network (Sécurité et réseau), choisissez le nom de votre groupe de sécurité ou .

   La page Groupes de sécurité du EC2 tableau de bord s'affiche.

5. Dans la liste des groupes de sécurité, choisissez votre groupe de sécurité.

6. Au bas de la page, choisissez Entrant, puis Modifier.

7. Dans la boîte de dialogue Modifier les règles entrantes, ajoutez une règle pour chaque URL point de terminaison que vous souhaitez rendre accessible au public (l'exemple suivant montre comment procéder pour une console Web de courtier).

   1. Choisissez Add Rule (Ajouter une règle).

   2. Pour Type, sélectionnez Personnalisé TCP.

   3. Pour Source, laissez l'option Custom (Personnalisée) sélectionnée, puis tapez l'adresse IP du système qui doit pouvoir accéder à la console web (par exemple, 192.0.2.1).

   4. Choisissez Save (Enregistrer).

      Votre agent peut désormais accepter les connexions entrantes.

Pour connecter votre agent à une fonction Lambda

1. Ajoutez les autorisations de IAM rôle suivantes à votre rôle d'exécution de fonction Lambda.

   • mq : DescribeBroker

   • EC2 : CreateNetworkInterface

   • EC2 : DeleteNetworkInterface

   • EC2 : DescribeNetworkInterfaces

   • EC2 : DescribeSecurityGroups

   • EC2 : DescribeSubnets

   • EC2 : DescribeVpcs

   • journaux : CreateLogGroup

   • journaux : CreateLogStream

   • journaux : PutLogEvents

   • responsable des secrets : GetSecretValue

   Note

   Sans les IAM autorisations nécessaires, votre fonction ne pourra pas lire correctement les enregistrements des ressources Amazon MQ.

2. (Facultatif) Si vous avez créé un agent sans accès public, vous devez effectuer l'une des opérations suivantes pour permettre à Lambda de se connecter à votre agent :

   • Configurez une NAT passerelle par sous-réseau public. Pour plus d'informations, consultez la section Accès à Internet et aux services pour les fonctions VPC connectées dans le Guide du AWS Lambda développeur.

   • Créez une connexion entre votre Amazon Virtual Private Cloud (AmazonVPC) et Lambda à l'aide d'un VPC point de terminaison. Votre Amazon VPC doit également se connecter à AWS Security Token Service (AWS STS) et aux points de terminaison Secrets Manager. Pour plus d'informations, consultez la section Configuration des VPC points de terminaison d'interface pour Lambda dans AWS Lambda le Guide du développeur.

3. Configurez votre agent en tant que source d'événement pour une fonction Lambda à l'aide de la AWS Management Console. Vous pouvez également utiliser la create-event-source-mapping AWS Command Line Interface commande.

4. Écrivez du code pour votre fonction Lambda pour traiter les messages de votre consommateur à partir de votre agent. La charge utile Lambda récupérée par votre mappage de source d'événement dépend du type de moteur de l'agent. Voici un exemple de charge utile Lambda pour une file d'attente Amazon MQ for RabbitMQ.

   Note

   Dans l'exemple, test est le nom de la file d'attente et / est le nom de l'hôte virtuel par défaut. Lors de la réception de messages, la source d'événement répertorie les messages sous test::/.

   {
     "eventSource": "aws:rmq",
     "eventSourceArn": "arn:aws:mq:us-west-2:112556298976:broker:test:b-9bcfa592-423a-4942-879d-eb284b418fc8",
     "rmqMessagesByQueue": {
       "test::/": [
         {
           "basicProperties": {
             "contentType": "text/plain",
             "contentEncoding": null,
             "headers": {
               "header1": {
                 "bytes": [
                   118,
                   97,
                   108,
                   117,
                   101,
                   49
                 ]
               },
               "header2": {
                 "bytes": [
                   118,
                   97,
                   108,
                   117,
                   101,
                   50
                 ]
               },
               "numberInHeader": 10
             }
             "deliveryMode": 1,
             "priority": 34,
             "correlationId": null,
             "replyTo": null,
             "expiration": "60000",
             "messageId": null,
             "timestamp": "Jan 1, 1970, 12:33:41 AM",
             "type": null,
             "userId": "AIDACKCEVSQ6C2EXAMPLE",
             "appId": null,
             "clusterId": null,
             "bodySize": 80
           },
           "redelivered": false,
           "data": "eyJ0aW1lb3V0IjowLCJkYXRhIjoiQ1pybWYwR3c4T3Y0YnFMUXhENEUifQ=="
         }
       ]
     }
   }