Kinesis - AWS Serverless Application Model
SyntaxEigenschaftenBeispiele

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.

Kinesis

Das Objekt, das einen Kinesis Ereignisquellentyp beschreibt. Weitere Informationen finden Sie unter Verwenden von AWS Lambda mit Amazon Kinesis im AWS Lambda -Entwicklerhandbuch.

AWS SAM generiert eine -AWS::Lambda::EventSourceMappingRessource, wenn dieser Ereignistyp festgelegt ist.

Syntax

Verwenden Sie die folgende Syntax, um diese Entität in Ihrer AWS Serverless Application Model (AWS SAM)-Vorlage zu deklarieren.

Eigenschaften

BatchSize

Gibt die maximale Anzahl der Elemente an, die in einem einzigen Stapel zurückzugeben werden.

Typ: Ganzzahl

Required: No

Standard: 100

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -BatchSizeEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

Minimum: 1

Maximum: 10000

BisectBatchOnFunctionError

Wenn die Funktion einen Fehler zurückgibt, teilen Sie den Batch in zwei Teile und versuchen Sie es erneut.

Typ: Boolesch

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -BisectBatchOnFunctionErrorEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

DestinationConfig

Ein Amazon Simple Queue Service (Amazon SQS)-Warteschlangen- oder Amazon Simple Notification Service (Amazon SNS)-Themenziel für verworfene Datensätze.

Geben Sie ein: DestinationConfig

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -DestinationConfigEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

Enabled

Deaktiviert den Ereignis-Quellzuweisung zum Anhalten und Aufrufen von Abfragen.

Typ: Boolesch

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -EnabledEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

FilterCriteria

Ein Objekt, das die Kriterien definiert, um zu bestimmen, ob Lambda ein Ereignis verarbeiten soll. Weitere Informationen finden Sie unter -AWS LambdaEreignisfilterung im AWS Lambda -Entwicklerhandbuch.

Geben Sie ein: FilterCriteria

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -FilterCriteriaEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

FunctionResponseTypes

Eine Liste der Antworttypen, die derzeit auf die Ereignisquellenzuordnung angewendet werden. Weitere Informationen finden Sie unter Melden von Batch-Elementen im AWS Lambda-Leitfaden für Entwickler.

Gültige Werte: ReportBatchItemFailures

Typ : Liste

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -FunctionResponseTypesEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

MaximumBatchingWindowInSeconds

Die maximale Zeitspanne zur Erfassung von Datensätzen vor dem Aufruf der Funktion in Sekunden.

Typ: Ganzzahl

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -MaximumBatchingWindowInSecondsEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

MaximumRecordAgeInSeconds

Das maximale Alter eines Datensatzes, den Lambda zur Verarbeitung an eine Funktion sendet.

Typ: Ganzzahl

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -MaximumRecordAgeInSecondsEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

MaximumRetryAttempts

Die maximale Anzahl der Wiederholungen, wenn die Funktion einen Fehler zurückgibt.

Typ: Ganzzahl

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -MaximumRetryAttemptsEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

ParallelizationFactor

Die Anzahl der Stapel, die von jedem Shard gleichzeitig verarbeitet werden sollen.

Typ: Ganzzahl

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -ParallelizationFactorEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

StartingPosition

Die Position im Stream, an der mit dem Lesen begonnen wird.

  • AT_TIMESTAMP – Geben Sie einen Zeitpunkt an, ab dem mit dem Lesen von Datensätzen begonnen werden soll.

  • LATEST – Schreibgeschützte neue Datensätze.

  • TRIM_HORIZON – Verarbeiten Sie alle verfügbaren Datensätze.

Zulässige Werte: AT_TIMESTAMP | LATEST | TRIM_HORIZON

Typ: Zeichenfolge

Erforderlich: Ja

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -StartingPositionEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

StartingPositionTimestamp

Die Zeit, ab der mit dem Lesen begonnen werden soll, in Unix-Zeitsekunden. Definieren SieStartingPositionTimestamp, wann als angegeben StartingPosition istAT_TIMESTAMP.

Type: Double

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -StartingPositionTimestampEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

Stream

Der Amazon-Ressourcenname (ARN) des Datenstroms oder eines Stream-Konsumenten.

Typ: Zeichenfolge

Erforderlich: Ja

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -EventSourceArnEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

TumblingWindowInSeconds

Die Dauer eines Verarbeitungsfensters in Sekunden. Der gültige Bereich liegt zwischen 1 und 900 (15 Minuten).

Weitere Informationen finden Sie unter Rollierende Fenster im AWS Lambda -Entwicklerhandbuch.

Typ: Ganzzahl

Required: No

AWS CloudFormation Kompatibilität: Diese Eigenschaft wird direkt an die -TumblingWindowInSecondsEigenschaft einer -AWS::Lambda::EventSourceMappingRessource übergeben.

Beispiele

Kinesis-Ereignisquelle

Im Folgenden finden Sie ein Beispiel für eine Kinesis-Ereignisquelle.

YAML

Events:
  KinesisEvent:
    Type: Kinesis
    Properties:
      Stream: arn:aws:kinesis:us-east-1:123456789012:stream/my-stream
      StartingPosition: TRIM_HORIZON
      BatchSize: 10
      Enabled: false
      FilterCriteria: 
        Filters: 
          - Pattern: '{"key": ["val1", "val2"]}'