Kinesis - AWS Serverless Application Model
SintassiProprietàEsempi

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Kinesis

L'oggetto che descrive un tipo di origine Kinesis dell'evento. Per ulteriori informazioni, consulta Using AWS Lambda with Amazon Kinesis nella AWS Lambda Developer Guide.

AWS SAM genera una AWS::Lambda::EventSourceMappingrisorsa quando questo tipo di evento è impostato.

Sintassi

Per dichiarare questa entità nel tuo modello AWS Serverless Application Model (AWS SAM), usa la seguente sintassi.

Proprietà

BatchSize

Il numero massimo di elementi da recuperare in un singolo batch.

Tipo: integer

Required: No

Impostazione predefinita: 100

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla BatchSize proprietà di una AWS::Lambda::EventSourceMapping risorsa.

Minimum: 1

Maximum: 10000

BisectBatchOnFunctionError

Se la funzione restituisce un errore, dividi il batch in due e riprova.

Tipo: Booleano

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla BisectBatchOnFunctionError proprietà di una AWS::Lambda::EventSourceMapping risorsa.

DestinationConfig

Una coda Amazon Simple Queue Service (Amazon SQS) o una destinazione tematica di Amazon Simple Notification Service (Amazon SNS) per i record scartati.

Tipo: DestinationConfig

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla DestinationConfig proprietà di una AWS::Lambda::EventSourceMapping risorsa.

Enabled

Disabilita la mappatura dell'origine eventi per sospendere il polling e la chiamata.

Tipo: Booleano

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla Enabled proprietà di una AWS::Lambda::EventSourceMapping risorsa.

FilterCriteria

Un oggetto che definisce i criteri per determinare se Lambda deve elaborare un evento. Per ulteriori informazioni, consulta il filtro AWS Lambda degli eventi nella Guida per gli AWS Lambda sviluppatori.

Tipo: FilterCriteria

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla FilterCriteria proprietà di una AWS::Lambda::EventSourceMapping risorsa.

FunctionResponseTypes

Un elenco dei tipi di risposta attualmente applicati alla mappatura delle sorgenti degli eventi. Per ulteriori informazioni, consulta la pagina Segnalazione di errori degli elementi batch nella Guida per gli sviluppatori di AWS Lambda .

Valori validi: ReportBatchItemFailures

Tipo: Elenco

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla FunctionResponseTypes proprietà di una AWS::Lambda::EventSourceMapping risorsa.

MaximumBatchingWindowInSeconds

Il tempo massimo in secondi per la raccolta dei record prima di richiamare la funzione.

Tipo: integer

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla MaximumBatchingWindowInSeconds proprietà di una AWS::Lambda::EventSourceMapping risorsa.

MaximumRecordAgeInSeconds

L'età massima di un record che Lambda invia a una funzione per l'elaborazione.

Tipo: integer

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla MaximumRecordAgeInSeconds proprietà di una AWS::Lambda::EventSourceMapping risorsa.

MaximumRetryAttempts

Il numero massimo di ripetizioni consentite quando la funzione restituisce un errore.

Tipo: integer

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla MaximumRetryAttempts proprietà di una AWS::Lambda::EventSourceMapping risorsa.

ParallelizationFactor

Il numero di batch da elaborare contemporaneamente da ogni shard.

Tipo: integer

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla ParallelizationFactor proprietà di una risorsa. AWS::Lambda::EventSourceMapping

StartingPosition

La posizione in un flusso da cui iniziare la lettura.

  • AT_TIMESTAMP— Specificare l'ora a partire dalla quale iniziare a leggere i record.

  • LATEST— Leggi solo i nuovi record.

  • TRIM_HORIZON— Elabora tutti i record disponibili.

Valori validi: AT_TIMESTAMP | LATEST | TRIM_HORIZON

▬Tipo: stringa

Campo obbligatorio: sì

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla StartingPosition proprietà di una AWS::Lambda::EventSourceMapping risorsa.

StartingPositionTimestamp

L'ora da cui iniziare a leggere, in secondi di tempo Unix. Definisce StartingPositionTimestamp quando StartingPosition è specificato comeAT_TIMESTAMP.

Tipo: double

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla StartingPositionTimestamp proprietà di una AWS::Lambda::EventSourceMapping risorsa.

Stream

L'Amazon Resource Name (ARN) del flusso di dati o di un consumatore di streaming.

▬Tipo: stringa

Campo obbligatorio: sì

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla EventSourceArn proprietà di una AWS::Lambda::EventSourceMapping risorsa.

TumblingWindowInSeconds

La durata, in secondi, di una finestra di elaborazione. L'intervallo valido è compreso tra 1 e 900 (15 minuti).

Per ulteriori informazioni, consulta Tumbling windows nella AWS Lambda Developer Guide.

Tipo: integer

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla TumblingWindowInSeconds proprietà di una AWS::Lambda::EventSourceMapping risorsa.

Esempi

Fonte di eventi Kinesis

Di seguito è riportato un esempio di sorgente di eventi Kinesis.

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"]}'