Tutorial di ActiveMQ

Connessione del broker a una funzione Lambda

1. Aggiungere le seguenti autorizzazioni del ruolo IAM al ruolo di esecuzione della funzione Lambda.

   • mq: DescribeBroker

   • ec2: CreateNetworkInterface

   • ec2: DeleteNetworkInterface

   • ec2: DescribeNetworkInterfaces

   • ec2: DescribeSecurityGroups

   • ec2: DescribeSubnets

   • ec2: DescribeVpcs

   • registri: CreateLogGroup

   • registri: CreateLogStream

   • registri: PutLogEvents

   • gestore dei segreti: GetSecretValue

   Nota

   Senza le necessarie autorizzazioni IAM, la tua funzione non sarà in grado di leggere correttamente i record dalle risorse di Amazon MQ.

2. (Opzionale) Se hai creato un broker senza accessibilità pubblica, devi effettuare una delle seguenti operazioni per consentire a Lambda di connettersi al broker:

   • Configurare un gateway NAT per sottorete pubblica. Per ulteriori informazioni, consultate l'accesso a Internet e ai servizi per VPC-connected le funzioni nella Guida per gli AWS Lambdasviluppatori.

   • Creare una connessione tra Amazon Virtual Private Cloud (Amazon VPC) e Lambda mediante un endpoint VPC. Il tuo Amazon VPC deve inoltre connettersi agli endpoint Servizio di token di sicurezza AWS (AWS STS) e Secrets Manager. Per ulteriori informazioni, consulta Configuring interface VPC endpoints for Lambda nella AWS LambdaGuida per gli sviluppatori.

3. Configurare il broker come origine dell'evento per una funzione Lambda che utilizza la Console di gestione AWS. Puoi anche usare il comando. create-event-source-mappingAWS Command Line Interface

4. Scrivere un codice per la funzione Lambda per elaborare i messaggi utilizzati dal broker. Il payload Lambda recuperato dalla mappatura dell'origine dell'evento dipende dal tipo di motore del broker. Di seguito è riportato un esempio di payload Lambda per una coda Amazon MQ per ActiveMQ.

   Nota

   Nell'esempio, testQueue corrisponde al nome della coda.

   {
     "eventSource": "aws:amq",
     "eventSourceArn": "arn:aws:mq:us-west-2:112556298976:broker:test:b-9bcfa592-423a-4942-879d-eb284b418fc8",
     "messages": {
       [
         {
           "messageID": "ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1---mq---us-west-2.amazonaws.com.rproxy.govskope.ca-37557-1234520418293-4:1:1:1:1",
           "messageType": "jms/text-message",
           "data": "QUJDOkFBQUE=",
           "connectionId": "myJMSCoID",
           "redelivered": false,
           "destination": {
             "physicalname": "testQueue" 
           }, 
           "timestamp": 1598827811958,
           "brokerInTime": 1598827811958,
           "brokerOutTime": 1598827811959
         },
         {
           "messageID": "ID:b-9bcfa592-423a-4942-879d-eb284b418fc8-1---mq---us-west-2.amazonaws.com.rproxy.govskope.ca-37557-1234520418293-4:1:1:1:1",
           "messageType":"jms/bytes-message",
           "data": "3DTOOW7crj51prgVLQaGQ82S48k=",
           "connectionId": "myJMSCoID1",
           "persistent": false,
           "destination": {
             "physicalname": "testQueue" 
           }, 
           "timestamp": 1598827811958,
           "brokerInTime": 1598827811958,
           "brokerOutTime": 1598827811959
         }
       ]
     }
   }