POST JSON-Objekt zu aws lambda

Wie kann ich eine json-Objekt zu aws lambda-Funktion über die aws-API-gateway ?

p.s.- Mein Ziel ist es, schreiben die lambda Funktion in python und dann per post an die aws SQS.

Vielen Dank im Voraus.

InformationsquelleAutor Sudip | 2017-05-11

5

Habe ich es herausgefunden. Jetzt habe ich ein API-Gateway acceptiong client geschrieben JSON-Daten von einem angegebenen format und dann übergabe an eine AWS Lambda-Funktion, die dumps die Daten in eine AWS-SQS. Die Schritte sind im folgenden im Detail erläutert-

SCHRITT 1-

Erstellen Sie eine lambda-Funktion in alle unterstützten Sprachen (die ich verwendet habe Python 3.6). Hier ist ein Beispiel-code.
```
import boto3  
import json

def lambda_handler(event, context):

    sqs = boto3.resource('sqs')

    queue = sqs.get_queue_by_name(QueueName='userData')

    response = queue.send_message(MessageBody=json.dumps(event))

    return {
                "status":"0",
                "message":"",
                "pubId":event["ClientID"],
                "routetitle":event["routeTitle"]
            }
```
Hinweis: ich importiert haben, sowohl json und boto3 Bibliothek, die in aws-Kontext keine Notwendigkeit, fügen Sie keine weitere Datei. Auch habe ich keine Angaben für die SQS als der name, weil meine beiden Lambda-Funktion und SQS sind in der gleichen AWS-region. Ich bin dumping das ganze "event" - variable SQS als diese enthält nur die geposteten JSON-Daten.

SCHRITT 2-

Nun in der AWS-Konsole goto "- API Gateway" und erstellen Sie eine neue API-Gateway und erstellen Sie dann eine "POST" action unter Ressourcen.

Bitte überprüfen Sie den screenshot

Nun, unter der post-action, klicken Sie auf "Integration-Anfrage". Jetzt fügen Sie eine Körper-Vorlage, um es, wie im Beispiel unten angegeben-
```
{
  "userMobile" : "$input.params('userMobile')",
  "ClientID" : "$input.params('ClientID')",
  "routeTitle" : "$input.params('routeTitle')"
}
```
Stellen Sie außerdem sicher, dass Sie die "Integration Type" Ihre API als "Lambda" und der Lambda-Funktion die wir erstellt haben in SCHRITT 1 angeschlossen ist, um die API.

Nun sind wir fast fertig. alles was wir jetzt tun müssen ist, erstellen Sie eine Bühne für die API, die wir geschaffen haben, und die Bereitstellung der API. ***

Bitte beachten Sie die HTTP-URL des API nach der Bereitstellung.

SCHRITT 3-

Gehen Sie nun auf die "Simple Queuing Service (SQS)" und dann erstellen Sie eine einfache SQS mit dem halten alle Standard-Parameter. Stellen Sie sicher, dass die queue-Namen passt, mit der Sie zur Verfügung gestellt haben in Ihrer Lambda-Funktion und sowohl Ihre Lambda-Funktion und Ihre SQS sind in der gleichen AWS-region.

Nun können Sie POST JSON-Daten in das gleiche format, um Ihre API und Ihre Lambda-Funktion wird es dump der SQS-Warteschlange, wo man gehen kann und die Daten anzeigen.

Können Sie auch test die API-Verwendung von tools wie der Fidler.

*** stellen Sie sicher, um Sie erneut zu implementieren die API für jedes mal, wenn Sie eine änderung vornehmen, um es.
- Vielen Dank für die ausführliche Antwort! Können Sie Kennzeichnen diese Frage beantwortet mit diesem?
- Hi, @AbhignaNagaraja Dank für Ihre Anerkennung. Ich markierte diese Frage beantwortet mit dies.
- Ich kann nicht sehen, wie Sie verwenden die response Objekt, nachdem Sie es schaffen?
- Hi @CpILL ich habe nicht das response-Objekt, in diesem besonderen Beispiel. Dies ist nur ein Beispiel, um zu zeigen, wie die post-Daten in SQS, indem Sie es als ein JSON-Objekt über AWS-Gateway-API. Aber wenn Sie interessiert sind, können Sie gehen Sie durch diesen Artikel. Aber, wenn Sie erstellen möchten .NET lambda-Funktion zum bereitstellen von Daten im SQS (oder vielleicht verwenden Sie DynamoDB), ich schlage vor, Sie nutzen den AWS-SDK für Visual Studio. Dort können Sie die serverlose Funktion Projekt-Vorlagen, die Sie direkt veröffentlichen Sie Ihre Funktionen.
- Stecken Sie das für Wochen und habe versucht, zu hacken um ihn herum. Das ist eine wirkliche Lösung, die ich erweitern können, um den rest meines serverlose worklfow - gut gemacht @Sudip
InformationsquelleAutor Sudip

Ja, Sie können,

Wenn Sie Sie auslösen, die Lambda-Funktion aus der API-Gateway mithilfe der Lambda-Proxy-integration die Anfrage rufen Sie die Funktion mit einer Nutzlast, die so aussieht wie das unten. Wie Sie sehen können alles, was Sie tun müssen, ist zum Parsen der JSON-Körper-Attribut.

  {
    "resource": /path",
    "path": "/path",
    "httpMethod": "PUT",
    "headers": {
      "Accept": "*/*",
      "Accept-Encoding": "gzip, deflate, sdch, br",
      "Accept-Language": "en-US,en;q=0.8,pl;q=0.6,en-GB;q=0.4",
      "Cache-Control": "no-cache",
      "CloudFront-Forwarded-Proto": "https",
      "CloudFront-Is-Desktop-Viewer": "true",
      "CloudFront-Is-Mobile-Viewer": "false",
      "CloudFront-Is-SmartTV-Viewer": "false",
      "CloudFront-Is-Tablet-Viewer": "false",
      "CloudFront-Viewer-Country": "PL",
      "Content-Type": "application/json",
      "DNT": "1",
      "Host": "api.stockflare.com",
      "Origin": "http://localhost:3000",
      "Pragma": "no-cache",
      "Referer": "http://localhost:3000/databank",
      "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/57.0.2987.133 Safari/537.36",
      "Via": "1.1 XXXXX.cloudfront.net (CloudFront)",
      "X-Amz-Cf-Id": "XXXXXX==",
      "X-Amzn-Trace-Id": "Root=XXXXXX",
      "X-Forwarded-For": "XXXXX",
      "X-Forwarded-Port": "443",
      "X-Forwarded-Proto": "https"
    },
    "queryStringParameters": null,
    "pathParameters": null,
    "stageVariables": null,
    "requestContext": {
      "path": "/path",
      "accountId": "XXXXX",
      "resourceId": "p0flbp",
      "stage": "v1",
      "requestId": "XXXXX",
      "identity": {
        "cognitoIdentityPoolId": null,
        "accountId": null,
        "cognitoIdentityId": null,
        "caller": null,
        "apiKey": "",
        "sourceIp": "XXXXXX",
        "accessKey": null,
        "cognitoAuthenticationType": null,
        "cognitoAuthenticationProvider": null,
        "userArn": null,
        "userAgent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/57.0.2987.133 Safari/537.36",
        "user": null
      },
      "resourcePath": "/path",
      "httpMethod": "PUT",
      "apiId": "XXXXXX"
    },
    "body": "{\"fields\":[\"forecast_pe\"],\"countries\":[\"_all\",\"amer\",\"apac\",\"emea\"],\"sectors\":[\"50\",\"51\"]}",
    "isBase64Encoded": false
  }

Danke @Mark. Ich acctually dem Tat es auf eine andere Weise. Habe ich eine JSON-Schema-Modell in der API-Gateway und verwendet es in der API-Körper-Vorlage. Dann holte ich alle Daten der variable verbunden, das Lambda und dann warf Sie in einer AWS SQS. Es funktioniert ziemlich gut für mich.Ich Schreibe eine eigene Antwort für diese Frage zu erklären, die gleichen.

InformationsquelleAutor Mark Stratmann

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.