9

Przechodzę przez this tutorial opublikowane przez amazon. W kroku zatytułowanym "Włączanie schematu lambda" odwołuje się do planu dynamodb-to-elasticsearch. W mojej konsoli AWS nie ma takiego planu. Czy ktoś wie, jak wygląda kod Pythona dla tego projektu? Czy nie mogę tego zobaczyć z powodu mojego konkretnego konta AWS, czy AWS usunął to?Jak napisać od DynamoDB do ElasticSearch za pomocą Lambda?

+0

może wolą teraz tę metodę: http://docs.aws.amazon.com/elasticsearch-service/latest/developerguide/es-aws-integrations.html#es -aws-integrations-dynamodb-es – at0mzk

+0

Próbowałem zanim przyjrzałem się podejściu lambda, ale to doprowadziło mnie w dół [ta ścieżka] (https://github.com/awslabs/logstash-input-dynamodb/issues/21), dla którego nie wydaje się być świetne rozwiązanie –

Odpowiedz

1

Musisz upewnić się, że strumień DynamoDB jest włączony na twoim stole, w tym zarówno stary, jak i nowy obraz. Najpierw wyciągnij rekord strumienia DynamoDB z rekordu strumienia Kinesis. Następnie sprawdź, czy rekord strumienia DynamoDB reprezentuje wstawienie, aktualizację lub usunięcie. Po trzecie deleguj odpowiednio i wstawiaj odpowiedni dokument w ES, aby wstawiać i aktualizować, i usuwać odpowiedni dokument w ES w celu usunięcia.

Na razie można dostosować Python lambda handler shared here na Github - analizuje on zapisy strumieniowe i zapisuje dokumenty do ES.