Kinesis - AWS Serverless Application Model

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 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.

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