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

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

Dans cet article, nous allons introduire une couche d’accès aux données en tant que wrapper au-dessus de notre table dynamodb. Ici spécifiquement, nous avons choisi graphql en utilisant AWS appsync pour effectuer des éléments de liste de base et obtenir un élément de dynamodb.

Chantier 🏗

Commençons par créer un nouveau fichier lib/appsync-stack.ts pour notre nouvelle pile.

Imports utilisés dans cette nouvelle pile ⛩

Ici, nous avons importé les objets ci-dessous pour nous aider dans notre définition

import { Duration, Expiration, Stack, StackProps } from 'aws-cdk-lib';
import { Construct } from 'constructs';
import { Table } from 'aws-cdk-lib/aws-dynamodb';
import { GraphqlApi, MappingTemplate, Schema, FieldLogLevel, AuthorizationType } from 'aws-lib-cdk/aws-appsync-alpha';

Construction Appsync avec définition ⛺️

Une nouvelle pile est créée qui est utilisée pour définir notre point de terminaison appsync comme indiqué ci-dessous.

Ici, nous obtiendrons une clé API par défaut avec une expiration de 7 jours afin que nous puissions la faire pivoter périodiquement. En plus de cela, nous avons suffisamment enregistré notre API pour mieux comprendre le processus d’arrière-plan.

export class GqlStack extends Stack {
  constructor(scope: Construct, id: string, props?: StackProps) {
    super(scope, id, props);

    const AppSyncApi = new GraphqlApi(this, 'gqlApi', {
      name: 'gqlApi',
      schema: Schema.fromAsset('assets/messages-schema.gql'),
      xrayEnabled: true,
      logConfig: {
            excludeVerboseContent: false,
            fieldLogLevel: FieldLogLevel.ALL,
      },
      authorizationConfig: {
          defaultAuthorization: {
              authorizationType: AuthorizationType.API_KEY,
              apiKeyConfig: {
                  name: 'default-api-key',
                  description: 'default-api-key-description',
                  expires: Expiration.after(Duration.days(7))
              }
          }
      }
    })

  }
}

Fichier de définition de schéma 🎢

Vous pouvez également utiliser la console AWS pour mettre à jour le schéma avant la mise à jour dans les fichiers d’actifs CDK lorsque nous en sommes sûrs.

type Message {
    message: AWSJSON!
}

type MessagesTable {
    createdAt: AWSTimestamp!
    messageId: String!
    event: Message
}

type MessagesTableConnection {
    items: [MessagesTable]
    nextToken: String
    scannedCount: Int
}

type Query {
    getMessage(messageId: String!, createdAt: AWSTimestamp!): MessagesTable
    listMessages(filter: TableMessagesTableFilterInput, limit: Int, nextToken: String): MessagesTableConnection
}

input TableAWSTimestampFilterInput {
    ne: AWSTimestamp
    eq: AWSTimestamp
    le: AWSTimestamp
    lt: AWSTimestamp
    ge: AWSTimestamp
    gt: AWSTimestamp
    contains: AWSTimestamp
    notContains: AWSTimestamp
    between: [AWSTimestamp]
}

input TableMessagesTableFilterInput {
    createdAt: TableAWSTimestampFilterInput
    messageId: TableStringFilterInput
}

input TableStringFilterInput {
    ne: String
    eq: String
    le: String
    lt: String
    ge: String
    gt: String
    contains: String
    notContains: String
    between: [String]
    beginsWith: String
}

Connexion Dynamodb comme source de données 🛶

Ici, nous intégrons directement l’API dynamodb avec graphql comme source de données

const messages = Table.fromTableName(this,'MessagesTableImport', 'MessagesTable');

const MessagesDS = AppSyncApi.addDynamoDbDataSource("MessagesDataSource", messages);

Modèle de mappage VTL 🛩

Ici, nous devons utiliser VTL (Velocity Template Language) pour transformer/manipuler notre demande et la réponse que nous envoyons/recevons des résolveurs ci-dessous. L’utiliser peut être une bonne stratégie car cela peut être utilisé dans de nombreux endroits, pas seulement dans appsync et la passerelle API.

Vous pouvez également utiliser la console AWS pour tester ces transformations à l’aide de l’exemple de charge utile des journaux avant la mise à jour dans les fichiers d’actifs CDK.

Obtenez le résolveur de message 🚠

Ici, vous pouvez également consulter le traçage aux rayons X pour comprendre quand ces blocs sont utilisés pour getMessage résolveur

MessagesDS.createResolver({
      typeName: 'Query',
      fieldName: 'getMessage',
      requestMappingTemplate: MappingTemplate.fromFile('assets/getMessageRequest.vtl'),
      responseMappingTemplate: MappingTemplate.fromFile('assets/getMessageResponse.vtl'),
})

modèle VTL getMessageRequest 🌟

{
    "version": "2017-02-28",
    "operation": "GetItem",
    "key": {
        "messageId": $util.dynamodb.toDynamoDBJson($ctx.args.messageId),
        "createdAt": $util.dynamodb.toDynamoDBJson($ctx.args.createdAt)
    }
}

Modèle VTL getMessageResponse ⛱

#set($ctx.result.event = $util.parseJson($ctx.result.event))

$util.toJson($ctx.result)

Résolveur de messages de liste 🤡

Ici, vous pouvez également consulter le traçage aux rayons X pour comprendre quand ces blocs sont utilisés pour listMessages résolveur

MessagesDS.createResolver({
        typeName: 'Query',
        fieldName: 'listMessages',
        requestMappingTemplate: MappingTemplate.fromFile('assets/listMessagesRequest.vtl'),
        responseMappingTemplate: MappingTemplate.fromFile('assets/listMessagesResponse.vtl'),
})

modèle listMessagesRequest VTL 🎈

{
  "version": "2017-02-28",
  "operation": "Scan",
  "filter": #if($context.args.filter) $util.transform.toDynamoDBFilterExpression($ctx.args.filter) #else null #end,
  "limit": $util.defaultIfNull($ctx.args.limit, 20),
  "nextToken": $util.toJson($util.defaultIfNullOrEmpty($ctx.args.nextToken, null)),
}

Modèle VTL listMessagesResponse 🎣

#set($children = [])
#foreach($item in $ctx.result.items)
  #set($item.event = $util.parseJson($item.event))
  $util.qr($children.add($item))
#end
#set($ctx.result.items = $children)
$util.toJson($ctx.result)

Client pour explorer graphQl ❄️

Requêtes Appsync Explorer ♨️

Dans la console AWS, vous pouvez naviguer dans l’appsync et commencer à interroger. L’un des avantages que vous avez ici est que nous avons des journaux de surveillance et de suivi du cloud facilement disponibles si vous souhaitez vérifier.

Requêtes Apollo Studio 🏕

Mais préférez normalement le mode sombre dans apollo graphql studio, vous pouvez également l’essayer si vous préférez cela, peut-être que nous obtiendrions cela dans la console AWS également un jour.

Conclusion 💫

Dans cet exercice, nous avons essayé uniquement les opérations get et list pour différencier l’efficacité de l’opération scan et query.

scannedCount La valeur dans les résultats ci-dessus montre le coût associé à l’opération de liste à mesure que la table s’agrandit. J’ai supprimé la variable de filtre pour vous montrer quels sont les enregistrements numérisés, comme indiqué ci-dessous.

Nous affinerons cela dans nos prochains articles pour atteindre une vitesse et une utilisation des ressources optimales.

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 – 🐲 GraphQL utilisant AppSync avec dynamodb
{ par @Aravind_V7 }

Commander plus tel dans ma pagehttps://t.co/CuYxnKr0Ighttps://t.co/phzOKFlXXO#aws #manuscrit #graphql #dynamodb #awscdk https://t.co/yeqeLZQt8A

— Aravind V (@Aravind_V7) 30 mai 2022