Créez des fonctions Lambda à utiliser avec la messagerie Amazon Pinpoint SMS

Ouvrez la AWS Lambda console à l'adresse https://console.aws.amazon.com/lambda/.

Sélectionnez Create function (Créer une fonction).

Sous Créer une fonction, choisissez Utiliser un plan.

Dans le champ de recherche, entrez hello, puis appuyez sur Entrée. Dans la liste des résultats, choisissez la fonction Node.js hello-world, comme illustré dans l'image suivante.

Sous Basic information (Informations de base), procédez comme suit :

Lorsque vous avez terminé, choisissez Create function (Créer une fonction).

Pour Code source, supprimez l'exemple de fonction dans l'éditeur de code, puis collez le code suivant :

import { PinpointClient, PhoneNumberValidateCommand, UpdateEndpointCommand, SendMessagesCommand } from "@aws-sdk/client-pinpoint"; // ES Modules import
const pinClient = new PinpointClient({region: process.env.region});  

// Make sure the SMS channel is enabled for the projectId that you specify.
// See: https://docs.aws.amazon.com/pinpoint/latest/userguide/channels-sms-setup.html
var projectId = process.env.projectId;

// You need a dedicated long code in order to use two-way SMS. 
// See: https://docs.aws.amazon.com/pinpoint/latest/userguide/channels-voice-manage.html#channels-voice-manage-request-phone-numbers
var originationNumber = process.env.originationNumber;

// This message is spread across multiple lines for improved readability.
var message = "ExampleCorp: Reply YES to confirm your subscription. 2 msgs per "
            + "month. No purchase req'd. Msg&data rates may apply. Terms: "
            + "example.com/terms-sms";
            
var messageType = "TRANSACTIONAL";

export const handler = async (event, context) => {
  console.log('Received event:', event);
  await validateNumber(event);
};

async function validateNumber (event) {
  var destinationNumber = event.destinationNumber;
  if (destinationNumber.length == 10) {
    destinationNumber = "+1" + destinationNumber;
  }
  var params = {
    NumberValidateRequest: {
      IsoCountryCode: 'US',
      PhoneNumber: destinationNumber
    }
  };
  try{
    const PhoneNumberValidateresponse = await pinClient.send( new  PhoneNumberValidateCommand(params));
    console.log(PhoneNumberValidateresponse);
     if (PhoneNumberValidateresponse['NumberValidateResponse']['PhoneTypeCode'] == 0) {
        await createEndpoint(PhoneNumberValidateresponse, event.firstName, event.lastName, event.source);
        
      } else {
        console.log("Received a phone number that isn't capable of receiving "
                   +"SMS messages. No endpoint created.");
      }
  }catch(err){
    console.log(err);
  }
}

async function createEndpoint(data, firstName, lastName, source) {
  var destinationNumber = data['NumberValidateResponse']['CleansedPhoneNumberE164'];
  var endpointId = data['NumberValidateResponse']['CleansedPhoneNumberE164'].substring(1);
  
  var params = {
    ApplicationId: projectId,
    // The Endpoint ID is equal to the cleansed phone number minus the leading
    // plus sign. This makes it easier to easily update the endpoint later.
    EndpointId: endpointId,
    EndpointRequest: {
      ChannelType: 'SMS',
      Address: destinationNumber,
      // OptOut is set to ALL (that is, endpoint is opted out of all messages)
      // because the recipient hasn't confirmed their subscription at this
      // point. When they confirm, a different Lambda function changes this 
      // value to NONE (not opted out).
      OptOut: 'ALL',
      Location: {
        PostalCode:data['NumberValidateResponse']['ZipCode'],
        City:data['NumberValidateResponse']['City'],
        Country:data['NumberValidateResponse']['CountryCodeIso2'],
      },
      Demographic: {
        Timezone:data['NumberValidateResponse']['Timezone']
      },
      Attributes: {
        Source: [
          source
        ]
      },
      User: {
        UserAttributes: {
          FirstName: [
            firstName
          ],
          LastName: [
            lastName
          ]
        }
      }
    }
  };
  try{
    const UpdateEndpointresponse = await pinClient.send(new UpdateEndpointCommand(params));
    console.log(UpdateEndpointresponse);
    await sendConfirmation(destinationNumber);
  }catch(err){
    console.log(err);
  }  
}

async function sendConfirmation(destinationNumber) {
  var params = {
    ApplicationId: projectId,
    MessageRequest: {
      Addresses: {
        [destinationNumber]: {
          ChannelType: 'SMS'
        }
      },
      MessageConfiguration: {
        SMSMessage: {
          Body: message,
          MessageType: messageType,
          OriginationNumber: originationNumber
        }
      }
    }
  };
  try{
    const SendMessagesCommandresponse = await pinClient.send(new SendMessagesCommand(params));
    console.log("Message sent! " 
          + SendMessagesCommandresponse['MessageResponse']['Result'][destinationNumber]['StatusMessage']);
  }catch(err){
    console.log(err);
  }
}

Dans l'onglet Configuration des variables d'environnement, choisissez Modifier puis Ajouter une variable d'environnement, procédez comme suit :

Lorsque vous avez terminé, la section Environment Variables (Variables d' environnement) doit ressembler à l'exemple illustré dans l'image suivante.

Dans le haut de la page, choisissez Enregistrer.

Choisissez l’onglet Test.

Choisissez Créer un nouvel événement, procédez comme suit :

Sélectionnez Test.

Sous Execution result : succeeded (Résultat de l'exécution : succès), choisissez Details (Détails). Dans la section Log output (Sortie de journal), vérifiez le résultat de la fonction. Assurez-vous que la fonction s'est exécutée sans erreurs.

Vérifiez le périphérique associé au destinationNumber que vous avez spécifié pour vous assurer qu'il a reçu le message de test.

Ouvrez la console Amazon Pinpoint à l'adresse. https://console.aws.amazon.com/pinpoint/

Sur la page Tous les projets, choisissez le projet que vous avez créé dans Créer un projet Amazon Pinpoint.

Dans le volet de navigation, sélectionnez Segments. Sur la page Segments, choisissez Create a segment (Créer un segment).

Dans le groupe Segment group 1 (1er groupe de segments), sous Add filters to refine your segment (Ajouter des filtres pour affiner votre segment), choisissez Filter by user (Filtrer par utilisateur).

Pour Choisir un attribut utilisateur, sélectionnez FirstName. Ensuite, pour Choose values (Choisir des valeurs), choisissez le premier nom que vous avez spécifié dans l'événement de test.

La section Segment estimate (Estimation du segment) doit montrer qu'il n'existe aucun point de terminaison éligible et un point de terminaison global, comme illustré dans l'image suivante. Ce résultat est prévu. Lorsque la fonction crée un nouveau point de terminaison, le point de terminaison est désinscrit. Les segments dans Amazon Pinpoint excluent automatiquement les points de terminaison désabonnés.

Ouvrez la AWS Lambda console à l'adresse https://console.aws.amazon.com/lambda/.

Sélectionnez Create function (Créer une fonction).

Sous Create a function (Créer une fonction), choisissez Blueprints (Plans).

Dans le champ de recherche, entrez hello, puis appuyez sur Entrée. Dans la liste des résultats, choisissez la fonction Node.js hello-world, comme illustré dans l'image suivante. Choisissez Configurer.

Sous Basic information (Informations de base), procédez comme suit :

Lorsque vous avez terminé, choisissez Create function (Créer une fonction).

Supprimez l'exemple de fonction dans l'éditeur de code, puis collez le code suivant :

import { PinpointClient, UpdateEndpointCommand } from "@aws-sdk/client-pinpoint"; // ES Modules import

// Create a new Pinpoint client instance with the region specified in the environment variables
const pinClient = new PinpointClient({ region: process.env.region });

// Get the Pinpoint project ID and the confirm keyword from environment variables
const projectId = process.env.projectId;
const confirmKeyword = process.env.confirmKeyword.toLowerCase();

// This is the main handler function that is invoked when the Lambda function is triggered
export const handler = async (event, context) => {
    console.log('Received event:', event);

    try {
        // Extract the timestamp, message, and origination number from the SNS event
        const timestamp = event.Records[0].Sns.Timestamp;
        const message = JSON.parse(event.Records[0].Sns.Message);
        const originationNumber = message.originationNumber;
        const response = message.messageBody.toLowerCase();

        // Check if the response message contains the confirm keyword
        if (response.includes(confirmKeyword)) {
            // If the confirm keyword is found, update the endpoint's opt-in status
            await updateEndpointOptIn(originationNumber, timestamp);
        }
    }catch (error) {
        console.error('An error occurred:', error);
        throw error; // Rethrow the error to handle it upstream
    }
};

// This function updates the opt-in status of a Pinpoint endpoint
async function updateEndpointOptIn(originationNumber, timestamp) {
    // Extract the endpoint ID from the origination number
    const endpointId = originationNumber.substring(1);

     // Prepare the parameters for the UpdateEndpointCommand
    const params = {
        ApplicationId: projectId,
        EndpointId: endpointId,
        EndpointRequest: {
            Address: originationNumber,
            ChannelType: 'SMS',
            OptOut: 'NONE',
            Attributes: {
                OptInTimestamp: [timestamp]
            },
        }
    };

    try {
        // Send the UpdateEndpointCommand to update the endpoint's opt-in status
        const updateEndpointResponse = await pinClient.send(new UpdateEndpointCommand(params));
        console.log(updateEndpointResponse);
        console.log(`Successfully changed the opt status of endpoint ID ${endpointId}`);
    } catch (error) {
        console.error('An error occurred while updating endpoint:', error);
        throw error; // Rethrow the error to handle it upstream
    }
}

Sous Environment variables (Variables d'environnement), effectuez les opérations suivantes :

Lorsque vous avez terminé, la section Environment Variables (Variables d' environnement) doit ressembler à l'exemple illustré dans l'image suivante.

Dans le haut de la page, choisissez Enregistrer.

Sélectionnez Tester).

Sur la fenêtre Configure test event (Configurer un événement de test), procédez de la façon suivante :

1. Choisissez Create new test event.

2. Pour Event name (Nom d'événement), saisissez un nom pour l'événement de test, tel que MyResponse.

3. Effacez l'exemple de code dans l'éditeur de code. Collez le code suivant :

   {
     "Records":[
       {
         "Sns":{
           "Message":"{\"originationNumber\":\"+12065550142\",\"messageBody\":\"Yes\"}",
           "Timestamp":"2019-02-20T17:47:44.147Z"
         }
       }
     ]
   }
   

   Dans l'exemple de code précédent, remplacez les valeurs de l'attribut originationNumber par le numéro de téléphone que vous avez utilisé lorsque vous avez testé la fonction Lambda précédente. Remplacez la valeur de messageBody par le SMS mot clé bidirectionnel que vous avez spécifié dans Activer le mode bidirectionnel SMS. Le cas échéant, vous pouvez remplacer la valeur Timestamp par la date et l'heure actuelles.

4. Sélectionnez Create (Créer).

Choisissez Test à nouveau.

Sous Execution result : succeeded (Résultat de l'exécution : succès), choisissez Details (Détails). Dans la section Log output (Sortie de journal), vérifiez le résultat de la fonction. Assurez-vous que la fonction s'est exécutée sans erreurs.

Ouvrez la console Amazon Pinpoint à l'adresse. https://console.aws.amazon.com/pinpoint/

Sur la page Tous les projets, choisissez le projet que vous avez créé dans Créer un projet Amazon Pinpoint.

Dans le volet de navigation, sélectionnez Segments. Sur la page Segments, choisissez Create a segment (Créer un segment).

Dans le groupe Segment group 1 (1er groupe de segments), sous Add filters to refine your segment (Ajouter des filtres pour affiner votre segment), choisissez Filter by user (Filtrer par utilisateur).

Pour Choisir un attribut utilisateur, sélectionnez FirstName. Ensuite, pour Choose values (Choisir des valeurs), choisissez le premier nom que vous avez spécifié dans l'événement de test.

La section Segment estimate (Estimation du segment) doit montrer qu'il existe un point de terminaison éligible et un point de terminaison global.