Invoke Lambda basierend auf Kinesis-Aufzeichnungen Partition Key

Question

Ich habe verschiedene Arten von Daten fließen durch meine Kinesis-Streams. Jeder Datensatz hat einen anderen Partitionsschlüssel. Ich muss eine Lambda-Funktion nur aufrufen, wenn ein Datensatz mit einem bestimmten Partitionsschlüssel zum Stream hinzugefügt wurde. Gibt es eine Möglichkeit, anzugeben, dass das Lambda nur ausgelöst wird, wenn ein Partitionsschlüssel "a" gefunden wird, anstatt ein Lambda aufzurufen und dann den Partitionsschlüssel zu prüfen?

Answer 1

Es ist eher eine Design-Frage, ich weiß nicht, ob Sie das konfigurieren können. Sie können jedoch immer Lambda Chaining mit SNS verwenden.

Lambda Fuctions with SNS

für jede Ihrer Partition Key erstellen SNS Thema und konfigurieren Sie Ihr Lambda auf sie jeweils dann können Sie einen Elternteil Lambda-Funktion erstellen, die Partition Schlüssel und Objekt erhalten. Und veröffentlichen Sie diese Objekte in den jeweiligen SNS-Themen.