[PYTHON] Erstellen wir eine Chat-Funktion mit Vue.js + AWS Lambda + Dynamo DB [AWS-Einstellungen]

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


#Tabellendefinition
dynamodb_client = boto3.client('dynamodb')
dynamodb = boto3.resource('dynamodb')
connections = dynamodb.Table('connections')
messages = dynamodb.Table('messages')

#TimeZone-Einstellungen
JST = timezone(timedelta(hours=+9), 'JST')

def lambda_handler(event, context):

    #Setzen Sie die Parameterinformationen auf 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')

    #Überprüfen Sie, ob die Verbindungs-ID übereinstimmt
    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' }
    
    #ApiGatewayManagementApi-Einstellungen
    apigw_management = boto3.client('apigatewaymanagementapi',
                                    endpoint_url=F"https://{domain_name}/{stage}")
    
    #Erfassungsdatum und -zeit
    now = "{0:%Y-%m-%d %H:%M:%S}".format(datetime.now(JST))

    #Nachrichteninformationen abrufen
    get_message_items = messages.query(
        KeyConditionExpression=Key("user_id").eq(str(user_id)) & Key("created_at").lte(now),
        ScanIndexForward=True
    ).get('Items')

    #Nachricht festlegen, wenn eine Nachricht vorhanden ist, leeres Array, wenn nicht
    content_all = [] if len(get_message_items) == 0 else get_message_items

    #POST eine Nachricht an die Verbindung
    _ = apigw_management.post_to_connection(
        ConnectionId=connection_id,
        Data=json.dumps(content_all)
    )
    
    return {
        'statusCode': 200,
        'body': 'ok'
    }

Verknüpfen des Root-Schlüssels und Lambda

Wir werden das erstellte Lambda mit dem Stammschlüssel von API Gateway verknüpfen.

Stellen Sie die erstellte WebSocket-API bereit

Nachdem der Stammschlüssel verknüpft wurde, stellen wir die WebSocket-API bereit. Dieses Mal wird der Künstlername mit "Test" erstellt.

Nach Abschluss der Bereitstellung erhalten Sie eine WebSocket-URL und eine Verbindungs-URL. Dies ist die URL, die für die Kommunikation mit der Rezeption erforderlich ist.

Damit sind die Einstellungen auf der AWS-Seite abgeschlossen, und schließlich werden wir nur den Vorgang überprüfen.

Bestätigter Betrieb der WebSocket-API mit wscat

Installieren Sie wscat

$ npm install -g wscat

Verwenden Sie wscat, um den Vorgang zu überprüfen und zu bestätigen, dass die Daten in dynamoDB gespeichert sind.

$ 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"}]

Klicken Sie hier für den Status von dynamoDB!

Zusammenfassung

Ich habe eine AWS-Einstellung für die Chat-Funktion mit "Vue.js + AWS Lambda + Dynamo DB" erstellt. Dieses Mal habe ich es hauptsächlich für die Arbeit erstellt, daher denke ich, dass im Fehlerfall nicht viel verarbeitet wird und dass viele andere Dinge zu beachten sind, um es tatsächlich zu implementieren.

Als Nächstes erstellen wir mit Vue.js einen Frontbildschirm und kommunizieren mit der API.

• Datum und Uhrzeit der Buchung sind unentschieden

Wenn Sie Vorschläge haben, kommentieren Sie bitte!