[PYTHON] Créons une fonction de chat avec Vue.js + AWS Lambda + dynamo DB [Paramètres AWS]

import boto3
import json
from boto3.dynamodb.conditions import Key, Attr
from datetime import datetime, timedelta, timezone


#définition de table
dynamodb_client = boto3.client('dynamodb')
dynamodb = boto3.resource('dynamodb')
connections = dynamodb.Table('connections')
messages = dynamodb.Table('messages')

#Paramètres de TimeZone
JST = timezone(timedelta(hours=+9), 'JST')

def lambda_handler(event, context):

    #Définir les informations de paramètre sur variable
    body = json.loads(event["body"])
    user_id = body['user_id']
    connection_id = event.get('requestContext',{}).get('connectionId')
    domain_name = event.get('requestContext',{}).get('domainName')
    stage       = event.get('requestContext',{}).get('stage')

    #Vérifiez si l'ID de connexion correspond
    connection_items = connections.query(
        ProjectionExpression="connection_id",
        KeyConditionExpression=Key("connection_id").eq(connection_id),
        FilterExpression=Key('user_id').eq(str(user_id)),
    ).get('Items')

    if len(connection_items) == 0:
        return { 'statusCode': 500,'body': 'something went wrong' }
    
    #Paramètres d'ApiGatewayManagementApi
    apigw_management = boto3.client('apigatewaymanagementapi',
                                    endpoint_url=F"https://{domain_name}/{stage}")
    
    #Date et heure d'acquisition
    now = "{0:%Y-%m-%d %H:%M:%S}".format(datetime.now(JST))

    #Obtenir des informations sur le message
    get_message_items = messages.query(
        KeyConditionExpression=Key("user_id").eq(str(user_id)) & Key("created_at").lte(now),
        ScanIndexForward=True
    ).get('Items')

    #Définir le message s'il y a un message, le tableau vide sinon
    content_all = [] if len(get_message_items) == 0 else get_message_items

    #POSTER un message à la connexion
    _ = apigw_management.post_to_connection(
        ConnectionId=connection_id,
        Data=json.dumps(content_all)
    )
    
    return {
        'statusCode': 200,
        'body': 'ok'
    }

Lier la clé racine et Lambda

Nous lierons le Lambda créé à la clé racine d'API Gateway.

Déployer l'API WebSocket créée

Une fois la clé racine liée, nous déploierons l'API WebSocket. Cette fois, le nom de la scène est créé avec Test.

Lorsque le déploiement est terminé, l'URL WebSocket et l'URL de connexion seront émises. Il s'agit de l'URL requise pour la communication avec la réception.

Cela termine les paramètres du côté AWS, et enfin nous ne vérifierons que l'opération.

Fonctionnement confirmé de l'API WebSocket avec wscat

Installez wscat

$ npm install -g wscat

Utilisez wscat pour vérifier l'opération et confirmer que les données sont enregistrées dans dynamoDB.

$ wscat -c [WebSocket URL]?userId=A

Connected (press CTRL+C to quit)
> {"action":"sendmessage","user_id": "A", "message": "Test"}
[{"message": "Test", "user_id": "A", "created_at": "2020-08-29 17:22:43"}]

> {"action":"getmessages", "user_id": "A"}
[{"message": "Test", "user_id": "A", "created_at": "2020-08-29 17:22:43"}]

Cliquez ici pour le statut de dynamoDB!

Résumé

J'ai essayé de créer des paramètres AWS pour la fonction de chat avec Vue.js + AWS Lambda + dynamo DB. Cette fois, je l'ai principalement créé pour fonctionner, donc je pense qu'il n'y a pas beaucoup de traitement en cas d'erreur, et il y a beaucoup d'autres choses à penser afin de l'implémenter réellement.

Ensuite, nous allons créer un écran avant en utilisant Vue.js et communiquer avec l'API.

• La date et l'heure de publication sont indécises

Si vous avez des suggestions, veuillez commenter!