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.
Powiązane problemy
- 1. Szyfrowanie wartości za pomocą Amazon KMS, przechowywanie/pobieranie za pomocą DynamoDB z Lambda (NodeJS)
- 2. Jak napisać wyrażenie VB.Net Lambda
- 3. Blokowanie stanu Terraform za pomocą DynamoDB
- 4. Jak zaktualizować dokument za pomocą elasticsearch-py?
- 5. Problemy z zapytaniem dynamodb za pomocą KeyConditionExpression
- 6. Jak napisać deklarację XML za pomocą xml.etree.ElementTree
- 7. Jak napisać transfer za pomocą T-SQL
- 8. Jak wypełnić HashMap za pomocą Lambda Expression
- 9. Jak napisać kartę inteligentną za pomocą pyscard
- 10. Contains(), jak odwrócić za pomocą lambda
- 11. Jak uzyskać dane z dynamodb za pomocą api odpoczynku
- 12. Jak napisać cykl jako funkcję lambda?
- 13. Jak modelować ucznia/klasy za pomocą DynamoDB (NoSQL)
- 14. Jak mogę napisać wtyczkę do VS2010 za pomocą MEF?
- 15. jak napisać do nowej komórki w Pythonie za pomocą openpyxl
- 16. Jak powinienem obsługiwać tryb offline za pomocą DynamoDB i iOS?
- 17. Oblicz różne wartości za pomocą elasticsearch
- 18. projekt aplikacji rezerwacji samochodu za pomocą elasticsearch
- 19. elasticsearch określić kolejność sortowania za pomocą kwerendy
- 20. Jak skonfigurować Spring Boot za pomocą elasticsearch 5.2.1?
- 21. ElasticSearch wyszukiwanie pełnotekstowe za pomocą Java API
- 22. Uzyskaj nazwę metody za pomocą wyrażeń Lambda
- 23. Elasticsearch: dodawanie ręcznego mapowania za pomocą Java
- 24. Obsługa autouzupełniania nagłówków za pomocą ElasticSearch
- 25. Jak zapytać o indeks Elasticsearch za pomocą Pyspark i Dataframes
- 26. Tworzenie metod rozszerzających za pomocą wyrażeń lambda
- 27. Lambda Expression za pomocą foreach Klauzulę
- 28. Jak wykonać "sprzężenie"/"pod-zapytanie" za pomocą ElasticSearch?
- 29. Jak dodać mapowanie w ElasticSearch za pomocą JEST
- 30. napisać metodę, która akceptuje wyrażenia lambda
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 –