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?
9
A
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.
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
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 –