InMy.Live

🔰 Débutants qui découvrent AWS CDK, veuillez consulter mes articles précédents un par un dans cette série.

Si au cas où vous auriez manqué mon article précédent, retrouvez-le avec les liens ci-dessous.

🔁 Message précédent original sur 🔗 Dev Post

🔁 Republié le post précédent à 🔗 dev à @aravindvcyber

Dans cet article, refactorisons l’une de nos fonctions lambda précédentes qui crée un événement directement avec le message complet reçu en ajoutant une configuration pour enregistrer le message réel reçu en premier dans s3 avant de créer un événement.

Avantages de l’utilisation des couches lambda 🚿

Ce ne sont pas les seuls avantages, c’est juste ce que je viens d’observer dans mes déploiements.

• L’utilisation de couches lambda nous aide à déployer plus rapidement car la même couche peut être attachée à plusieurs fonctions.

• En plus de cela, nous pouvons également inclure nos modules personnalisés dans les couches lambda et les partager entre plusieurs fonctions.

• Cela permet également de patcher simplement ces modules sans redéployer toutes les fonctions.

Projet de construction 🏗

Comme nous l’avons mentionné précédemment, nous essayons également d’enregistrer un JSON dans s3, ce qui créera à l’intérieur de notre pile. Pour enregistrer n’importe quel objet dans s3, nous avons besoin de deux choses comme suit.

• Un nom de compartiment pour enregistrer notre message
• Une clé/identifiant d’objet pour le référer à un emplacement spécifique.

Création de bucket S3 💊

Commençons par créer un compartiment S3, en ajoutant les lignes ci-dessous dans notre pile de courrier lib/common-event-stack.ts.

const stgMsgBucket = new s3.Bucket(this, 'stg-msg-bucket',{
      bucketName: 'stg-msg-bucket',
      encryption: s3.BucketEncryption.S3_MANAGED,
      removalPolicy: RemovalPolicy.RETAIN
});

Vous constaterez peut-être que nous avons nommé notre seau unique avec le nom stg-msg-bucket avec la stratégie de chiffrement gérée par S3, comme indiqué ci-dessus.

Octroi de la fonction put Object to handler 🔑

stgMsgBucket.grantWrite(eventCounterBus.handler);

Changements à l’intérieur de notre fonction lambda ✂️

Dans notre lambda, ajoutons les importations ci-dessous comme suit.

import { S3 } from "aws-sdk";
import { PutObjectOutput } from "aws-sdk/clients/s3";
const s3 = new S3({ region: "ap-south-1" });

fonction d’assistance putObject 💉

J’ai créé la fonction d’assistance ci-dessous à l’intérieur du lambda pour nous aider à mettre un objet dans S3.

const save = async (uploadParams: S3.PutObjectRequest) => {
  let putResult: PromiseResult<PutObjectOutput, AWSError> | undefined =
    undefined;
  try {
    putResult = await s3.putObject(uploadParams).promise();
  } catch (e) {
    console.log(e);
  } finally {
    console.log(putResult);
    return putResult;
  }
};

Génération de l’objet uploadParams 🔆

À l’intérieur de notre lambda, ajoutons les instructions ci-dessous à l’intérieur de l’instruction try avant de publier le msg objet dans le nouveau pont d’événement mettre l’événement.

const uploadParams: S3.PutObjectRequest = {
      Bucket: message.bucket,
      Key: message.key,
      Body: JSON.stringify(message),
      ContentType: "application/json",
};

Appel de la fonction d’aide à la sauvegarde 🔱

const putResult: PromiseResult<PutObjectOutput, AWSError> | undefined =
      await save(uploadParams);

Ajout du résultat putObject à notre message 👓

message.putStatus = putResult;
const msg: string = JSON.stringify({ message });

Propriétés supplémentaires pour saisir le message 🔧

Dans ce bloc de code ci-dessus, nous avons utilisé le nom du compartiment et la clé du compartiment, voyons comment nous définissons ces propriétés ci-dessous.

message.key = `uploads/${message.uuid}.json`;
message.bucket = process.env.BucketName || "";

Génération Uuid 🔥

Ici, vous remarquerez peut-être que nous avons une propriété UUID attachée au message d’entrée. Dans le code ci-dessous, nous allons générer l’UUID.

message.uuid = getUuid();

Ce getUuid vient de la uuid module exporté qui est disponible dans le /opt/uuid chemin.

Importation de la fonction utils à partir du calque ⚙️

const { getUuid } = require("/opt/utils");

Mais comment fait-on pour obtenir le module du /opt/* dossier? Le dossier opt est le chemin extrait provenant des couches lambda car c’est le seul moyen d’obtenir les modules tiers dans la fonction lambda en les important.

Créer une nouvelle couche lambda ☄

Étapes pour créer un nouveau calque.

• Créez un nouveau dossier représentant votre nom de couche layers/utils
• Dans ce dossier créer un nouveau dossier nodejs
• Dans ce sous-dossier, exécutez npm init -y
• Nous allons maintenant obtenir un package * fichiers .json
• Utiliser npm install --save uuidcela installe notre module tiers.
• Créons ensuite un nouveau fichier nommé utils.js et ajoutez les lignes ci-dessous

const {v4:uuidv4} = require('uuid');
exports.getUuid = ()=> {
    return uuidv4();
}

déclaration de création de couche à l’intérieur de la pile ⚖️

Nous devons maintenant ajouter l’instruction ci-dessous dans notre pile principale pour créer un calque comme suit.

const nodejsUtils = new lambda.LayerVersion(this, `nodejsUtils`, {
      removalPolicy: RemovalPolicy.DESTROY,
      code: lambda.Code.fromAsset('layers/utils'),
      compatibleArchitectures: [lambda.Architecture.X86_64],
      compatibleRuntimes: [lambda.Runtime.NODEJS_14_X]
});

Vous pouvez constater que nous avons spécifié le temps d’exécution et les architectures de manière appropriée

Le bloc de code ci-dessus créera le nouveau calque comme indiqué ci-dessous.

Ajout de la couche lambda à lambda ❄️

Ajoutons maintenant la couche lambda ci-dessus dans notre définition de fonction lambda comme suit.

const eventCounterFn = new lambda.Function(this, 'EventCounterHandler', {
     runtime: lambda.Runtime.NODEJS_14_X,
     handler: 'event-counter-bus.counter',
     code: lambda.Code.fromAsset('lambda'),
     environment: {
       DetailType: downstreamBus.props.DetailType,
       EventBusName: downstreamBus.props.EventBusName,
       Source: downstreamBus.props.Source,
       EVENT_COUNTER_TABLE_NAME: Counters.tableName,
       BucketName: bucketName
     },
     logRetention: logs.RetentionDays.ONE_MONTH,
     layers: [nodejsXray,nodejsUtils]
});

Ainsi, nous avons ajouté la couche dans notre fonction lambda, cela aidera à les importer dans nos fonctions.

Nous ajouterons plus de connexions à notre pile et la rendrons plus utilisable dans les prochains articles en créant de nouvelles constructions, alors pensez à suivre et à vous abonner à ma newsletter.

⏭ Nous avons notre prochain article en serverless, consultez

🎉 Merci pour votre soutien ! 🙏

Ce serait formidable si vous aimez ☕ Achetez-moi un café, pour aider à stimuler mes efforts.

🔁 Message original sur 🔗 Dev Post

🔁 Republié à 🔗 dev à @aravindvcyber

🤡 AWS CDK 101 – 🤾‍♂ Utilisation de couches dans les fonctions Lambda et enregistrement de JSON dans S3
@hashnode

Découvrez la collection complètehttps://t.co/CuYxnKr0Ig#TheHashnodeWriteathon

— Aravind V (@Aravind_V7) 8 mai 2022