Kinesis

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

AWS SAM genera un 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.

YAML


  BatchSize: Integer
  BisectBatchOnFunctionError: Boolean
  DestinationConfig: DestinationConfig
  Enabled: Boolean
  FilterCriteria: FilterCriteria
  FunctionResponseTypes: List
  KmsKeyArn: String          
  MaximumBatchingWindowInSeconds: Integer
  MaximumRecordAgeInSeconds: Integer
  MaximumRetryAttempts: Integer
  MetricsConfig: MetricsConfig
  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 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 (AmazonSQS) o una destinazione tematica di Amazon Simple Notification Service (AmazonSNS) per i record scartati.

Tipo: DestinationConfig

Required: No

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

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.

KmsKeyArn

L'Amazon Resource Name (ARN) della chiave per crittografare le informazioni relative a questo evento.

Tipo: Stringa

Required: No

AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla KmsKeyArn 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.

MetricsConfig

Una configurazione opzionale per ottenere metriche avanzate per le mappature delle sorgenti degli eventi che catturano ogni fase dell'elaborazione. Per vedere un esempio, consulta MetricsConfig evento.

Tipo: MetricsConfig

Required: No

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

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

MetricsConfig evento

Di seguito è riportato un esempio di risorsa che utilizza la MetricsConfig proprietà per acquisire ogni fase dell'elaborazione per le mappature delle sorgenti degli eventi.


Resources:
  FilteredEventsFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: s3://sam-demo-bucket/metricsConfig.zip
      Handler: index.handler
      Runtime: nodejs16.x
      Events:
        KinesisStream:
          Type: Kinesis
          Properties:
            Stream: !GetAtt KinesisStream.Arn
            StartingPosition: LATEST
            MetricsConfig:
              Metrics:
              - EventCount

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

Avvertimento JavaScript è disabilitato o non è disponibile nel tuo browser.

Per usare la documentazione AWS, JavaScript deve essere abilitato. Consulta le pagine della guida del browser per le istruzioni.

Convenzioni dei documenti

IoTRule