Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
aws-kinesisstreams-lambda

Alle Klassen befinden sich in aktiver Entwicklung und unterliegen nicht abwärtskompatiblen Änderungen oder Entfernen in jeder zukünftigen Version. Diese unterliegen nicht derSemantische Versionierung
Hinweis: Um eine ordnungsgemäße Funktionalität sicherzustellen, müssen die AWS Solutions Constructs Pakete und AWS CDK-Pakete in Ihrem Projekt dieselbe Version aufweisen.
Sprache | Paket |
---|---|
![]() |
aws_solutions_constructs.aws-kinesis-streams-lambda
|
![]() |
@aws-solutions-constructs/aws-kinesisstreams-lambda
|
![]() |
software.amazon.awsconstructs.services.kinesisstreamslambda
|
Overview
Dieses AWS Solutions Construct stellt eine Kinesis Stream- und Lambda Funktion mit den entsprechenden Ressourcen/Eigenschaften für Interaktion und Sicherheit bereit.
Hier ist eine minimale bereitstellbare Musterdefinition in TypeScript:
import { KinesisStreamsToLambda } from '@aws-solutions-constructs/aws-kinesisstreams-lambda'; new KinesisStreamsToLambda(this, 'KinesisToLambdaPattern', { kinesisEventSourceProps: { startingPosition: lambda.StartingPosition.TRIM_HORIZON, batchSize: 1 }, lambdaFunctionProps: { runtime: lambda.Runtime.NODEJS_14_X, // This assumes a handler function in lib/lambda/index.js code: lambda.Code.fromAsset(`${__dirname}/lambda`), handler: 'index.handler' } });
Initializer
new KinesisStreamsToLambda(scope: Construct, id: string, props: KinesisStreamsToLambdaProps);
Parameter
-
Bereich
Construct
-
id
string
Muster-Konstrukt Requisiten
Name | Typ | Beschreibung |
---|---|---|
Gibt es LambdaObj? |
lambda.Function
|
Vorhandene Instanz des Lambda Function-Objekts, die sowohl diese als auchlambdaFunctionProps führt zu einem -Fehler. |
LambdaFunctionProps? |
lambda.FunctionProps
|
Optionale vom Benutzer bereitgestellte Eigenschaften, um die Standardeigenschaften für die Lambda Funktion zu überschreiben. Wird ignoriert, wenn einexistingLambdaObj wird bereitgestellt. |
KinesisStreamProps? |
kinesis.StreamProps
|
Optionale, vom Benutzer bereitgestellte Requisiten zum Überschreiben der Standard-Requisiten für den Kinesis Stream. |
Bestehend StreamObj? |
kinesis.Stream
|
Vorhandene Instanz von Kinesis Stream, die sowohl diese als auchkinesisStreamProps führt zu einem -Fehler. |
KinesisEventSourceProps? |
aws-lambda-event-sources.KinesisEventSourceProps
|
Optionale, vom Benutzer bereitgestellte Requisiten zum Überschreiben der Standard-Requisiten für die Lambda Ereignisquellenzuordnung. |
CreateCloudWatchalarms |
boolean
|
Gibt an, ob empfohlene CloudWatch Alarme erstellt werden sollen. |
Muster-Eigenschaften
Name | Typ | Beschreibung |
---|---|---|
KinesisisStream |
kinesis.Stream
|
Gibt eine Instanz des Kinesis Streams zurück, der durch das Muster erstellt wurde. |
LambdaFunction |
lambda.Function
|
Gibt eine Instanz der Lambda Funktion zurück, die durch das Muster erstellt wurde. |
KinesisStreamRole |
iam.Role
|
Gibt eine Instanz der IAM-Rolle zurück, die durch das Muster für den Kinesis Stream erstellt wurde. |
CloudwatChalarms? |
cloudwatch.Alarm[]
|
Gibt eine Liste eines oder mehrerer CloudWatch Alarme zurück, die durch das Muster erstellt wurden. |
Standardeinstellung
Die vorgefertigte Implementierung dieses Musters ohne Überschreibungen setzt die folgenden Standardwerte:
Amazon Kinesis Streams
-
Konfigurieren Sie die IAM-Rolle für den Zugriff auf die geringste Berechtigung für Kinesis Stream.
-
Aktivieren Sie die serverseitige Verschlüsselung für Kinesis Stream mit AWS Managed KMS Key.
-
Stellen Sie bewährte CloudWatch Alarme für den Kinesis Stream bereit.
AWS Lambda-Funktion
-
Konfigurieren Sie die IAM-Rolle für den eingeschränkten Zugriffsberechtigungen für Lambda Funktion.
-
Aktivieren Sie die Wiederverwendung von Verbindungen mit Keep-Alive für NodeJS Lambda Funktion.
-
Aktivieren Sie die X-Ray Nachverfolgung.
-
Funktionen zur Fehlerbehandlung aktivieren: Bisect bei Funktion Fehler aktivieren; Standardeinstellung Maximales Datensatzalter (24 Stunden) festlegen; Standardeinstellung Maximale Wiederholungsversuche (500) festlegen und SQS-Warteschlange für Dead-Letter als Ziel bei einem Fehler bereitstellen.
-
Festlegen von Umgebungsvariablen:
-
AWS_NODEJS_CONNECTION_REUSE_ENABLED
(für Node 10.x und höhere Funktionen)
-
Architecture

GitHub
Um den Code für dieses Muster anzuzeigen, erstellen/anzeigen Probleme und Pull-Anforderungen usw.: | |
---|---|
![]() |
@aws -solutions-constructs/aws-kinesisstreams-lambda |