Kinesis

L'oggetto che descrive un tipo di origineKinesis dell'evento. Per ulteriori informazioni, consulta UtilizzoAWS Lambda con Amazon Kinesis nella Guida per gliAWS Lambda sviluppatori.

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

Sintassi

Per dichiarare questa entità nel modelloAWS Serverless Application Model (AWS SAM), utilizzare la sintassi seguente.

YAML

  BatchSize: Integer
  BisectBatchOnFunctionError: Boolean
  DestinationConfig: DestinationConfig
  Enabled: Boolean
  FilterCriteria: FilterCriteria
  FunctionResponseTypes: List
  MaximumBatchingWindowInSeconds: Integer
  MaximumRecordAgeInSeconds: Integer
  MaximumRetryAttempts: Integer
  ParallelizationFactor: Integer
  StartingPosition: String
  StartingPositionTimestamp: Double
  Stream: String
  TumblingWindowInSeconds: Integer

Proprietà

BatchSize

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

Tipo: integer

Required: No

Impostazione predefinita: 100

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaBatchSize proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Minimum: 1

Maximum: 10000

BisectBatchOnFunctionError

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

Tipo: Booleano

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaBisectBatchOnFunctionError proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

DestinationConfig

Una mappatura dell'argomento Amazon Simple Queue Service (Amazon Simple Notification Service) (Amazon SNS) per i record eliminati.

Tipo: DestinationConfig

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaDestinationConfig proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Enabled

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

Tipo: Booleano

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaEnabled proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

FilterCriteria

Un oggetto che definisce i criteri per determinare se Lambda debba elaborare un evento. Per ulteriori informazioni, consulta il filtroAWS Lambda degli eventi nella Guida per gliAWS Lambda sviluppatori.

Tipo: FilterCriteria

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaFilterCriteria proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

FunctionResponseTypes

Un elenco dei eventi. Per ulteriori informazioni, consulta Segnalazione degli errori degli articoli in batch nella Guida per gliAWS Lambda sviluppatori.

Valori validi: ReportBatchItemFailures

Tipo: Elenco

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaFunctionResponseTypes proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

MaximumBatchingWindowInSeconds

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

Tipo: integer

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaMaximumBatchingWindowInSeconds proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

MaximumRecordAgeInSeconds

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

Tipo: integer

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaMaximumRecordAgeInSeconds proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

MaximumRetryAttempts

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

Tipo: integer

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaMaximumRetryAttempts proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

ParallelizationFactor

Il numero di batch da elaborare contemporaneamente da ogni partizione.

Tipo: integer

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaParallelizationFactor proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

StartingPosition

La posizione in un flusso da cui iniziare la lettura.

• AT_TIMESTAMP— Specifica un orario a partire dal quale avviare la lettura dei record.

• LATEST— Leggi solo i nuovi record.

• TRIM_HORIZON— Elaborare tutti i record disponibili.

Valori validi: AT_TIMESTAMP | LATEST | TRIM_HORIZON

Tipo: stringa

Required: Yes

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaStartingPosition proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

StartingPositionTimestamp

Il tempo da cui avviare la lettura, in secondi di tempo Unix. DefinisceStartingPositionTimestamp quandoStartingPosition viene specificato comeAT_TIMESTAMP.

Tipo: double

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaStartingPositionTimestamp proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Stream

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

Tipo: stringa

Required: Yes

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaEventSourceArn proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

TumblingWindowInSeconds

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

Per ulteriori informazioni, consulta Tumbling windows nella Guida per gliAWS Lambda sviluppatori.

Tipo: integer

Required: No

AWS CloudFormationcompatibilità: questa proprietà viene passata direttamente allaTumblingWindowInSeconds proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Esempi

Origine eventi Kinesis

Di seguito è illustrato un esempio 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"]}'