Kinesis

El objeto que describe un tipo de fuente deKinesis eventos. Para obtener más información, consulte UsoAWS Lambda con Amazon Kinesis en la Guía paraAWS Lambda desarrolladores.

AWS SAMgenera un AWS::Lambda::EventSourceMappingrecurso cuando se establece este tipo de evento.

Sintaxis

Para declarar esta entidad en su plantillaAWS Serverless Application Model (AWS SAM), use la siguiente sintaxis.

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

Propiedades

BatchSize

El número máximo de elementos que se recuperan en un único lote.

Tipo: entero

Obligatorio: no

Valor predeterminado: 100

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laBatchSize propiedad de unAWS::Lambda::EventSourceMapping recurso.

Mínimo: 1

Máximo: 10000

BisectBatchOnFunctionError

Si la función devuelve un error, divida el lote en dos y vuelva a intentarlo.

Tipo: booleano

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laBisectBatchOnFunctionError propiedad de unAWS::Lambda::EventSourceMapping recurso.

DestinationConfig

Un destino de Amazon Simple Queue Service (Amazon SQS) o Amazon Simple Notification Service (Amazon SNS) para registros descartados.

Tipo: DestinationConfig

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laDestinationConfig propiedad de unAWS::Lambda::EventSourceMapping recurso.

Enabled

Deshabilita el mapeo de origen de eventos para pausar el sondeo y la invocación.

Tipo: booleano

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laEnabled propiedad de unAWS::Lambda::EventSourceMapping recurso.

FilterCriteria

Un objeto que define los criterios para determinar si Lambda debe procesar un evento. Para obtener más información, consulte el filtrado deAWS Lambda eventos en la Guía paraAWS Lambda desarrolladores.

Tipo: FilterCriteria

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laFilterCriteria propiedad de unAWS::Lambda::EventSourceMapping recurso.

FunctionResponseTypes

Una lista de origen de eventos. Para obtener más información, consulte Informar de errores en los elementos del lote en la Guía paraAWS Lambda desarrolladores.

Valores válidos: ReportBatchItemFailures

Tipo: Lista

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laFunctionResponseTypes propiedad de unAWS::Lambda::EventSourceMapping recurso.

MaximumBatchingWindowInSeconds

La cantidad de tiempo máxima para recopilar registros antes de invocar la función, en segundos.

Tipo: entero

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laMaximumBatchingWindowInSeconds propiedad de unAWS::Lambda::EventSourceMapping recurso.

MaximumRecordAgeInSeconds

La antigüedad máxima de un registro que Lambda envía a una función para su procesamiento.

Tipo: entero

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laMaximumRecordAgeInSeconds propiedad de unAWS::Lambda::EventSourceMapping recurso.

MaximumRetryAttempts

El número máximo de veces que se debe volver a intentar cuando la función devuelve un error.

Tipo: entero

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laMaximumRetryAttempts propiedad de unAWS::Lambda::EventSourceMapping recurso.

ParallelizationFactor

El número de lotes de cada partición que se procesarán simultáneamente.

Tipo: entero

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laParallelizationFactor propiedad de unAWS::Lambda::EventSourceMapping recurso.

StartingPosition

Posición del flujo donde comienza la lectura.

• AT_TIMESTAMP— Especifique el tiempo a partir del cual comenzar la lectura de los registros.

• LATEST— Solo lectura registros nuevos.

• TRIM_HORIZON— Procesar todos los registros disponibles.

Valores válidos: AT_TIMESTAMP | LATEST | TRIM_HORIZON

Tipo: cadena

Obligatorio: sí

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laStartingPosition propiedad de unAWS::Lambda::EventSourceMapping recurso.

StartingPositionTimestamp

El tiempo a partir del cual comenzar la lectura, en segundos de tiempo Unix. DefinaStartingPositionTimestamp cuándoStartingPosition se especifica comoAT_TIMESTAMP.

Tipo: doble

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laStartingPositionTimestamp propiedad de unAWS::Lambda::EventSourceMapping recurso.

Stream

El nombre de Amazon (ARN) de Amazon (ARN) del flujo de datos.

Tipo: cadena

Obligatorio: sí

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laEventSourceArn propiedad de unAWS::Lambda::EventSourceMapping recurso.

TumblingWindowInSeconds

La duración, en segundos, de una ventana de procesamiento. El intervalo válido es de 1 a 900 (15 minutos).

Para obtener más información, consulte Ventanas emergentes en la Guía paraAWS Lambda desarrolladores.

Tipo: entero

Obligatorio: no

AWS CloudFormationcompatibilidad: esta propiedad se pasa directamente a laTumblingWindowInSeconds propiedad de unAWS::Lambda::EventSourceMapping recurso.

Ejemplos

Origen Kinesis de de.

A continuación, se muestra un ejemplo de un origen de eventos de eventos de eventos de eventos de eventos de eventos de eventos de

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